java - 可扩展且高性能的消息 channel

Question

我正在开发代理来从不同来源收集数据，数据应该以高频率(例如每 15 秒)发布到 channel 。 REST 绝对不是一个解决方案。该要求显然是即发即忘，因为与状态回复无关。

吞吐量更重要，消息丢失最多 5% 是可以接受的。

我遇到的可能的解决方案是

• 消息总线
• 组播
• UDP

任何替代方案，请提出。

Answer 1

恕我直言，高频太快了，看不到，15秒你就能看到。发送一条消息到世界各地并返回大约需要 0.5 秒。您只能看到大约 15 毫秒。如果你谈论的是 15 微秒，那绝对是高频。我有一个持久消息传递解决方案，延迟约为 0.1 微秒，即 0.0000001 秒，但我不建议您需要它。

如果您需要的只是每 15 秒一条消息，我会使用想到的最简单的解决方案。我会尝试 ActiveMQ，我发现它是最简单的工作方式之一。您应该能够实现高达每秒 20,000 条消息的速率和大约 0.01 秒的适当延迟，并且您不应该丢失任何消息。