Skip to content

yanglikun/disruptor-example

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

20 Commits
 
 
 
 
 
 
 
 

Repository files navigation

#disruptor example 环境:JDK version:1.6 disruptor:3.3.6

disruptor可以简单的看做是内存MQ(内存消息队列)

image

  • producer:生产事件
  • disruptor(确切的说是里面的ring buffer):存放事件
  • EventHandler:处理事件,进行业务逻辑
  • 对于一个事件,所有的EventHandler都能接收到,也就是说一个事件消息会被处理多次(也可以使用wokerpool只让一个消息处理一次,后面会说)

代码示例

没有顺序,并行执行

step1、step2、step3三个处理器都会接收到消息而且执行没有先后顺序 测试类:example_basic.ParallelEventHandlersMain image

有先后依赖顺序执行

step1、step2、step3 三个步骤会严格按照顺序执行 测试类example_basic.DependenciesChainMain image

菱形顺序

step1-1、step1-2之间没有顺序,但是step2会等到step1-1、step2-1都执行完后才会执行 测试类example_basic.DependenciesDiamondMain image

链式依赖顺序

chain1、chain2之间没有依赖关系,but chain1中的 step1-1、step1-2有先后关系、chain12中的 step2-1、step2-2有先后关系。测试类example_basic.DependenciesMultiChainMain image

异常处理

异常需要设置setDefaultExceptionHandler,要不然处理器抛出异常后,就不会再处理事件了。测试类example_other.SimulationExceptionMain

监控disruptor的负载

调用ringBuffer.remainingCapacity()查看还有多少没使用,测试类example_other.MonitorDisruptorMain

About

No description or website provided.

Topics

Resources

Stars

Watchers

Forks

Releases

No releases published

Packages

No packages published

Languages