那些熟悉lmax ring buffer (disruptor)的人知道該數據結構的最大優勢之一在於它批量處理事件，並且當我們有一個消費者可以利用批處理使系統自動可調對負載來說，你投入的事件越多越好。 不知想不出我們實現與可觀察到同樣的效果（針對批處理功能）。我已經嘗試過Observable.buffer，但這是非常不同的，緩衝區將等待並且不發出批處理，而預期的事件數沒有到達。我們想要的是完全不同
繼Disruptor Getting Started Guide之後，我已經與一個生產者和一個消費者建立了一個最小的破壞者。 生產者 import com.lmax.disruptor.RingBuffer;
public class LongEventProducer
{
private final RingBuffer<LongEvent> ringBuffer;
示例代碼... public class LongEvent
{
private long value;
public void set(long value)
{
this.value = value;
}
}
編號：https://github.com/LMAX-Exchange/disruptor/wiki/Getting-Sta
我有以下的在我的春天啓動的應用程序的反應器結構： @Configuration
public class AsyncConfig {
@Bean
public EventBus eventBus(){
return EventBus.create(getDispatcher("rb-relay"));
}
public MultiThrea
我計劃在我的干擾者中擁有許多平行消費者。 我需要每個消費者只消費對他們有意義的消息。 例如，我有類型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型