Spring 中 WebFlux 編寫一個簡單的 Controller

引言：響應式編程與 WebFlux

隨著應用程序需要處理大量并發請求的情況越來越多，傳統的 Servlet 編程模式可能無法滿足高效和低延遲的需求。為了應對這種情況，Spring 5 引入了 WebFlux，一個基于響應式編程的 Web 框架，旨在通過非阻塞的 I/O 模型提供更高的性能。

WebFlux 是 Spring 5 中提供的響應式 Web 框架，它基于 Reactor 庫，并支持響應式流（Reactive Streams）。它允許你以非阻塞的方式編寫處理 HTTP 請求的代碼，從而更好地處理高并發場景。

在這篇文章中，我們將學習如何在 Spring WebFlux 中編寫一個簡單的 Controller，來處理 HTTP 請求并響應數據。

一、什么是 WebFlux

Spring WebFlux 是 Spring 5 引入的模塊，它與傳統的基于 Servlet 的 Spring MVC 相對立。WebFlux 采用響應式編程模型，通過使用 Mono 和 Flux 類型來支持異步和非阻塞的 Web 應用開發。

Mono：代表一個單一元素的異步序列。
Flux：代表一個包含 0 到 N 個元素的異步序列。

這種響應式方式的最大優勢在于處理大量并發請求時，可以避免線程阻塞，提高系統的吞吐量和資源利用率。

二、創建 Spring WebFlux 項目

首先，我們需要在 Spring Boot 項目中啟用 WebFlux。通過 spring-boot-starter-webflux 來集成 WebFlux：

1. 在 `pom.xml` 中添加依賴：

<dependencies><!-- Spring Boot WebFlux Starter --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-webflux</artifactId></dependency><!-- Spring Boot Starter for Reactive Testing --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope></dependency>
</dependencies>

2. 啟動類 `@SpringBootApplication`：

@SpringBootApplication
public class WebFluxExampleApplication {public static void main(String[] args) {SpringApplication.run(WebFluxExampleApplication.class, args);}
}

三、編寫簡單的 WebFlux Controller

在 WebFlux 中，Controller 的編寫與傳統的 Spring MVC 類似，但它支持響應式返回類型 Mono 和 Flux。我們來編寫一個簡單的 Controller，展示如何使用 WebFlux 來處理 HTTP 請求。

1. 創建一個簡單的 Controller：

@RestController
@RequestMapping("/api")
public class MyController {// GET 請求，返回一個字符串@GetMapping("/greet")public Mono<String> greet() {return Mono.just("Hello, WebFlux!");}// GET 請求，返回一個簡單的對象@GetMapping("/user")public Mono<User> getUser() {User user = new User("John", "Doe");return Mono.just(user);}// GET 請求，返回一個包含多個對象的 Flux@GetMapping("/users")public Flux<User> getUsers() {User user1 = new User("Alice", "Wonderland");User user2 = new User("Bob", "Marley");return Flux.just(user1, user2);}
}

2. 創建 `User` 類：

public class User {private String firstName;private String lastName;// 構造器public User(String firstName, String lastName) {this.firstName = firstName;this.lastName = lastName;}// Getters and Setterspublic String getFirstName() {return firstName;}public void setFirstName(String firstName) {this.firstName = firstName;}public String getLastName() {return lastName;}public void setLastName(String lastName) {this.lastName = lastName;}
}

3. 請求示例：

GET /api/greet：返回一個字符串 "Hello, WebFlux!"
GET /api/user：返回一個 User 對象，類似于 {"firstName": "John", "lastName": "Doe"}。
GET /api/users：返回一個 User 數組，包含兩個用戶對象。

四、響應式編程模型

在 WebFlux 中，Mono 和 Flux 是核心概念：

Mono：表示 0 或 1 個元素的異步序列，常用于返回單一對象或沒有內容的響應。
Flux：表示 0 到 N 個元素的異步序列，常用于返回多個對象或列表。

通過使用 Mono 和 Flux，Spring WebFlux 可以在服務器端異步地處理請求，不會阻塞線程，從而實現更高效的并發處理。

五、運行 WebFlux 應用

啟動 Spring Boot 應用：
運行你的 Spring Boot 應用，它將自動配置一個內嵌的 Web 服務器（如 Tomcat 或 Netty）。你可以訪問 WebFlux 提供的 REST API。
測試 API：
打開瀏覽器或 Postman，訪問以下 URL：
- http://localhost:8080/api/greet
- http://localhost:8080/api/user
- http://localhost:8080/api/users
你將能夠看到返回的響應數據。