Skip to main content
版本:Next

RabbitMQ

RabbitMQSinkConnector:从 EventMesh 到 RabbitMQ

  1. 启动你的 RabbitMQ 和 EventMesh Runtime。
  2. 启用 sinkConnector 并检查 sink-config.yml
  3. 启动你的 RabbitMQConnectorServer,它将订阅到 EventMesh Runtime 中 pubSubConfig.subject 中定义的主题,并将数据发送到 RabbitMQ 中的 connectorConfig.queueName
  4. 使用在 pubSubConfig.subject 中指定的 Topic,向 EventMesh 发送消息,然后你将在 RabbitMQ 中接收到该消息。
pubSubConfig:
# 默认端口 10000
meshAddress: your.eventmesh.server:10000
subject: TopicTest
idc: FT
env: PRD
group: rabbitmqSink
appId: 5031
userName: rabbitmqSinkUser
passWord: rabbitmqPassWord
connectorConfig:
connectorName: rabbitmqSink
host: your.rabbitmq.server
port: 5672
username: coyrqpyz
passwd: passwd
virtualHost: coyrqpyz
exchangeType: TOPIC
# 使用内置的 exchangeName 或在连接到 RabbitMQ 后创建新的 exchangeName。
exchangeName: amq.topic
# 如果在连接之前不存在,RabbitMQ 将自动创建 routingKey 和 queueName。
routingKey: eventmesh
queueName: eventmesh
autoAck: true

RabbitMQSourceConnector:从 RabbitMQ 到 EventMesh

  1. 启动你的 RabbitMQ 和 EventMesh Runtime。
  2. 启用 sourceConnector 并检查 source-config.yml(与 sink-config.yml 基本相同)。
  3. 启动你的 RabbitMQConnectorServer,它将订阅到 RabbitMQ 中的 connectorConfig.queueName,并将数据发送到 EventMesh Runtime 中的 pubSubConfig.subject
  4. 向队列发送一个 CloudEvent 消息,然后你将在 EventMesh 中接收到该消息。