其他分享
首页 > 其他分享> > disruptor笔记之四:事件消费知识点小结

disruptor笔记之四:事件消费知识点小结

作者:互联网

欢迎访问我的GitHub

这里分类和汇总了欣宸的全部原创(含配套源码):https://github.com/zq2599/blog_demos

关于独立消费和共同消费

独立消费的核心知识点

  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竞争来抢占事件用于消费:
    在这里插入图片描述

用图说话

在这里插入图片描述

  1. 100个订单,短信和邮件系统独立消费
  2. 100个订单,邮件系统的两个邮件服务器共同消费;
  3. 100个订单,短信系统独立消费,与此同时,两个邮件服务器共同消费;

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

  1. Java系列
  2. Spring系列
  3. Docker系列
  4. kubernetes系列
  5. 数据库+中间件系列
  6. DevOps系列

标签:知识点,消费,消费者,WorkerPool,Sequence,disruptor,实例,之四,邮件
来源: https://blog.csdn.net/boling_cavalry/article/details/117395009