RingBuffer Processors

基于RingBuffer的Reactive Stream Processor优点如下:

  • 高吞吐量
  • 回放最近未消费的数据
    • 如果没有Subscriber监听,数据不会丢失(不像Reactor Stream中的Broadcaster会丢失数据)。
    • 如果Subscriber在处理中被中断,信号会被安全的回放,实际上它能在RingBufferWorkProcessor上很好的工作。
  • 灵活的背压,它允许任何时间有限数量数据的背压,Subscriber有能力消费掉并且请求更多数据
  • 传播的背压,因为它是一个Processor,它可以通过订阅方式传递消息。
  • Processer拥有多线程处理出入的能力

其实RingBuffer*Processor更类似一个典型的MicroMessageBroker !

它们唯一的缺点是运行时创建开销较大,它们不能像它们的表兄RingBufferDispatcher一样易于分享。这让它们更适合可预定义的高吞吐量管道。