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

@Data
public class OrderEvent {
    private String orderId;
    private BigDecimal amount;
    private LocalDateTime createTime;
}

public class OrderEventFactory implements EventFactory<OrderEvent> {
    @Override
    public OrderEvent newInstance() {
        return new OrderEvent();
    }
}

public class OrderEventHandler implements EventHandler<OrderEvent> {


    // 支付處理（第一個消費者）
    @Override
    public void onEvent(OrderEvent event, long sequence, boolean endOfBatch) {
        System.out.println("處理支付: " + event.getOrderId());
    }
}


public class LogEventHandler implements EventHandler<OrderEvent> {


    // 日志記錄（第二個消費者）
    @Override
    public void onEvent(OrderEvent event, long sequence, boolean endOfBatch) {
        System.out.println("記錄日志: " + event.getOrderId());
    }
}

@Configuration
public class DisruptorConfig {


    @Bean
    public Disruptor<OrderEvent> orderDisruptor() {
        int bufferSize = 1024 * 1024; // 2^20


        Disruptor<OrderEvent> disruptor = new Disruptor<>(
                new OrderEventFactory(),
                bufferSize,
                Executors.defaultThreadFactory(),
                ProducerType.MULTI, // 多生產(chǎn)者模式
                new BlockingWaitStrategy());


        // 配置處理鏈：支付處理 -> 日志記錄
        disruptor.handleEventsWith(new OrderEventHandler())
                 .then(new LogEventHandler());


        return disruptor;
    }
}

import com.lmax.disruptor.RingBuffer;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
@RestController
public class OrderController {
    private final RingBuffer<OrderEvent> ringBuffer;
    public OrderController(RingBuffer<OrderEvent> ringBuffer) {
        this.ringBuffer = ringBuffer;
    }
    @GetMapping("/createOrder")
    public String createOrder(@RequestParam long orderId, @RequestParam double amount) {
        long sequence = ringBuffer.next();  // Grab the next sequence
        try {
            OrderEvent event = ringBuffer.get(sequence); // Get the entry in the Disruptor
            event.setOrderId(orderId);
            event.setAmount(amount);
        } finally {
            ringBuffer.publish(sequence);
        }
        return "Order created with ID: " + orderId;
    }
}