Reactor

Reactor 是一个基于 JVM 的非阻塞异步应用基础库，它并非特指某一款安卓软件。该库与 Java 8 的函数式编程结合紧密，提供了一套响应式编程模型，用于处理异步数据流。在 Spring 框架体系中，Reactor 与 Spring WebFlux 配合使用，可用来构建响应式 Web 应用。

性能与编程模型

1、在最新的硬件平台上，Reactor 的表现较为突出，借助无阻塞分发器，每秒能够处理大量事件，适合高并发场景。

2、它以事件和回调为基础，把传统的命令式编程转换为响应式编程，使数据处理过程更灵活，效率也更高。

3、与 Spring WebFlux 的集成，让开发者多了一套构建响应式 Web 应用的工具组合。

核心抽象与函数式支持

1、Flux 与 Mono：这是 Reactor 提供的两个异步序列 API。Flux 表示包含 0 到多个元素的异步序列，Mono 表示包含 0 或 1 个元素的异步序列，开发者可依据数据数量选择合适的一种。

2、函数式编程：库中充分利用了 Java 8 的函数式特性，包括 CompletableFuture、Stream 和 Duration，有助于写出更简洁、更易维护的代码。

3、操作符：Reactor 提供了数量众多的操作符，用于对流数据执行过滤、映射、聚合等各类转换与处理。

基本用法

1、创建对象：通过 Reactor 提供的构造器和方法可以创建 Flux 与 Mono 对象，例如用 just() 方法指定序列中的元素。

2、流计算：创建完成后即可对 Flux 和 Mono 对象执行流计算，如用 map() 做数据转换，用 filter() 做数据过滤。

3、错误处理：Reactor 带有相应的错误处理机制，例如用 onErrorReturn() 方法在发生错误时返回默认值。

测试方式

1、引入依赖：在项目中加入 reactor-test 依赖，用于测试 Reactor 中的代码。

2、使用 StepVerifier：StepVerifier 是 reactor-test 的核心接口，提供多种静态工厂方法和状态机接口，可验证 Publisher 的状态及输出是否符合预期。

3、编写测试：通过 StepVerifier 的 create 方法传入待测试的 Publisher，再设置断言，检查其输出与行为是否达到预期。

从整体来看，Reactor 围绕异步序列的创建、变换与错误处理展开，配合 reactor-test 完成验证，适合在 JVM 上构建需要处理高并发事件流的响应式应用，也适合与 Spring WebFlux 协作完成响应式 Web 开发。