Micronaut Reactor
Micronaut 和 Reactor 之间的集成。
1. 简介
Micronaut Reactor 为 Micronaut 2.x 应用程序添加了对 Project Reactor 的支持。如果你使用的是 Micronaut 1.x,则不需要此模块。
- Reactor 类型的转换器,以便在控制器和客户端中使用 Reactor 类型。
- 用于 Reactor 类型的仪表,以便对 Reactor 类型进行跟踪
- 支持 Reactor 的 Http 客户端版本
2. 发布历史
关于此项目,你可以在此处找到版本列表(含发布说明):
https://github.com/micronaut-projects/micronaut-reactor/releases
3. 重大变更
3.0.0
Reactor Http 客户端
Reactor Http 客户端改为返回 Mono<HttpResponse<O>>
而非 Flux<HttpResponse<O>>
。这在语义上更为正确,因为每个请求只能有一个响应。
4. 快速开始
在 Micronaut 应用程序中添加以下依赖:
- Gradle
- Maven
implementation("io.micronaut.reactor:micronaut-reactor")
<dependency>
<groupId>io.micronaut.reactor</groupId>
<artifactId>micronaut-reactor</artifactId>
</dependency>
要使用 HTTP 客户端,请添加以下依赖:
- Gradle
- Maven
implementation("io.micronaut.reactor:micronaut-reactor-http-client")
<dependency>
<groupId>io.micronaut.reactor</groupId>
<artifactId>micronaut-reactor-http-client</artifactId>
</dependency>
要使用 Micronaut HTTP 客户端的 Reactor 变体,请注入 ReactorHttpClient 接口(或其他变体)。例如:
import io.micronaut.reactor.http.client.*;
@Inject ReactorHttpClient httpClient; // regular client
@Inject ReactorSseClient sseClient; // server sent events
@Inject ReactorStreamingHttpClient streamingClient; // streaming
5. 仓库
你可以在此资源库中找到此项目的源代码:
https://github.com/micronaut-projects/micronaut-reactor