异步流处理:反应流

反应流为带有非阻塞回压(back pressure)的异步流处理定义了标准。

这类系统最大的问题是资源消耗。
快速的生产者会使较慢的消费者超负荷。
这些组件之间的数据队列规模可能过度增加,从而影响整个系统的行为。
回压机制确保了在生产者和消费者之间进行协调的队列含有限定数目的元素。

反应流定义了描述必要操作和实体所需的接口、方法和协议的最小集合。
它们基于以下三个要素。

反应流规范根据以下规则明确了这些类应该如何交互。

如前所述,所有这些通信都是异步的,因此可以充分利用多核处理器的全部性能。

基本内容

  1. Java 反应流简介
  2. 第一个例子:面向事件通知的集中式系统
  3. 第二个例子:新闻系统

小结