disruptor 笔记之四：事件消费知识点小结，kalilinux 教程 pdf

第一种：要发十封邮件和十条短信，此时，邮件系统和短信系统是各自独立的，他们各自消费这十个订单的事件，也就是说十个事件被消费二十次，所以邮件系统和短信系统各自独立消费，彼此没有关系，如下图，一个原点代表一个事件：

第二种：假设邮件系统处理能力差，为了提升处理能力，部署了两台邮件服务器，因此是这两台邮件服务器共同处理十个订单事件，合起来一共发送了十封邮件，如下图，一号邮件服务器和二号邮件服务器是共同消费，某个订单事件只会在一个邮件服务器被消费：

独立消费的核心知识点

1. 使用的 API 是 handleEventsWith

2. 业务处理逻辑放入 EventHandler 的实现类中

3. 内部实现用 BatchEventProcessor 类，一个消费者对应一个 BatchEventProcessor 实例，任务是获取事件再调用 EventHandler 的 onEvent 方法处理

4. 一个消费者对应一个 SequenceBarrier 实例，用于等待可消费事件

5. 一个消费者对应一个 Sequence 实例（BatchEventProcessor 的成员变量），用于记录消费进度

6. 每个 BatchEventProcessor 实例都会被放入集合（consumerRepository.consumerInfos）

7. Disruptor 的 start 方法中，会将 BatchEventProcessor 放入线程池执行，也就是说每个消费者都在独立线程中执行

共同消费的核心知识点

1. 使用的 API 是 handleEventsWithWorkerPool

2. 业务处理逻辑放入 WorkHandler 的实现类中

3. 内部实现用 WorkerPool 和 WorkProcessor 类合作完成的，WorkerPool 实例只有一个，每个消费者对应一个 WorkProcessor 实例

4. SequenceBarrier 实例只有一个，用于等待可消费事件

5. 每个消费者都有自己的 Sequence 实例，另外还有一个公共的 Sequence 实例（WorkerPool 的成员变量），用于记录消费进度

6. WorkerPool 实例会包裹成 WorkerPoolInfo 实例再放入集合（consumerRepository.consumerInfos）

7. Disruptor 的 start 方法中，会调用 WorkerPool.start 方法，这里面会将每个 WorkProcessor 放入线程池执行，也就是说每个消费者都在独立线程中执行

精简的小结

• 上述核心知识点还是有点多，咱们用对比来精简一下，以下是精华中的精华，真不能再省了，请重点关注：

1. 独立消费的每个消费者都有属于自己独有的 SequenceBarrier 实例，共同消费者是所有人共用同一个 SequenceBarrier 实例

2. 独立消费的每个消费者都有属于自己独有的 Sequence 实例，对于共同消费者，虽然他们也有属于自己的 Sequence 实例，但这个 Sequence 实例的值是从一个公共 Sequence 实例（WorkerPool 的成员变量 workSequence）得来的

3. 独立消费和共同消费都有自己的取数据再消费的代码，放在一起对比看就一目了然了，如下图，共同消费时，每个消费者的 Sequence 值其实来自公共 Sequence 实例，多线程之间用 CAS 竞争来抢占事件用于消费：

用图说话

• 最后放上自制图一张，希望有一图胜千言的效果吧：

• 至此，理论分析结束，接下来的文章会乘热

《Android学习笔记总结+最新移动架构视频+大厂安卓面试真题+项目实战源码讲义》
浏览器打开：qq.cn.hn/FTe 免费领取

打铁，基于上述知识点进行实战，编码实现三个场景：

1. 100 个订单，短信和邮件系统独立消费

2. 100 个订单，邮件系统的两个邮件服务器共同消费；

3. 100 个订单，短信系统独立消费，与此同时，两个邮件服务器共同消费；

你不孤单，欣宸原创一路相伴

1. Java系列
   

2. Spring系列
   

3. Docker系列