Apache RocketMQ EventBridge：构建下一代事件驱动引擎 _云计算

作者：沈林

## 前言

事件驱动，这个词在部分人印象中，它是一个过时的技术——没什么新意。从时间上看，确实也是这样，上世纪 60 年代，事件驱动就已经被正式提出，经常会被在 GUI 编程中。但是在有些人印象中，事件驱动又是一个非常陌生，非常新颖的技术。

不管怎么样，现实是已经有越来越多的公司，开始或则经把事件驱动架构应用到企业的核心业务中，包括：阿里巴巴、喜力、联合利华、美国联邦航空管理局、银行资本市场等等。市场上，也有很多公司推出了自己的产品或解决方案，比如阿里云、AWS、Google，Solace。行业里也孕育出了事件的标准：CloudEventsGartener，则把事件驱动定义为未来十大趋势之一；

这个时候，我们就要问了，事件驱动架构到底是什么呢？为什么现在，被越来越多的人，开始关注事件驱动架构了呢？

![1.png](http://www.zzvips.com/uploads/allimg/5d6c8aa7ad954cf79e6ec639be1b71b1~tplv-k3u1fbpfcp-watermark.image)5 月 28 日，GOTC 2023 全球开源技术峰会上，阿里云智能技术专家沈林发表主题演讲：Apache RocketMQ 事件驱动引擎。![2.png](http://www.zzvips.com/uploads/allimg/0cf92c37c40641a5977bb0a5aa49b4be~tplv-k3u1fbpfcp-watermark.png](http://www.zzvips.com/uploads/allimg/9257b6ee4f154966a842fced1e847eca~tplv-k3u1fbpfcp-watermark.png](http://www.zzvips.com/uploads/allimg/0e35f8c863a04f84ae58e9cc2ed31ebe~tplv-k3u1fbpfcp-watermark.png](http://www.zzvips.com/uploads/allimg/9cb5090c28e84902882fb00138d6a2ca~tplv-k3u1fbpfcp-watermark.png](http://www.zzvips.com/uploads/allimg/efd239e0cace407e8bd822d05ed7beec~tplv-k3u1fbpfcp-watermark.png](http://www.zzvips.com/uploads/allimg/k3u1fbpfcp-watermark.image)如果在事件驱动架构中，客户的营销系统，需要怎么做呢？他什么都不需要，只要登高一声大喊：“我需要什么样的订单事件格式，我提供一个 API，其他系统就按这个订单事件格式发给我就可以了”。EventBroker 会将上游的事件转换成客户营销系统需要的数据格式，发送给他的 API。不管接多少系统的交易订单、不管外部系统怎么变，反正我不变。![8.png](http://www.zzvips.com/uploads/allimg/c074c2ad97354507a383af9159f5ca5d~tplv-k3u1fbpfcp-watermark.png

#### 2、耦合方向

这里我们分析下这三种方式的耦合关系：我们要知道，耦合是有方向性的。

*   方式 1-直接调用:是上游 A 依赖下游 B；（一旦下游 B 发生改变，A 需要同步的改变）
*   方式 2-消息异步解偶：是 B 依赖于 A；（一旦上游 A 的数据格式，发生改变，B 需要同步的改变）
*   方式 3-事件驱动：A 不依赖于 B，B 也不依赖于 A；（所有的耦合，都由中间的 Event Broker 来统一处理和维护）

![9.png](http://www.zzvips.com/uploads/allimg/dcb139420d1f46b6b1b6e150e5e7fe56~tplv-k3u1fbpfcp-watermark.png](http://www.zzvips.com/uploads/allimg/2064b8ffa74447a4b58f3d329b69caf2~tplv-k3u1fbpfcp-watermark.png](http://www.zzvips.com/uploads/allimg/cdae72caae994e41b9f61fd68557eea9~tplv-k3u1fbpfcp-watermark.png](http://www.zzvips.com/uploads/allimg/6b1fa848e6694d7c92eff45b05869c34~tplv-k3u1fbpfcp-watermark.png](http://www.zzvips.com/uploads/allimg/eef4b748b56040ad817e9e2df73db94d~tplv-k3u1fbpfcp-watermark.png](http://www.zzvips.com/uploads/allimg/fcd363e0aed14863ad4a4b7134117bcf~tplv-k3u1fbpfcp-watermark.png

### 如何描述事件

关于刚才提到的第一点事件标准，这个很重要。事件标准，就相当于不同系统之间交流的语言，如果语言都不通，相互交流肯定会出很多问题。我们推荐使用 CNCF 旗下的开源 CloudEvents 协议，目前已经很多公司广泛集成，算是一个事实上的标准。CloudEvent 协议也很简单，我们有一个简单的例子, 详细可以参考官网 **\[** **1]** ：

```
{
  "specversion":"1.0",
  "type":"com.github.pull_request.opened",
  "source":"https://github.com/cloudevents",
  "subject":"123",
  "id":"A234-1234-1234",
  "time":"2018-04-05T17:31:00Z",
  "comexampleextension1":"value",
  "comexampleothervalue":5,
  "datacontenttype":"text/xml",
  "data":"<much wow=\"xml\"/>"
}
```

### 事件中心

另外，我们必须得有一个事件中心。事件中心对于事件驱动架构来说，是非常重要的一个角色。他就像我们刚才说的市场经济的大卖场，所有的事件，在这个大卖场里，都有详细的使用说明，大家都可以进来瞧一瞧，看一看，觉得合适，就订阅买走。

至于事件中心如何管理，我们可以从API管理里学习很多经验：我们知道 API 包含注册、Schema 描述、Sample、文档、SDK、测试、监控。Event，其实也是一样，它需要在事件中心被注册，定义 Schema 描述、Sample、文档、CodeBinding、测试、监控。

这样消费者拿到这个事件的时候，才知道是什么，怎么用，用的放心。

![15.png](http://www.zzvips.com/uploads/allimg/ba93cc92f183404f9c0e7c4c2c5abf68~tplv-k3u1fbpfcp-watermark.png](http://www.zzvips.com/uploads/allimg/6638159172fe46f49841a37f1dd5e92a~tplv-k3u1fbpfcp-watermark.png](http://www.zzvips.com/uploads/allimg/a660364c83fb40eb8f1f41cefd84c1dd~tplv-k3u1fbpfcp-watermark.png

## 欢迎加入我们

大家如果想进一步了解 EventBridge，可以点击下方链接，也可以一起参与社区的建设。

RocketMQ EventBridge：

*<https://github.com/apache/rocketmq-eventbridge>*

**RocketMQ 学习社区体验地址**

RocketMQ 学习社区重磅上线！AI 互动，一秒了解 RocketMQ 功能源码。RocketMQ 学习社区是国内首 个基于 AIGC 提供的知识服务社区，旨在成为 RocketMQ 学习路上的“贴身小二”。

> *PS：RocketMQ 社区以 RocketMQ 5.0 资料为主要训练内容，持续优化迭代中，回答内容均由人工智能模型生成，其准确性和完整性无法保证，且不代表 RocketMQ 学习社区的态度或观点。*