Java Disruptor 完整指南：原理、安装与实战示例

1. 什么是 Disruptor？为什么需要它？

Disruptor 是由 LMAX 公司开发的一款高性能 Java 无锁并发库，专为线程间通信（IPC）设计。它的目标是以极低的延迟和极高的吞吐量在线程之间传递数据。与传统的阻塞队列（如 LinkedBlockingQueue）不同，Disruptor 采用固定大小的环形缓冲区（ring buffer），从而避免了内存分配、线程同步和垃圾回收带来的额外开销。

Disruptor 解决的核心问题是线程间的“资源竞争”。在传统队列中，多个生产者和消费者会竞争锁资源，导致线程阻塞和性能下降。而 Disruptor 通过“序列屏障”（sequence barriers）和乐观锁（CAS — Compare-And-Swap）机制，实现了微秒级延迟和每秒数百万条消息的吞吐量。

该库非常适合对事件处理速度有极致要求的系统，例如：金融交易平台、游戏服务器、日志处理系统、高并发 Web 应用。Disruptor 也是许多现代框架（如 Apache Storm 和部分 Event Sourcing 实现）的底层基石。

2. 安装 Disruptor

Disruptor 通过 Maven Central 分发。要在项目中使用它，请在 pom.xml（Maven）中添加以下依赖：

<dependency>
    <groupId>com.lmax</groupId>
    <artifactId>disruptor</artifactId>
    <version>4.0.0</version>
</dependency>

对于 Gradle（build.gradle）：

implementation 'com.lmax:disruptor:4.0.0'

如果你使用其他依赖管理工具，可以从 Maven Central 直接下载 JAR 包。

3. 快速入门：最小可用示例

下面我们创建一个简单的 Disruptor 示例，它接收字符串事件并将其打印到控制台。

import com.lmax.disruptor.*;
import com.lmax.disruptor.dsl.Disruptor;
import com.lmax.disruptor.util.DaemonThreadFactory;

// 1. 定义事件类
public class StringEvent {
    private String value;

    public String getValue() { return value; }
    public void setValue(String value) { this.value = value; }
}

// 2. 事件工厂（用于复用空事件对象）
public class StringEventFactory implements EventFactory<StringEvent> {
    @Override
    public StringEvent newInstance() {
        return new StringEvent();
    }
}

// 3. 事件处理器（消费者）
public class StringEventHandler implements EventHandler<StringEvent> {
    @Override
    public void onEvent(StringEvent event, long sequence, boolean endOfBatch) {
        System.out.println("收到事件: " + event.getValue());
    }
}

// 4. 主类
public class QuickStart {
    public static void main(String[] args) throws InterruptedException {
        // 环形缓冲区大小（必须是 2 的幂）
        int bufferSize = 1024;

        // 创建 Disruptor
        Disruptor<StringEvent> disruptor = new Disruptor<>(
            new StringEventFactory(),
            bufferSize,
            DaemonThreadFactory.INSTANCE
        );

        // 连接事件处理器
        disruptor.handleEventsWith(new StringEventHandler());

        // 启动 Disruptor
        disruptor.start();

        // 获取 RingBuffer 引用
        RingBuffer<StringEvent> ringBuffer = disruptor.getRingBuffer();

        // 发布事件
        for (int i = 0; i < 10; i++) {
            long sequence = ringBuffer.next(); // 获取下一个可用槽位
            try {
                StringEvent event = ringBuffer.