Flux.create 和 Flux.generate 的区别

1. 引言

Project Reactor 提供了一个完全非阻塞的编程基础，适用于 JVM。它提供了响应式流规范的实现，并提供了可组合的异步 API，如 Flux。Flux 是一个响应式流发布者，可以发出 0 到 N 个元素，然后成功完成或出现错误。根据我们的需求，可以通过多种不同的方式创建它。

2. 理解 Flux

Flux 是一个响应式流发布者，可以发出 0 到 N 个元素。它有几个操作符，用于生成、协调和转换 Flux 序列。Flux 可以成功完成或出现错误完成。

在本教程中，我们将深入探讨Java响应式编程，以解决一个有趣的问题：如何将Flux<DataBuffer>读取为单个InputStream。

2. 请求设置

作为将Flux<DataBuffer>读取为单个InputStream问题的第一步，我们将使用Spring响应式WebClient进行GET请求。此外，我们可以使用由gorest.co.in托管的公共API端点进行此类测试场景：

String REQUEST_ENDPOINT = "https://gorest.co.in/public/v2/users";

在本文中，我们将讨论Spring WebFlux提供的取消正在进行的_Flux_的各种选项。首先，我们将快速概述响应式编程中的_Flux_。接下来，我们将探讨取消正在进行的_Flux_的必要性。

我们将查看Spring WebFlux提供的各种方法，以显式和自动方式取消订阅。我们将使用JUnit测试来驱动我们的简单示例，以验证系统的行为符合预期。最后，我们将看到如何在取消后执行清理工作，使我们能够将系统重置为取消后所需的状态。

让我们首先快速概述一下_Flux_。

2. 什么是Flux？

Spring WebFlux是一个响应式Web框架，为构建异步、非阻塞应用程序提供了强大的功能。Spring WebFlux的一个关键特性是其处理fluxes的能力。_Flux_是一个响应式数据流，它可以发出零个或多个项目。它可以从各种来源创建，例如数据库查询、网络调用或内存集合。

1. 概述

Spring 响应式编程引入了一种新时代的应用，这些应用既响应迅速又可扩展。Project Reactor 是一个在该生态系统中管理异步和事件驱动编程的卓越工具包。

MathFlux 是 Project Reactor 的一个组件，它为我们提供了各种为响应式编程设计的数学函数。

在本教程中，我们将探索 Project Reactor 的 MathFlux 模块，并了解如何利用它在响应式流上执行各种数学运算。

2. Maven 依赖

让我们在我们的 IDE 中创建一个 Spring Boot 项目，并将 reactor-core 和 reactor-extra 依赖项添加到 pom.xml 文件中：

错误处理是使用Spring WebFlux进行响应式编程的一个关键方面。开发者通常依赖两种主要方法来处理错误：抛出异常或使用Project Reactor提供的_Mono.error()_方法。这两种方法都用于信号错误，但它们具有不同的特点和用例。

在本教程中，我们将解释在Spring WebFlux中抛出异常和使用_Mono.error()_的区别。我们将提供说明性的Java代码示例，以使其更易于理解。

2. 传统方法：抛出异常

多年来，抛出异常一直是管理Java应用程序中错误的可靠方式。这是一种简单的方法，可以中断程序的正常流程，并将错误传达给应用程序的更高层。Spring WebFlux与这种传统的错误处理方法无缝集成，使开发者能够在其响应式端点中抛出异常。下面的代码代表了传统方法的一个例子：

拦截器，也被称为过滤器，是 Spring 的一个特性，允许我们拦截客户端请求。这使我们能够在控制器处理它或向客户端返回响应之前检查和转换请求。

在本教程中，我们将讨论使用 WebFlux 框架拦截客户端请求并添加自定义头部的各种方式。我们首先探索如何为特定端点执行此操作。然后，我们将确定拦截所有传入请求的方法。

我们将使用以下 spring-boot-starter-webflux Maven 依赖项，以支持 Spring 框架的响应式 Web 功能：

`<dependency>`
    `<groupId>`org.springframework.boot`</groupId>`
    `<artifactId>`spring-boot-starter-webflux`</artifactId>`
    `<version>`3.1.5`</version>`
`</dependency>`

在Reactor库中，Flux.map()和Flux.doOnNext()操作符在处理流数据元素时扮演着不同的角色。

Flux.map()操作符有助于转换Flux发出的每个元素。Flux.doOnNext()操作符是一个生命周期钩子，允许我们在每个元素发出时执行副作用操作。

在本教程中，我们将深入探讨这些操作符的详细信息，探索它们的内部实现和实际用例。此外，我们还将看到如何一起使用这两个操作符。

Maven依赖

要使用Flux发布者和其他响应式操作符，让我们将reactor-core依赖项添加到pom.xml中：

\<dependency\>
    \<groupId\>io.projectreactor\</groupId\>
    \<artifactId\>reactor-core\</artifactId\>
    \<version\>3.6.5\</version\>
\</dependency\>

1. 概述

在响应式编程中，我们有多种方法可以创建类型为 Mono 或 Flux 的发布者。在这里，我们将探讨使用 defer 方法来延迟执行 Mono 发布者。

2. Mono.defer 方法是什么？

我们可以使用 defer 方法创建一个最多产生一个值的冷发布者。让我们看看方法签名：

public static ````<T>```` Mono````<T>```` defer(Supplier``<? extends Mono<? extends T>``> supplier)

在这篇简短的教程中，我们将探索 Spring 5 WebFlux 中的 Mono 对象的各种监听器。我们将比较 doOnNext() 和 doOnSuccess() 方法，并发现尽管它们相似，但对于空的 Mono，它们的行为是不同的。

Mono 的 doOnNext() 允许我们附加一个监听器，当数据被发出时会被触发。 在本文的代码示例中，我们将使用 PaymentService 类。在这种情况下，我们只有在 paymentMono 发出数据时，使用 doOnNext() 调用 processPayment 方法：

@Test
void givenAPaymentMono_whenCallingServiceOnNext_thenCallServiceWithPayment() {
    Payment paymentOf100 = new Payment(100);
    Mono````<Payment>```` paymentMono = Mono.just(paymentOf100);

    paymentMono.doOnNext(paymentService::processPayment)
        .block();

    verify(paymentService).processPayment(paymentOf100);
}

在本教程中，我们将探讨在Project Reactor中处理异常的几种方式。代码示例中引入的操作符在_Mono_和_Flux_类中都有定义。然而，我们将只关注_Flux_类中的方法。

2. Maven依赖

让我们从添加Reactor核心依赖开始：

`<dependency>`
    `<groupId>`io.projectreactor`</groupId>`
    `<artifactId>`reactor-core`</artifactId>`
    `<version>`3.6.0`</version>`
`</dependency>`