LMAX Disruptor如何解决典型的message问题？

Question

我对LMAX消毒器的理解是，它是一个充满可怕的、快速的、可怕的并发Java代码的罐子，它允许每秒2,000万条消息的吞吐量(如果使用正确的话)。

我们目前有一个ActiveMQ实例，它以每秒400条消息的速度来满足我们的需要。我想知道，重构代码以使用LMAX是否会使我们受益，但我们需要考虑以下几点：

• 如何拥有一个发布者和多个(竞争)消费者
• LMAX如何存储/存储它的信息？在记忆里？
• 故障转移- LMAX是否有故障转移协议/机制？
• 磁盘I/O - LMAX能否将未使用的消息持久化到磁盘并在稍后恢复？

而且，如果我完全偏离了所有这些，并且似乎完全误解了LMAX的使用，那么有人能提供一个具体的例子来说明何时使用吗？提前感谢！

Answer 1

Disruptor不是跨进程或跨服务器消息传递系统的直接替代品。它被设计为一个进程内的跨线程消息传递系统.将处理线程之间的依赖关系图替换为有用，通常线程之间会有队列。这使得它对于在线程之间使用管道或多播模式的设计非常有用。ActiveMQ有着不同的用途。

基于Disruptor的系统中的线程更像是通过Disruptor传递事件进行通信的长寿命Actors。

要获得一些好的示例，请查看源代码中提供的性能测试。