#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

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