支撑每秒数百万订单无压力，SpringBoot + Disruptor 太猛了！

package com.icoderoad.disruptor.entity;
import lombok.Data;
@Data
public class OrderEvent {
    private String orderId;
    private String userId;
    private double price;
    private String status;
}

package com.icoderoad.disruptor.factory;
import com.lmax.disruptor.EventFactory;
import com.icoderoad.disruptor.entity.OrderEvent
public class OrderEventFactory implements EventFactory<OrderEvent> {
    @Override
    public OrderEvent newInstance() {
        return new OrderEvent();
    }
}

package com.icoderoad.disruptor.handler;
import com.icoderoad.disruptor.entity.OrderEvent
import com.lmax.disruptor.EventHandler;
public class OrderEventHandler implements EventHandler<OrderEvent> {
    @Override
    public void onEvent(OrderEvent event, long sequence, boolean endOfBatch) {
        // 处理订单的具体业务逻辑
        processOrder(event);
    }
    private void processOrder(OrderEvent orderEvent) {
        // 模拟订单支付逻辑
        System.out.println("处理订单: " + orderEvent.getOrderId() + ", 用户: " + orderEvent.getUserId() + ", 金额: " + orderEvent.getPrice());
        // 假设订单处理通过后更新订单状态
        orderEvent.setStatus("已支付");
        // 模拟库存扣减逻辑
        reduceInventory(orderEvent);
        System.out.println("订单处理完成: " + orderEvent.getOrderId() + " 状态: " + orderEvent.getStatus());
    }
    private void reduceInventory(OrderEvent orderEvent) {
        // 模拟库存扣减逻辑
        System.out.println("扣减库存: 订单 " + orderEvent.getOrderId());
        // 假设库存扣减成功
    }
}

package com.icoderoad.disruptor.producer;
import com.icoderoad.disruptor.entity.OrderEvent
import com.lmax.disruptor.RingBuffer;
import java.util.UUID;
public class OrderEventProducer {
    private final RingBuffer<OrderEvent> ringBuffer;
    public OrderEventProducer(RingBuffer<OrderEvent> ringBuffer) {
        this.ringBuffer = ringBuffer;
    }
    public void onData(String userId, double price) {
        long sequence = ringBuffer.next();  // 获取下一个序列号
        try {
            OrderEvent orderEvent = ringBuffer.get(sequence); // 获取事件对象
            orderEvent.setOrderId(UUID.randomUUID().toString());
            orderEvent.setUserId(userId);
            orderEvent.setPrice(price);
            orderEvent.setStatus("未支付");
        } finally {
            ringBuffer.publish(sequence);  // 发布事件
        }
    }
}

package com.icoderoad.disruptor.config;
import com.lmax.disruptor.dsl.Disruptor;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import com.icoderoad.disruptor.entity.OrderEvent
  import com.icoderoad.disruptor.factory.OrderEventFactory
import java.util.concurrent.Executors;
@Configuration
public class DisruptorConfig {
    @Bean
    public Disruptor<OrderEvent> disruptor() {
        OrderEventFactory factory = new OrderEventFactory();
        int bufferSize = 1024; // RingBuffer 大小
        Disruptor<OrderEvent> disruptor = new Disruptor<>(factory, bufferSize, Executors.defaultThreadFactory());
        // 绑定事件处理器
        disruptor.handleEventsWith(new OrderEventHandler());
        disruptor.start();
        return disruptor;
    }
    @Bean
    public OrderEventProducer orderEventProducer(Disruptor<OrderEvent> disruptor) {
        return new OrderEventProducer(disruptor.getRingBuffer());
    }
}

package com.icoderoad.disruptor.controller;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.*;
import com.icoderoad.disruptor.producer.OrderEventProducer;
@RestController
@RequestMapping("/orders")
public class OrderController {
    @Autowired
    private OrderEventProducer orderEventProducer;
    @PostMapping("/create")
    public ResponseEntity<String> createOrder(@RequestBody OrderRequest orderRequest) {
        orderEventProducer.onData(orderRequest.getUserId(), orderRequest.getPrice());
        return ResponseEntity.ok("订单创建成功，正在处理！");
    }
}
class OrderRequest {
    private String userId;
    private double price;
    // Getters and Setters
    public String getUserId() {
        return userId;
    }
    public void setUserId(String userId) {
        this.userId = userId;
    }
    public double getPrice() {
        return price;
    }
    public void setPrice(double price) {
        this.price = price;
    }
}