java - 对于 java 同步锁，disruptor onEvent 处理程序似乎太快了

Question

我同时将 2 个或更多不同的事件发布到输出中断器（一个接一个），并且中断器 onEvent 通常只将最后一个要发布的事件发送到 IO 会话。基本上，事件数据被覆盖。而我想在会话层上查看每个事件的副本。我曾尝试在锁上同步会话层，但即使对于锁，发布者通常仍然太快（有时它正在工作，但大多数时候它不是）。

这是一些代码：

private final Object lock = new Object();

public void onEvent(final FixEvent event, final long sequence, final boolean endOfBatch) 
    {       
        synchronized(lock)
        {
             sendMessage(event.message);
        }
    } 

这有发生在其他人身上吗？除了发布者的减速带之外，还有其他解决方案吗？

这是生产者代码：

public void onData(Message message, SessionID s)
{
    long sequence = ringBuffer.next();  // Grab the next sequence
    try
    {
        FixEvent event = ringBuffer.get(sequence);
        event.set(message, s);
    }
    finally
    {
        ringBuffer.publish(sequence);
    }
}

Answer 1

onEvent每个 eventHandler 只会对 ringbuffer 中的每个序列调用一次。

如果没有看到生产者代码，就不可能说出你为什么观察到这种行为。

可能值得添加一些日志记录以确认每个给定序列号的事件是什么。