Lmax Disruptor，许多消费者 - 如何让消费者只接受特定类型的消息并独立进行？

Question

我计划在我的干扰器中有很多并行消费者。

我需要每个消费者只消费适合他们的消息。

例如，我有 A、B、C 类型的消息，我有类似

的缓冲区

 #1 - type A, #2 - type B, #3 - type C,  #4 - type A, #5 - type C, #6 - type C,  (and so on)

每种类型都有消费者。我如何实现 A 的消费者将接收消息 1 和 4，对于类型 B - 消息 2，C - 消息 3、5、6？

重要提示：我希望处理是独立的。消费者不应被链接在一起，每个消费者都独立地在缓冲区中移动。如果 A 的消费者比 C 慢，"type C" 消费者对 #6 的处理可能会早于 #1 类型 A。

感谢您解释如何使用 LMAX 干扰器配置。

Answer 1

将干扰器配置为使用单一类型的对象，但创建多个干扰器，每个对象类型一个。在上面的例子中，将有三个独立的破坏者。

Answer 2

典型的模式是使用序列号——假设你有 4 个事件处理程序挂在一个干扰器上；如果你给每个人一个唯一的号码，你可以select是否接受消息：

void onEvent(T event, long sequence, boolean endOfBatch) throws Exception {
    // instanceNumber could be assigned in a constructor 
   if ((sequence % 4) != instanceNumber) 
        // message isn't for me
        return;
   }
   // do my thing
}

Lmax Disruptor，许多消费者 - 如何让消费者只接受特定类型的消息并独立进行？

Lmax Disruptor, many consumers - how make consumer take only messages of particular kind and proceed independently?

java

concurrency

disruptor-pattern

lmax