| "use strict";(self.webpackChunkrocketmq_docs=self.webpackChunkrocketmq_docs||[]).push([[2100],{15680:(e,n,t)=>{t.d(n,{xA:()=>p,yg:()=>m});var r=t(96540);function a(e,n,t){return n in e?Object.defineProperty(e,n,{value:t,enumerable:!0,configurable:!0,writable:!0}):e[n]=t,e}function o(e,n){var t=Object.keys(e);if(Object.getOwnPropertySymbols){var r=Object.getOwnPropertySymbols(e);n&&(r=r.filter((function(n){return Object.getOwnPropertyDescriptor(e,n).enumerable}))),t.push.apply(t,r)}return t}function c(e){for(var n=1;n<arguments.length;n++){var t=null!=arguments[n]?arguments[n]:{};n%2?o(Object(t),!0).forEach((function(n){a(e,n,t[n])})):Object.getOwnPropertyDescriptors?Object.defineProperties(e,Object.getOwnPropertyDescriptors(t)):o(Object(t)).forEach((function(n){Object.defineProperty(e,n,Object.getOwnPropertyDescriptor(t,n))}))}return e}function i(e,n){if(null==e)return{};var t,r,a=function(e,n){if(null==e)return{};var t,r,a={},o=Object.keys(e);for(r=0;r<o.length;r++)t=o[r],n.indexOf(t)>=0||(a[t]=e[t]);return a}(e,n);if(Object.getOwnPropertySymbols){var o=Object.getOwnPropertySymbols(e);for(r=0;r<o.length;r++)t=o[r],n.indexOf(t)>=0||Object.prototype.propertyIsEnumerable.call(e,t)&&(a[t]=e[t])}return a}var l=r.createContext({}),g=function(e){var n=r.useContext(l),t=n;return e&&(t="function"==typeof e?e(n):c(c({},n),e)),t},p=function(e){var n=g(e.components);return r.createElement(l.Provider,{value:n},e.children)},s="mdxType",u={inlineCode:"code",wrapper:function(e){var n=e.children;return r.createElement(r.Fragment,{},n)}},d=r.forwardRef((function(e,n){var t=e.components,a=e.mdxType,o=e.originalType,l=e.parentName,p=i(e,["components","mdxType","originalType","parentName"]),s=g(t),d=a,m=s["".concat(l,".").concat(d)]||s[d]||u[d]||o;return t?r.createElement(m,c(c({ref:n},p),{},{components:t})):r.createElement(m,c({ref:n},p))}));function m(e,n){var t=arguments,a=n&&n.mdxType;if("string"==typeof e||a){var o=t.length,c=new Array(o);c[0]=d;var i={};for(var l in n)hasOwnProperty.call(n,l)&&(i[l]=n[l]);i.originalType=e,i[s]="string"==typeof e?e:a,c[1]=i;for(var g=2;g<o;g++)c[g]=t[g];return r.createElement.apply(null,c)}return r.createElement.apply(null,t)}d.displayName="MDXCreateElement"},93764:(e,n,t)=>{t.r(n),t.d(n,{assets:()=>l,contentTitle:()=>c,default:()=>u,frontMatter:()=>o,metadata:()=>i,toc:()=>g});var r=t(58168),a=(t(96540),t(15680));const o={},c="RocketMQ EventBridge \u5feb\u901f\u5f00\u59cb",i={unversionedId:"eventbridge/03RocketMQEventBridgeQuickStart",id:"version-5.0/eventbridge/03RocketMQEventBridgeQuickStart",title:"RocketMQ EventBridge \u5feb\u901f\u5f00\u59cb",description:"RocketMQ EventBridge \u9700\u8981\u4e00\u4e2a\u6d88\u606f\u670d\u52a1\u6765\u5b58\u50a8\u4e8b\u4ef6\uff0c\u53e6\u5916\u9700\u8981\u4e00\u4e2aRuntime\u6765\u8ba2\u9605\u5e76\u63a8\u9001\u4e8b\u4ef6\u3002\u8fd9\u91cc\u6211\u4eec\u9009\u62e9 Apache RocketMQ \u4f5c\u4e3a\u6211\u4eec\u7684\u6d88\u606f\u670d\u52a1\uff0c\u9009\u62e9 Apache RocketMQ Connect \u4f5c\u4e3a\u6211\u4eec\u7684Runtime\u6765\u8ba2\u9605\u548c\u63a8\u9001\u4e8b\u4ef6\u3002\u5f53\u7136\uff0c\u60a8\u4e5f\u53ef\u4ee5\u9009\u62e9\u5176\u4ed6\u6d88\u606f\u670d\u52a1\u4ee3\u66ff\uff0cEventBridge\u5e76\u4e0d\u5bf9\u6b64\u505a\u9650\u5236\u3002\u672a\u6765EventBridge\u4e5f\u8ba1\u5212\u57fa\u4e8eOpenMessaging Connect API \u5b9e\u73b0\u81ea\u5df1\u7684Runtime\uff0c\u4ee5\u4fbf\u66f4\u597d\u7684\u63d0\u4f9b\u4e8b\u4ef6\u9a71\u52a8\u670d\u52a1\u3002",source:"@site/versioned_docs/version-5.0/07-eventbridge/03RocketMQEventBridgeQuickStart.md",sourceDirName:"07-eventbridge",slug:"/eventbridge/03RocketMQEventBridgeQuickStart",permalink:"/zh/docs/eventbridge/03RocketMQEventBridgeQuickStart",draft:!1,editUrl:"https://github.com/apache/rocketmq-site/tree/new-official-website/versioned_docs/version-5.0/07-eventbridge/03RocketMQEventBridgeQuickStart.md",tags:[],version:"5.0",frontMatter:{},sidebar:"version-5.0/myAutogeneratedSidebar",previous:{title:"RocketMQ EventBridge \u6982\u89c8",permalink:"/zh/docs/eventbridge/02RocketMQEventBridgeOverview"},next:{title:"RocketMQ MQTT \u6982\u89c8",permalink:"/zh/docs/mqtt/01RocketMQMQTTOverview"}},l={},g=[{value:"\u90e8\u7f72Apache RocketMQ",id:"\u90e8\u7f72apache-rocketmq",level:2},{value:"\u90e8\u7f72Apache RocketMQ Connect",id:"\u90e8\u7f72apache-rocketmq-connect",level:2},{value:"\u90e8\u7f72RocketMQ EventBridge",id:"\u90e8\u7f72rocketmq-eventbridge",level:2},{value:"Demo",id:"demo",level:2}],p={toc:g},s="wrapper";function u(e){let{components:n,...o}=e;return(0,a.yg)(s,(0,r.A)({},p,o,{components:n,mdxType:"MDXLayout"}),(0,a.yg)("h1",{id:"rocketmq-eventbridge-\u5feb\u901f\u5f00\u59cb"},"RocketMQ EventBridge \u5feb\u901f\u5f00\u59cb"),(0,a.yg)("p",null,"RocketMQ EventBridge \u9700\u8981\u4e00\u4e2a\u6d88\u606f\u670d\u52a1\u6765\u5b58\u50a8\u4e8b\u4ef6\uff0c\u53e6\u5916\u9700\u8981\u4e00\u4e2aRuntime\u6765\u8ba2\u9605\u5e76\u63a8\u9001\u4e8b\u4ef6\u3002\u8fd9\u91cc\u6211\u4eec\u9009\u62e9 Apache RocketMQ \u4f5c\u4e3a\u6211\u4eec\u7684\u6d88\u606f\u670d\u52a1\uff0c\u9009\u62e9 Apache RocketMQ Connect \u4f5c\u4e3a\u6211\u4eec\u7684Runtime\u6765\u8ba2\u9605\u548c\u63a8\u9001\u4e8b\u4ef6\u3002\u5f53\u7136\uff0c\u60a8\u4e5f\u53ef\u4ee5\u9009\u62e9\u5176\u4ed6\u6d88\u606f\u670d\u52a1\u4ee3\u66ff\uff0cEventBridge\u5e76\u4e0d\u5bf9\u6b64\u505a\u9650\u5236\u3002\u672a\u6765EventBridge\u4e5f\u8ba1\u5212\u57fa\u4e8eOpenMessaging Connect API \u5b9e\u73b0\u81ea\u5df1\u7684Runtime\uff0c\u4ee5\u4fbf\u66f4\u597d\u7684\u63d0\u4f9b\u4e8b\u4ef6\u9a71\u52a8\u670d\u52a1\u3002"),(0,a.yg)("p",null,"\u7cfb\u7edf\u8981\u6c42:"),(0,a.yg)("ul",null,(0,a.yg)("li",{parentName:"ul"},"64\u4f4d\u64cd\u4f5c\u7cfb\u7edf\uff0c\u63a8\u8350 Linux/Unix/macOS"),(0,a.yg)("li",{parentName:"ul"},"64\u4f4d JDK 1.8+")),(0,a.yg)("h2",{id:"\u90e8\u7f72apache-rocketmq"},"\u90e8\u7f72Apache RocketMQ"),(0,a.yg)("p",null,"Apache RocketMQ \u662f\u4e00\u4e2a\u5f88\u68d2\u7684\u6d88\u606f\u670d\u52a1\uff0c\u6211\u4eec\u9ed8\u8ba4\u9009\u62e9\u5b83\u4f5c\u4e3aEventBus\u7684\u9ed8\u8ba4\u5b58\u50a8\u3002\u8fd9\u91cc\u60a8\u53ef\u4ee5\u6839\u636e\u8fd9\u4e2a\u624b\u518c\u5feb\u901f\u90e8\u7f72: ",(0,a.yg)("a",{parentName:"p",href:"https://rocketmq.apache.org/docs/quick-start/"},"Apache RocketMQ Quick Start")),(0,a.yg)("h2",{id:"\u90e8\u7f72apache-rocketmq-connect"},"\u90e8\u7f72Apache RocketMQ Connect"),(0,a.yg)("p",null,"\u6211\u4eec\u4f7f\u7528Apache RocketMQ Connect\u4f5c\u4e3a\u6211\u4eec\u7684\u9ed8\u8ba4Runtime\uff0c\u6765\u8fde\u63a5\u5916\u90e8\u7684\u4e0a\u4e0b\u6e38\u670d\u52a1\uff0c\u60a8\u53ef\u4ee5\u6839\u636e\u624b\u518c\u5b8c\u6210\u90e8\u7f72: ",(0,a.yg)("a",{parentName:"p",href:"https://github.com/apache/rocketmq-connect"},"RocketMQ Connect Quick Start")," \u3002\u5728\u90e8\u7f72 Apache RocketMQ Connect \u4e4b\u524d\uff0c\u60a8\u5e94\u8be5\u4e0b\u8f7d\u4e0b\u9762\u7684\u63d2\u4ef6\uff0c\u5e76\u5c06\u5176\u653e\u5728rocketmq-connect\u4e2d\u914d\u7f6e\u53c2\u6570\u201cpluginPaths\u201d\u6240\u5b9a\u4e49\u7684\u76ee\u5f55\u4e0b\uff1a"),(0,a.yg)("ul",null,(0,a.yg)("li",{parentName:"ul"},(0,a.yg)("a",{parentName:"li",href:"https://cn-hangzhou-eventbridge.oss-cn-hangzhou.aliyuncs.com/rocketmq-connect-eventbridge-0.0.1-SNAPSHOT-jar-with-dependencies.jar"},"rocketmq-connect-eventbridge-jar-with-dependencies.jar")),(0,a.yg)("li",{parentName:"ul"},(0,a.yg)("a",{parentName:"li",href:"https://cn-hangzhou-eventbridge.oss-cn-hangzhou.aliyuncs.com/rocketmq-connect-dingtalk-1.0-SNAPSHOT-jar-with-dependencies.jar"},"rocketmq-connect-dingtalk-jar-with-dependencies.jar")),(0,a.yg)("li",{parentName:"ul"},(0,a.yg)("a",{parentName:"li",href:"https://cn-hangzhou-eventbridge.oss-cn-hangzhou.aliyuncs.com/connect-cloudevent-transform-1.0.0-SNAPSHOT-jar-with-dependencies.jar"},"connect-cloudevent-transform-jar-with-dependencies.jar")),(0,a.yg)("li",{parentName:"ul"},(0,a.yg)("a",{parentName:"li",href:"https://cn-hangzhou-eventbridge.oss-cn-hangzhou.aliyuncs.com/connect-filter-transform-1.0.0-SNAPSHOT-jar-with-dependencies.jar"},"connect-filter-transform-jar-with-dependencies.jar")),(0,a.yg)("li",{parentName:"ul"},(0,a.yg)("a",{parentName:"li",href:"https://cn-hangzhou-eventbridge.oss-cn-hangzhou.aliyuncs.com/connect-eventbridge-transform-1.0.0-SNAPSHOT-jar-with-dependencies.jar"},"connect-eventbridge-transform-jar-with-dependencies.jar"))),(0,a.yg)("h2",{id:"\u90e8\u7f72rocketmq-eventbridge"},"\u90e8\u7f72RocketMQ EventBridge"),(0,a.yg)("ul",null,(0,a.yg)("li",{parentName:"ul"},"\u83b7\u53d6 EventBridge")),(0,a.yg)("p",null,"\u4f60\u53ef\u4ee5\u4ece",(0,a.yg)("a",{parentName:"p",href:"https://www.apache.org/dyn/closer.cgi?path=rocketmq/rocketmq-eventbridge/1.0.0/rocketmq-eventbridge-1.0.0-bin-release.zip"},"\u8fd9\u91cc"),"\u4e0b\u8f7dEventBridge\u7684\u4e8c\u8fdb\u5236\u5305\uff1arocketmq-eventbridge-xxx-bin-release.zip,\u4e0b\u8f7d\u5b8c\u6bd5\u540e\u8fdb\u884c\u89e3\u538b\u7f29\uff0c\u4f60\u4f1a\u5f97\u5230\u4e00\u4e2a\u5982\u4e0b\u76ee\u5f55\uff1a"),(0,a.yg)("pre",null,(0,a.yg)("code",{parentName:"pre",className:"language-text"},"/rocketmq-eventbridge-xxx-bin-release/\n|\u2014\u2014bin\n| |\u2014\u2014runserver.sh\n| |\u2014\u2014eventbridge.sh\n|\u2014\u2014config\n| |\u2014\u2014application.properties\n|\u2014\u2014jar\n| |\u2014\u2014rocketmq-eventbridge.jar\n")),(0,a.yg)("ul",null,(0,a.yg)("li",{parentName:"ul"},"\u914d\u7f6e EventBridge")),(0,a.yg)("p",null,"\u8fd0\u884c\u524d\uff0c\u6211\u4eec\u9700\u8981\u914d\u7f6eEventBridge\u7684\u8fd0\u884c\u73af\u5883\uff0c\u4fee\u6539config/application.properties,\u53c2\u8003\u5982\u4e0b\uff1a"),(0,a.yg)("pre",null,(0,a.yg)("code",{parentName:"pre",className:"language-properties"},"# Mysql\u6570\u636e\u5e93\u7684\u8fde\u63a5\u5730\u5740\nspring.datasource.url=jdbc:mysql://xxxx:3306/xxxx?characterEncoding=utf8\nspring.datasource.username=xxx\nspring.datasource.password=xxxx\n\n# RocketMQ nameserver\u7684\u8fde\u63a5\u5730\u5740\nrocketmq.namesrvAddr=xxxxx:9876\n\n# RocketMQ\u7684\u96c6\u7fa4\u540d\u79f0.\nrocketmq.cluster.name=DefaultCluster\n\n# RocketMQ Connect\u7684\u8fde\u63a5\u5730\u5740\nrocketmq.connect.endpoint=xxxxxx:8082\n\n# log\u9ed8\u8ba4\u914d\u7f6e\nlog.path=\uff5e\nlog.level=INFO\napp.name=rocketmq-eventbridge\n")),(0,a.yg)("ul",null,(0,a.yg)("li",{parentName:"ul"},"\u542f\u52a8 EventBridge")),(0,a.yg)("pre",null,(0,a.yg)("code",{parentName:"pre",className:"language-shell"},"sh bin/eventbridge.sh start \n")),(0,a.yg)("p",null,"log\u9ed8\u8ba4\u76ee\u5f55\u4e3a\uff5e/rocketmq-eventbridge/rocketmq-eventbridge.log,\u53ef\u4ee5\u4fee\u6539\u4e0a\u8ff0log.path\u548capp.name\u8fdb\u884c\u4fee\u6539\u3002\u53ef\u4ee5\u901a\u8fc7\u65e5\u5fd7\u6765\u89c2\u5bdf\u670d\u52a1\u662f\u5426\u6b63\u5e38\u542f\u52a8\uff1a\n",(0,a.yg)("img",{alt:"img.png",src:t(20385).A,width:"3540",height:"612"})),(0,a.yg)("ul",null,(0,a.yg)("li",{parentName:"ul"},"\u6d4b\u8bd5 EventBridge")),(0,a.yg)("p",null,"\u5f53\u670d\u52a1\u542f\u52a8\u540e\uff0c\u6211\u4eec\u5c31\u53ef\u4ee5\u901a\u8fc7\u4e0b\u9762\u7684Demo\u7528\u4f8b\u6765\u6d4b\u8bd5\u548c\u9a8c\u8bc1EventBridge\u3002"),(0,a.yg)("h2",{id:"demo"},"Demo"),(0,a.yg)("h4",{id:""}),(0,a.yg)("ul",null,(0,a.yg)("li",{parentName:"ul"},"\u521b\u5efa\u4e8b\u4ef6\u603b\u7ebf")),(0,a.yg)("pre",null,(0,a.yg)("code",{parentName:"pre",className:"language-text"},'POST /bus/createEventBus HTTP/1.1\nHost: demo.eventbridge.com\nContent-Type: application/json; charset=utf-8\n{\n"eventBusName":"demo-bus",\n"description":"a demo bus."\n}\n')),(0,a.yg)("ul",null,(0,a.yg)("li",{parentName:"ul"},"\u521b\u5efa\u4e8b\u4ef6\u6e90")),(0,a.yg)("pre",null,(0,a.yg)("code",{parentName:"pre",className:"language-text"},'POST /source/createEventSource HTTP/1.1\nHost: demo.eventbridge.com\nContent-Type: application/json; charset=utf-8\n{\n"eventBusName":"demo-bus",\n"eventSourceName":"demo-source",\n"description":"A demo source."\n}\n')),(0,a.yg)("ul",null,(0,a.yg)("li",{parentName:"ul"},"\u521b\u5efa\u4e8b\u4ef6\u89c4\u5219")),(0,a.yg)("pre",null,(0,a.yg)("code",{parentName:"pre",className:"language-text"},'POST /rule/createEventRule HTTP/1.1\nHost: demo.eventbridge.com\nContent-Type: application/json; charset=utf-8\n{\n "eventBusName":"demo-bus",\n "eventRuleName":"demo-rule",\n "description":"A demo rule.",\n "filterPattern":"{}"\n}\n')),(0,a.yg)("ul",null,(0,a.yg)("li",{parentName:"ul"},"\u521b\u5efa\u4e8b\u4ef6\u76ee\u6807")),(0,a.yg)("p",null,"\u521b\u5efa\u4e00\u4e2a\u6295\u9012\u5230\u4e91\u4e0aEventBridge\u7684\u4e8b\u4ef6\u76ee\u6807\uff1a"),(0,a.yg)("pre",null,(0,a.yg)("code",{parentName:"pre",className:"language-text"},'POST /target/createEventTargets HTTP/1.1\nHost: demo.eventbridge.com\nContent-Type: application/json; charset=utf-8\n{\n "eventBusName":"demo-bus",\n "eventRuleName":"demo-rule",\n "eventTargets":[\n {\n "eventTargetName":"eventbridge-target",\n "className":"acs.eventbridge",\n "config":{\n "RegionId":"cn-hangzhou",\n "AliyunEventBus":"rocketmq-eventbridge"\n }\n }\n ]\n}\n')),(0,a.yg)("p",null,"\u521b\u5efa\u4e00\u4e2a\u6295\u9012\u5230\u9489\u9489\u673a\u5668\u4eba\u63a8\u9001\u901a\u77e5\u7684\u4e8b\u4ef6\u76ee\u6807\uff1a"),(0,a.yg)("pre",null,(0,a.yg)("code",{parentName:"pre",className:"language-text"},'POST /target/createEventTargets HTTP/1.1\nHost: demo.eventbridge.com\nContent-Type: application/json; charset=utf-8\n{\n "eventBusName":"demo-bus",\n "eventRuleName":"demo-rule",\n "eventTargets":[\n {\n "eventTargetName":"dingtalk-target",\n "className":"acs.dingtalk",\n "config":{\n "WebHook":"https://oapi.dingtalk.com/robot/send?access_token=b43a54b702314415c2acdae97eda1e092528b7a9dddb31510a5b4430be2ef867",\n "SecretKey":"SEC53483bf496b8f9e0b4ab0ab669d422208e6ccfaedfd5120ea6b8426b9ecd47aa",\n "Body":"{\\"template\\":\\"{\\\\\\"text\\\\\\":{\\\\\\"content\\\\\\":\\\\\\"${content}\\\\\\"},\\\\\\"msgtype\\\\\\":\\\\\\"text\\\\\\"}\\",\\"form\\":\\"TEMPLATE\\",\\"value\\":\\"{\\\\\\"content\\\\\\":\\\\\\"$.data.body\\\\\\"}\\"}"\n }\n }\n ]\n}\n')),(0,a.yg)("ul",null,(0,a.yg)("li",{parentName:"ul"},(0,a.yg)("p",{parentName:"li"},"\u53d1\u9001\u4e8b\u4ef6\u5230EventBus"),(0,a.yg)("p",{parentName:"li"},"\u6700\u540e\uff0c\u6211\u4eec\u901a\u8fc7API\u53d1\u9001\u4e00\u6761\u4e8b\u4ef6\uff0c\u5e76\u9a8c\u8bc1Target\u7aef\u662f\u5426\u6309\u9884\u671f\u6536\u5230\u5bf9\u5e94\u7684\u4e8b\u4ef6\u3002"))),(0,a.yg)("pre",null,(0,a.yg)("code",{parentName:"pre",className:"language-text"},'POST /putEvents HTTP/1.1\nHost: demo.eventbridge.com\nContent-Type:"application/cloudevents+json; charset=UTF-8"\n{\n "specversion" : "1.0",\n "type" : "com.github.pull_request.opened",\n "source" : "https://github.com/cloudevents/spec/pull",\n "subject" : "123",\n "id" : "A234-1234-1234",\n "time" : "2018-04-05T17:31:00Z",\n "datacontenttype" : "application/json",\n "data" : {\n "body":"demo"\n },\n "aliyuneventbusname":"demo-bus"\n}\n')))}u.isMDXComponent=!0},20385:(e,n,t)=>{t.d(n,{A:()=>r});const r=t.p+"assets/images/Started-284e7a8c9a25eecdff4498d093654fac.png"}}]); |