我有一个节点网络。节点必须能够相互发送消息。消息仅从节点发送到节点(即没有广播)。节点知道它们必须向其发送消息的节点的地址。节点不一定知道他们将从谁那里接收。一些节点(称为主节点)可能会从大量节点(> 100k)接收消息并向其发送消息。
我希望能够将持久消息从一个节点发送到另一个节点。我希望即使在不可靠的网络上也能异步发生。即我希望消息服务为我处理重发、确认等。
如http://activemq.apache.org/networks-of-brokers.html中所述,我已尝试将 ActiveMQ 与代理的静态网络(在我的小设置中只有 2 个节点)一起使用。这适用于我的设置,但我预计将有大约 10 万个节点关联到一个节点(称为主节点),然后必须运行 10 万个代理才能将消息转发到所有关联节点。所有节点可能偶尔发送,主节点有时可能不得不发送到几个(>10k)其他节点(注意:没有广播,因为它们都接收不同的消息)。
我想象使用的一种设置可以在这张图片http://i154.photobucket.com/albums/s260/sheep_p/communication.png中看到,其中圆柱体表示队列。这里每个节点都有一个入站和一个出站队列。
可以使用什么技术来实现这一点,需要什么样的技术配置?
该技术必须与 Java 一起使用,并拥有免费的私人或学术许可证。