Skip to main content
版本：v1.10.0

Event Bridge

event-bridge

Event Bridge 可以支持跨 mesh 集群的消息投递，下面展示这一功能的详细设计与体验步骤

event-bridge-detail

注：在本地体验这一功能时需要启动两台 EventMesh 实例，同时要修改eventmesh-runtime目录下的eventmesh.properties文件中的端口配置，避免端口冲突。便于下文描述，event-bridge 特性按照上图信息进行表述。

01 远程订阅​

描述：向 cluster2 EventMesh 发起远程订阅指令，cluster2 EventMesh 收到指令后会携带订阅信息调用 cluster1 EventMesh 的本地订阅接口

URL: http://{cluster2 address}/eventmesh/subscribe/remote

请求方式：POST

请求参数：application/json 格式

参数名类型是否必填说明
urlString是标识订阅 url 信息，暂时无用，后续可移除，目前仅为强校验，实际会被（/eventmesh/bridge/publish）替换
consumerGroupString是标识消费组信息，实际会被 cluster2 的 EventMesh 配置信息替换
topicList是标识订阅信息列表
modeString是标识消费模式，分为集群模式和广播模式
topicString是标识订阅的 topic
typeString是标识消费类型，分为同步和异步
remoteMeshString否标识远程 mesh 地址，优先根据 topic 从注册中心获取，获取不到使用该字段替换

请求样例：

{
  "url": "http://127.0.0.1:8088/sub/test",
  "consumerGroup": "TEST-GROUP",
  "topic": [
    {
      "mode": "CLUSTERING",
      "topic": "TEST-TOPIC-HTTP-ASYNC",
      "type": "ASYNC"
    }
  ],
  "remoteMesh" : "http://127.0.0.1:10105/eventmesh/subscribe/local"
}

02 本地订阅​

描述：向 cluster2 的 EventMesh 实例发起本地订阅指令，cluster2 的 EventMesh 收到订阅指令后会启动本地监听从 Event Store 收下来的消息，并推送给订阅信息中的 url。

URL: http://{cluster2 address}/eventmesh/subscribe/local

请求方式：POST

请求参数：application/json 格式

参数名类型是否必填说明
urlString是标识订阅 url 信息
consumerGroupString是标识消费组信息
topicList是标识订阅信息列表
modeString是标识消费模式，分为集群模式和广播模式
topicString是标识订阅的 topic
typeString是标识消费类型，分为同步和异步

请求样例：

{
  "url": "http://127.0.0.1:8088/sub/test",
  "consumerGroup": "TEST-GROUP",
  "topic": [
    {
      "mode": "CLUSTERING",
      "topic": "TEST-TOPIC-HTTP-ASYNC",
      "type": "ASYNC"
    }
  ]
}

03 发送消息​

描述：向 cluster1 的 EventMesh 实例发送消息，cluster1 的 EventMesh 收到消息后会发送到 Event Store，再从 Event Store 收下来消息推送给 cluster2 的 EventMesh url /eventmesh/bridge/publish。

URL: http://{cluster1 address}/eventmesh/publish/TEST-TOPIC-HTTP-ASYNC

请求方式：POST

请求参数：application/json 格式

请求样例：

{
    "name": "test",
    "age": "19"
}

04 远程去订阅​

描述：向 cluster2 的 EventMesh 实例发送去除订阅指令，cluster2 的 EventMesh 收到指令后会发送 cluster1 的 EventMesh，cluster1 的 EventMesh 会本地执行去除订阅

URL: http://{cluster2 address}/eventmesh/unsubscribe/remote

请求方式：POST

请求参数：application/json 格式

参数名类型是否必填说明
urlString是标识要去除订阅 url 信息，暂时无用，后续可移除，目前仅为强校验，实际会被（/eventmesh/bridge/publish）替换
consumerGroupString是标识要去除的消费组信息，实际会使用 EventMesh cluster2 的 group 信息替换
topicList是标识订阅 topic 信息列表

请求样例：

{
  "consumerGroup": "EventMeshTest-consumerGroup",
  "url": "http://127.0.0.1:8088/sub/test",
  "topic": [
    "TEST-TOPIC-HTTP-ASYNC"
  ]
}

05 本地去订阅​

描述：向 cluster2 的 EventMesh 实例发送去除订阅指令，cluster2 的 EventMesh 收到指令后会本地执行去除订阅

URL: http://{cluster2 address}/eventmesh/unsubscribe/local

请求方式：POST

请求参数：application/json 格式

参数名类型是否必填说明
urlString是标识要去除订阅 url 信息
consumerGroupString是标识要去除的消费组信息
topicList是标识订阅 topic 信息列表

请求样例：

{
  "consumerGroup": "EventMeshTest-consumerGroup",
  "url": "http://127.0.0.1:8088/sub/test",
  "topic": [
    "TEST-TOPIC-HTTP-ASYNC"
  ]
}