Ratpack 与反应式流 API

1. 引言

Ratpack 是一个基于 Netty 引擎构建的框架，它允许我们快速构建 HTTP 应用程序。我们之前的文章已经介绍了它的基本用法。这次，我们将展示如何使用其流 API 实现反应式应用程序。

2. 反应式流的快速回顾

在深入实际实现之前，让我们首先回顾一下构成反应式应用程序的基本属性。根据原始作者的说法，这类应用程序必须具备以下属性：

• 响应式
• 弹性
• 消息驱动

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

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

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

2. 什么是Flux？

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

1. 概述

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

2. Mono.defer 方法是什么？

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

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