好吧,假设我正在构建基于 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 实例之间共享的一些队列/主题?