Find centralized, trusted content and collaborate around the technologies you use most.
Teams
Q&A for work
Connect and share knowledge within a single location that is structured and easy to search.
我有两个网络环境(例如NETWORK -A和NETWORK -B)。现在,我在中部署了rocketmq-a,在中NETWORK-A 部署了rocketmq-b NETWORK-B,如何直接通信rocketmq-a和rocketmq-b?
NETWORK -A
NETWORK -B
NETWORK-A
NETWORK-B
根据您的评论,您有两个 RocketMQ 集群,一条消息应该复制到另一个 RocketMQ 集群。
所以这是一个消息复制。
你有两个选择:
实现发送消息挂钩
AbstractPluginMessageStore使用扩展并使用代理配置加载它的 messageStore 插件
AbstractPluginMessageStore
两者都需要自己实现复制。
但是,如果你让他们成为同一个经纪人组,那就很容易了。
只需将rocketmq-b作为rocketmq-a的slave,部署在不同的机房即可。
那么rocketmq-b将只提供读操作,并且总是从master复制数据