事件中心

事件中心承载整个系统的消息总线，提供高可靠的事件分发机制。事件流转过程如下图所示。

通过事件中心实现消息队列分为五个步骤

• 在应用服务管理中添加事件中心
• 写一个服务触发事件
• 写一个服务接收事件
• 设置事件订阅列表trigger，指定事件的接收服务
• 发布应用，调用服务触发事件，事件中心调用接收服务

1. 事件中心支持三种通道

应用市场中提供了事件中心应用

事件中心支持 redis、kafka 和 nats三种通道，默认使用 redis，如果使用第三方 redis，必须是5.0以上的版本。nats 目前尚未支持。使用第三方通道时，在应用配置的环境配置中配置通道参数，如下图所示。

2. 订阅第三方kafka事件

事件中心默认使用 redis，如果第三方触发的是 kafka 事件，需要将 redis 和 nats 的禁用服务设置为 true，kafka 的禁用服务设置为 false，同时设置 kafka 的端口和服务地址。

参考事件订阅一节，实现订阅第三方事件

3. 第三方订阅kafka事件

• 使用第三方的 kafka 集群，则在事件中心应用上配置 kafka 参数
• 使用平台集成的 kafka 集群，则添加 kafkaSimple 集群应用，会创建出 kafka 集群

平台集成的 kafka 集群，如需外部访问，还需将IP及端口映射到外网

参考事件触发一节，实现事件触发，第三方订阅后，即可收到触发的事件