以下是關于Reactor框架中Flux與Mono的功能介紹、使用示例及對比分析：

Flux功能介紹

1. 核心定義

   • Flux是Reactor庫中的核心接口，表示一個異步的、包含零到多個元素的序列（類似流式數據處理）[³][⁴][⁷]。它可以處理無限長度的數據流，適用于需要持續處理多個事件的場景[⁴][⁸]。

2. 關鍵特性

   • 異步非阻塞：基于響應式編程模型，以事件驅動方式處理數據流，避免阻塞主線程[³][⁴]。
   • 背壓支持：通過背壓機制協調生產者與消費者速率，防止數據過載[³][⁸]。
   • 豐富操作符：提供map、filter、flatMap、merge等操作符，支持數據轉換、合并、分組等復雜邏輯[³][⁷]。
   • 多源組合：可合并多個Flux或Mono流，實現多數據源的聚合處理[⁷][⁸]。
   • 狀態管理：支持冷/熱流切換，適應不同訂閱場景[⁸]。

3. 典型應用場景

   • 實時數據流處理（如消息隊列、傳感器數據）[⁴]。
   • 數據庫批量查詢（如獲取多條記錄）[⁴][⁷]。
   • 異步任務并行執行與結果合并[⁷]。

完整使用示例

以下是Flux的典型使用場景及代碼示例：

1. 多數據源合并與處理

   import reactor.core.publisher.Flux;
   import reactor.core.publisher.Mono;public class FluxExample {// 模擬從數據庫獲取產品列表public static Flux<Product> getProductsFromDatabase() {List<Product> products = Arrays.asList(new Product(1, "Phone", 500),new Product(2, "Laptop", 1200));return Flux.fromIterable(products);}// 模擬獲取限時優惠public static Flux<Product> getSpecialOffers() {List<Product> offers = Arrays.asList(new Product(3, "Headphones", 200));return Flux.fromIterable(offers);}// 模擬新商品通知public static Mono<Product> getNewProductNotification() {return Mono.just(new Product(4, "Smartwatch", 300));}public static void main(String[] args) {Flux.concat(getProductsFromDatabase(),getSpecialOffers(),getNewProductNotification()).filter(product -> product.getPrice() < 1000) // 過濾低價商品.sort((p1, p2) -> Integer.compare(p1.getPrice(), p2.getPrice())) // 按價格排序.subscribe(product -> System.out.println("Selected Product: " + product));}
   }// 輸出結果：
   // Selected Product: Headphones
   // Selected Product: Phone
   // Selected Product: Smartwatch
   

   • 說明：通過Flux.concat合并多個數據源（數據庫、優惠、通知），過濾并排序后輸出[⁷][⁸]。

2. 異步操作與背壓處理

   Flux.range(1, 10) // 生成1-10的流.map(i -> i * 2) // 映射為2-20.onBackpressureBuffer() // 啟用背壓緩沖.subscribe(data -> System.out.println("Received: " + data), // 處理數據error -> System.err.println("Error: " + error), // 錯誤處理() -> System.out.println("Stream completed") // 完成回調);
   

   • 說明：演示流式數據處理與背壓控制，確保生產者與消費者速率匹配[³][⁸]。

與Mono對比

特性	Flux	Mono
元素數量	0到多個	0或1個
適用場景	多事件流（如數據集合、實時流）	單次結果（如單個查詢、API響應）
典型操作	合并流（concat）、分組（group）	默認值（switchIfEmpty）、緩存（cache）
性能特點	適合高吞吐量、大數據量處理	輕量級，適合快速響應單一結果
錯誤處理	支持流中局部錯誤處理	單一錯誤信號
示例	數據庫批量查詢、消息隊列消費	單個用戶查找、HTTP請求返回

1. 核心區別

   • Flux：面向多元素流，強調流式處理與組合操作，適合復雜數據流場景[³][⁴]。
   • Mono：面向單元素或空結果，更適合簡單異步操作，如單一數據獲取或狀態更新[⁴][⁸]。

2. 互轉與組合

   • Mono轉Flux：Mono.just(value).flux() 將單元素轉換為Flux。
   • Flux轉Mono：flux.reduce() 或 flux.next() 提取單個結果。
   • 合并多個Mono：Mono.zip(mono1, mono2) 或 Flux.concat(mono1, mono2)[⁷][⁸]。

3. 選擇建議

   • 若需要處理多個并發事件或數據集合，優先使用Flux[⁴]。
   • 若僅需獲取單一結果（如配置項、單次查詢），使用Mono更簡潔[³][⁸]。

總結

1. Flux是Reactor中處理異步多元素流的核心工具，適用于流式數據處理、多源合并等場景，提供強大的操作符和背壓支持。
2. Mono則專注于單元素或空結果的異步處理，適合輕量級單向操作。
3. 實際開發中，根據數據特性（單/多結果）選擇合適的類型，并利用其組合能力構建高效的響應式應用[³][⁴][⁷][⁸]。