好吧,假设我正在构建基于 ActiveMQ 的聊天应用程序。这很简单。只有一个QUEUE.IN
和一个TOPIC.OUT
。所有消息都直接从 路由QUEUE.IN
到TOPIC.OUT
。客户正在生成他们的聊天消息QUEUE.IN
并从中消费TOPIC.OUT
。就这样。
现在,我想对它进行聚类。不需要复杂的东西。只需运行几个其他相同的节点(A..N)
。基本上,订阅A
节点的客户端将消息发送到A.QUEUE.IN
. 然后,该消息必须出现在所有其他节点上(A..N).TOPIC.OUT
。这可以通过简单的骆驼路由轻松完成,该路由将所有消息重新路由TOPIC.OUT
到其他节点,但是有一些不错的 ActiveMQ 原生方法吗?像几个 AMQ 实例之间共享的一些队列/主题?