高性能的异步处理框架Disruptor(四)——Disruptor2.0的优化

素颜马尾好姑娘i 2023-06-07 08:30 7阅读 0赞

现在读者应该能理解如下运行流程图了。如何还看不懂，则需要回顾上篇文章 [Disruptor消费者的依赖关系][Disruptor]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2Nhbm90_size_16_color_FFFFFF_t_70]  
Disruptor2.0主要变化有 3 点:

>  *  更贴切的命名;
>  *  把 producer barrier(生产者屏障)整合进了 ring buffer;
>  *  将 Disruptor Wizard 加入了主代码库。

对于上图的实现方案，在新版本的结构图大概如下:

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2Nhbm90_size_16_color_FFFFFF_t_70 1]

可以看到新版本更加简约，**ProducerBarrier 本身不再作为一个单独的实体存在，它的替代者是 PublishPort 接口，且 RingBuffer 自身就实现了这个接口。** 同样**DependencyBarrier 替代 ConsumerBarrier** 。另外，**Publisher (Producer的替代者)和 EventProcessor(替代了Consumer)** 更能精确地体现出它们的行为。Consumer 这个名字总是会带来一些混淆，因为因为其 实消费者从来不从 RingBuffer 消费任何东西。Consumer 之前仅仅是用于队列实现的一个术语。

图上没有表现出来的变动是以前存在 RingBuffer里的东西叫entry，而现在改名叫Event(事件)了，相应的就是 EventProcessor（事件处理者）。  
整个命名上的大规模更改是为了让大家更清晰的明白 Disruptor 是如何工作的，以及该如何使用它。

在 2.0 版中为了性能提升引入了一个新对象 Sequence(序列)，它被用来搞缓存行填充，并消除了对内存屏障的需要（happend-before）。现在缓存行填充的做法和以前略有不同，因为 JAVA7 新的优化特性，它成功的“优化”掉了我们原来的技术方案。

接下来，我们来看看前文说的加入了主代码库的[DisruptorDisruptor][]

对于上述的菱形依赖关系，在DisruptorWizard下实现会非常容易

//创建DisruptorWizard
    DisruptorWizard dw = new DisruptorWizard( ENTRY_FACTORY,
    RING_BUFFER_SIZE,
    EXECUTOR, ClaimStrategy.Option.SINGLE_THREADED, WaitStrategy.Option.YIELDING);
    
    //创建只会写入FIZZ字段的EventHandler
    FizzBuzzEventHandler fizzHandler =
    new FizzBuzzEventHandler(FIZZ);
    FizzBuzzEventHandler buzzHandler =
    new FizzBuzzEventHandler(BUZZ);
    FizzBuzzEventHandler fizzBuzzHandler =
    new FizzBuzzEventHandler(FIZZ_BUZZ);
    
    //fizzHandler, buzzHandler处理完后交给fizzBuzzHandler
    dw.handleEventsWith(fizzHandler, buzzHandler) .then(fizzBuzzHandler);

[Disruptor]: https://blog.csdn.net/canot/article/details/102470300
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2Nhbm90_size_16_color_FFFFFF_t_70]: /images/20230601/751f853149c34407ae0167d907e67574.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2Nhbm90_size_16_color_FFFFFF_t_70 1]: /images/20230601/450b6fc89cc247a19af678a525c3b2d0.png
[DisruptorDisruptor]: https://github.com/ajsutton/disruptorWizard