Disruptor介绍
1.Disruptor 是英国外汇交易公司LMAX开发的一个高性能队列，研发的初衷是解决内存队列的延迟问题（在性能测试中发现竟然与I/O操作处于同样的数量级）。基于 Disruptor 开发的系统单线程能支撑每秒 600 万订单，2010 年在 QCon 演讲后，获得了业界关注。
2.Disruptor是一个开源的Java框架，它被设计用于在生产者—消费者（producer-consumer problem，简称PCP）问题上获得尽量高的吞吐量（TPS）和尽量低的延迟。
3.从功能上来看，Disruptor 是实现了“队列”的功能，而且是一个有界队列。那么它的应用场景自然就是“生产者-消费者”模型的应用场合了。
4.Disruptor是LMAX在线交易平台的关键组成部分，LMAX平台使用该框架对订单处理速度能达到600万TPS，除金融领域之外，其他一般的应用中都可以用到Disruptor，它可以带来显著的性能提升。
5.其实Disruptor与其说是一个框架，不如说是一种设计思路，这个设计思路对于存在“并发、缓冲区、生产者—消费者模型、事务处理”这些元素的程序来说，Disruptor提出了一种大幅提升性能（TPS）的方案。
-
https://github.com/LMAX-Exchange/disruptor
http://GitHub开源地址
Disruptor是一种高性能的无锁并发框架，它可以用来实现并发数据结构和异步事件处理等场景。下面是Disruptor的使用步骤：
- 引入Disruptor依赖
在项目中引入Disruptor相关的依赖，例如Maven项目可以添加以下依赖：
复制代码
<dependency>
<groupId>com.lmax</groupId>
<artifactId>disruptor</artifactId>
<version>3.4.2</version>
</dependency>- 定义事件
Disruptor中需要定义一个事件(Event)类，这个类包含要传递的数据。
java复制代码
public class OrderEvent { private String orderId; // ... }- 编写事件处理器
Disruptor中需要实现一个或多个事件处理器(Event Handler)，以处理收到的事件。事件处理器需要继承EventHandler接口。
java复制代码
public class OrderEventHandler implements EventHandler<OrderEvent> {
@Override
public void onEvent(OrderEvent event, long sequence, boolean endOfBatch) throws Exception { // 处理事件 } }- 初始化Disruptor
生成Disruptor实例，指定RingBuffer的大小，以及指定线程池和事件处理器。
Disruptor<OrderEvent> disruptor = new Disruptor<>(OrderEvent::new, bufferSize, executorService); disruptor.handleEventsWith(new OrderEventHandler()); disruptor.start();- 发布事件
发布事件到Disruptor中，让事件传递给事件处理器进行处理。
RingBuffer<OrderEvent> ringBuffer = disruptor.getRingBuffer(); long nextSequence = ringBuffer.next(); OrderEvent orderEvent = ringBuffer.get(nextSequence);
orderEvent.setOrderId("123456"); ringBuffer.publish(nextSequence);- 关闭Disruptor
当不再需要使用Disruptor时，需要关闭它以释放资源。
disruptor.shutdown(); executorService.shutdown();以上就是Disruptor的基本使用流程。
