1

我有一个节点网络。节点必须能够相互发送消息。消息仅从节点发送到节点(即没有广播)。节点知道它们必须向其发送消息的节点的地址。节点不一定知道他们将从谁那里接收。一些节点(称为主节点)可能会从大量节点(> 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 一起使用,并拥有免费的私人或学术许可证。

4

1 回答 1

1

我从未遇到过可以做到这一点的开箱即用技术。

解决它的一种方法可能是在内部使用队列(ActiveMQ),如您的插图所示,并使用 Netty.io 或 Jersey 等服务创建 API(我没有使用 Netty 的经验,但曾将 Jersey 用于类似的应用程序),外部。这虽然需要一些编码,但是不是很好吗?:)

于 2012-11-15T10:59:25.693 回答