disruptor 笔记之四:事件消费知识点小结,kalilinux 教程 pdf
第一种:要发十封邮件和十条短信,此时,邮件系统和短信系统是各自独立的,他们各自消费这十个订单的事件,也就是说十个事件被消费二十次,所以邮件系统和短信系统各自独立消费,彼此没有关系,如下图,一个原点代表一个事件:
![](https://static001.geekbang.org/infoq/de/de6b2fe9660e5bbe45e6237fe2a8453d.png)
第二种:假设邮件系统处理能力差,为了提升处理能力,部署了两台邮件服务器,因此是这两台邮件服务器共同处理十个订单事件,合起来一共发送了十封邮件,如下图,一号邮件服务器和二号邮件服务器是共同消费,某个订单事件只会在一个邮件服务器被消费:
![](https://static001.geekbang.org/infoq/d0/d0513bf4307e82830ffbabfd964e3393.png)
独立消费的核心知识点
使用的 API 是 handleEventsWith
业务处理逻辑放入 EventHandler 的实现类中
内部实现用 BatchEventProcessor 类,一个消费者对应一个 BatchEventProcessor 实例,任务是获取事件再调用 EventHandler 的 onEvent 方法处理
一个消费者对应一个 SequenceBarrier 实例,用于等待可消费事件
一个消费者对应一个 Sequence 实例(BatchEventProcessor 的成员变量),用于记录消费进度
每个 BatchEventProcessor 实例都会被放入集合(consumerRepository.consumerInfos)
Disruptor 的 start 方法中,会将 BatchEventProcessor 放入线程池执行,也就是说每个消费者都在独立线程中执行
共同消费的核心知识点
使用的 API 是 handleEventsWithWorkerPool
业务处理逻辑放入 WorkHandler 的实现类中
内部实现用 WorkerPool 和 WorkProcessor 类合作完成的,WorkerPool 实例只有一个,每个消费者对应一个 WorkProcessor 实例
SequenceBarrier 实例只有一个,用于等待可消费事件
每个消费者都有自己的 Sequence 实例,另外还有一个公共的 Sequence 实例(WorkerPool 的成员变量),用于记录消费进度
WorkerPool 实例会包裹成 WorkerPoolInfo 实例再放入集合(consumerRepository.consumerInfos)
Disruptor 的 start 方法中,会调用 WorkerPool.start 方法,这里面会将每个 WorkProcessor 放入线程池执行,也就是说每个消费者都在独立线程中执行
精简的小结
上述核心知识点还是有点多,咱们用对比来精简一下,以下是精华中的精华,真不能再省了,请重点关注:
独立消费的每个消费者都有属于自己独有的 SequenceBarrier 实例,共同消费者是所有人共用同一个 SequenceBarrier 实例
独立消费的每个消费者都有属于自己独有的 Sequence 实例,对于共同消费者,虽然他们也有属于自己的 Sequence 实例,但这个 Sequence 实例的值是从一个公共 Sequence 实例(WorkerPool 的成员变量 workSequence)得来的
独立消费和共同消费都有自己的取数据再消费的代码,放在一起对比看就一目了然了,如下图,共同消费时,每个消费者的 Sequence 值其实来自公共 Sequence 实例,多线程之间用 CAS 竞争来抢占事件用于消费:
![](https://static001.geekbang.org/infoq/1f/1f6f280957b17456d7f40e08675be8f8.png)
用图说话
最后放上自制图一张,希望有一图胜千言的效果吧:
![](https://static001.geekbang.org/infoq/f7/f7c33d4b0b665381e42c4332dd3e44bd.png)
至此,理论分析结束,接下来的文章会乘热
打铁,基于上述知识点进行实战,编码实现三个场景:
100 个订单,短信和邮件系统独立消费
100 个订单,邮件系统的两个邮件服务器共同消费;
100 个订单,短信系统独立消费,与此同时,两个邮件服务器共同消费;
评论