目录

工欲善其事

实践出真知

活跃标签： linux java mysql 待分类 js springboot win10 电路 vue macOS nginx esp32 git docker windows idea maven esp8266 python Arduino

存档：

标签： Reactor (1)

Java 反应式框架Reactor中的Mono和Flux (转载)

Java反应式框架Reactor中的Mono和Flux 1. 前言 最近写关于响应式编程的东西有点多，很多同学反映对Flux和Mono这两个Reactor中的概念有点懵逼。但是目前Java响应式编程中我们对这两个对象的接触又最多，诸如Spring WebFlux、RSocket、R2DBC。我开始也对这两个对象头疼，所以今天我们就简单来探讨一下它们。 2. 响应流的特点 要搞清楚这两个概念，必须说一下响应流规范。它是响应式编程的基石。他具有以下特点： 响应流必须是无阻塞的。 响应流必须是一个数据流。 它必须可以异步执行。 并且它也应该能够处理背压。 背压是反应流中的一个重要概念，可以理解为，生产者可以感受到消费者反馈的消费压力，并根据压力进行动态调整生产速率。形象点可以按照下面理解： 3. Publisher 由于响应流的特点，我们不能再返回一个简单的POJO对象来表示结果了。必须返回一个类似Java中的Future的概念，在有结果可用时通知消费者进行消费响应。 Reactive Stream规范中这种被定义为Publisher<T> ，Publisher<T>....