《Java编程方法论:响应式Spring Reactor 3设计与实现》学习笔记目录

笔记来源：《Java编程方法论:响应式Spring Reactor 3设计与实现》ISBN:9787121394768 作者：知秋 出版时间：2020年09月

前言

• 作者 GitHub
• 示例源码

1.2 如何理解响应式编程中的背压

背压 Back Pressure

• 简单理解：限流

1.3 源码接口设计启示

响应式编程的 Rx 标准对应 JDK 中 java.util.concurrent.Flow

• Publisher 通过 subscribe 方法与 Subscriber 产生定义关系
• Subscriber 依靠 onSubscribe 方法与上游生产者产生联系
  • 通过 Subscription 实现

通过 Reactor 中的 reactor.core.publisher.FluxArray 理解

1
2
3
4
5
6
7

// 通过该方法与下游订阅者产生联系
// Params: actual – the Subscriber interested into the published sequence
// 对发布的序列感兴趣的订阅者
@Override
public void subscribe(CoreSubscriber<? super T> actual) {
    subscribe(actual, array);
}