Spring Boot WebFlux
最后修改于 2023 年 7 月 21 日
Spring Boot WebFlux 教程展示了如何使用 WebFlux 创建一个简单的 Spring Boot 响应式 Web 应用程序。
WebFlux
WebFlux 是一个 Spring 响应式堆栈 Web 框架。它被添加到 Spring 5 中。它完全非阻塞，支持响应式流背压，并在 Netty、Undertow 和 Servlet 3.1+ 容器等服务器上运行。
Spring WebFlux 是传统 Spring MVC 的替代方案。
Spring WebFlux 内部使用 Project Reactor 及其发布者实现 Flux 和 Mono。它支持两种编程模型：a) 基于注解的响应式组件，b) 函数式路由和处理。
响应式编程
响应式编程 是一种编程范式，它具有函数式、事件驱动、非阻塞、异步的特点，并以数据流处理为中心。术语“响应式”源于我们对变化的反应，例如鼠标点击或 I/O 事件。
当我们处理大量流数据时，响应式应用程序的可伸缩性更好，效率也更高。 响应式应用程序是非阻塞的；它们不使用资源等待进程完成。
响应式应用程序实现了一个基于事件的模型，其中数据被推送到使用者。数据的消费者（订阅者）订阅发布者，发布者发布异步的数据流。
Spring Reactor
Spring Reactor 是一个用于在 JVM 上构建非阻塞应用程序的响应式库，基于响应式流规范。
Reactor 项目提供两种类型的发布者：Mono 和 Flux。Flux 是一个发布者，它产生 0 到 N 个值。返回多个元素的操作使用此类型。Mono 是一个发布者，它产生 0 到 1 个值。它用于返回单个元素的操作。
Spring Boot WebFlux 示例
在下面的应用程序中，我们创建了一个简单的 Spring Boot Web 应用程序，具有响应式支持。
build.gradle
...
src
├───main
│ ├───java
│ │ └───com
│ │ └───zetcode
│ │ │ Application.java
│ │ └───controller
│ │ MyController.java
│ └───resources
│ application.properties
└───test
└───java
这是项目结构。
plugins {
id 'org.springframework.boot' version '3.1.1'
id 'io.spring.dependency-management' version '1.1.0'
id 'java'
}
group = 'com.zetcode'
version = '0.0.1-SNAPSHOT'
sourceCompatibility = '17'
repositories {
mavenCentral()
}
dependencies {
implementation 'org.springframework.boot:spring-boot-starter-webflux'
}
这是 Gradle 构建文件。spring-boot-starter-webflux 是一个 Spring Boot starter，用于使用 Spring 框架的响应式 Web 支持构建 WebFlux 应用程序。
spring.main.banner-mode=off
在 application.properties 中，我们关闭了 Spring Boot 横幅。
package com.zetcode.controller;
import org.reactivestreams.Publisher;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import reactor.core.publisher.Mono;
@RestController
public class MyController {
@GetMapping("/")
public Publisher<String> home() {
return Mono.just("Home page");
}
}
我们有一个简单的 REST 接口，它返回一条消息。home 方法的返回类型是 Publisher。Mono.just 发出一个指定的字符串消息。
package com.zetcode;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
@SpringBootApplication
public class Application {
public static void main(String[] args) {
SpringApplication.run(Application.class, args);
}
}
此代码设置了 Spring Boot 应用程序。
$ ./gradlew bootRun
我们运行应用程序并导航到 localhost:8080。
在本文中，我们创建了一个简单的 Spring Boot WebFlux 应用程序。