# reactor-learn

**Repository Path**: ywj1352/reactor-learn

## Basic Information

- **Project Name**: reactor-learn
- **Description**: 学习 响应式编程
- **Primary Language**: Unknown
- **License**: Apache-2.0
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 0
- **Forks**: 0
- **Created**: 2020-06-21
- **Last Updated**: 2021-01-20

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

## 发布者 Publisher

Publisher 将数据流发布给注册的 Subscriber。 它通常使用 Executor 异步发布项目给订阅者。 Publisher 需要确保每个订阅的 Subscriber 方法严格按顺序调用。
- subscribe：订阅者订阅发布者


## 订阅者 Subscriber

Subscriber 订阅 Publisher 的数据流，并接受回调。 如果 Subscriber 没有发出请求，就不会收到数据。对于给定 订阅合同（Subscription），调用 Subscriber 的方法是严格按顺序的。
- onSubscribe：发布者调用订阅者的这个方法来异步传递订阅 ， 这个方法在 publisher.subscribe方法调用后被执行
- onNext：发布者调用这个方法传递数据给订阅者
- onError：当 Publisher 或 Subscriber 遇到不可恢复的错误时调用此方法，之后不会再调用其他方法
- onComplete：当数据已经发送完成，且没有错误导致订阅终止时，调用此方法，之后不再调用其他方法

## 订阅合同 Subscription

Subscription 用于连接 Publisher 和 Subscriber。Subscriber 只有在请求时才会收到项目，并可以通过 Subscription 取消订阅。Subscription 主要有两个方法：
- request：订阅者调用此方法请求数据
- cancel：订阅者调用这个方法来取消订阅，解除订阅者与发布者之间的关系


## 处理器 Processor
Processor 位于 Publisher 和 Subscriber 之间，用于做数据转换。可以有多个 Processor 同时使用，组成一个处理链，链中最后一个处理器的处理结果发送给 Subscriber。JDK 没有提供任何具体的处理器。处理器同时是订阅者和发布者，接口的定义也是继承了两者 即作为订阅者也作为发布者 ，作为订阅者接收数据，然后进行处理，处理完后作为发布者，再发布出去。