好吧,可以说我正在构建基于ActiveMQ的聊天应用程序。这很简单。只有一个 QUEUE.IN 一个 TOPIC.OUT. 。所有消息都立即远离路由 QUEUE.INTOPIC.OUT. 。客户正在生产他们的聊天消息 QUEUE.IN 并从中消费 TOPIC.OUT. 。就这样。

现在,我想群集。不需要复杂的东西。只是运行其他几个相同的节点 (A..N). 。基本上,客户,订阅 A 节点,将消息发送到 A.QUEUE.IN. 。然后必须在所有其他节点上出现此消息 (A..N).TOPIC.OUT. 。这可以通过简单的骆驼路线轻松完成,重新浏览所有消息 TOPIC.OUT 对于其他节点,但是是否有一些不错的ActiveMQ本地方法可以这样做?就像一些AMQ实例中共享的一些队列/主题一样?

有帮助吗?

解决方案

我认为您可以在这里找到答案:

http://activemq.apache.org/how-do-distributed-queues-work.html

其他提示

您可以使用虚拟目的地将消息转发到ActiveMQ中的多个端点。

http://activemq.apache.org/virtual-destination.html

许可以下: CC-BY-SA归因
不隶属于 StackOverflow
scroll top