RSocket 是一種應用協議,提供 Reactive Streams 語義——它作為 HTTP 的一種替代方案而運作,例如。在本教程中,我們將使用 Spring Boot 探討 RSocket,並重點關注它如何抽象底層細節。
知識庫 / Reactive RSS 訂閱
響應式應用中的 Spring AMQP
本教程演示如何創建簡單的 Spring Boot Reactive 應用,並與 RabbitMQ 消息服務器集成,RabbitMQ 是 AMQP 消息標準的一種流行實現。 教程涵蓋了點對點和發佈訂閲兩種場景。
將單對象轉換為另一個單對象(Spring WebFlux)
Spring WebFlux 是一種反應式編程框架,它支持異步、非阻塞通信。使用 WebFlux 的關鍵在於處理 Mono 對象,這些對象代表單個異步結果。在實際應用中,我們經常需要處理 Mono 對象。
使用 WebClient 上傳文件
我們的應用程序經常需要通過 HTTP 請求處理文件上傳。自 Spring 5 版本起,我們現在可以對這些請求進行響應式處理。 新增的響應式編程支持使我們能夠以非阻塞方式工作,利用少量線程...
使用 Spring Reactive WebClient 將 Flux 轉換為單個 InputStream
本教程將深入探討 Java 響應式編程,以解決如何將 FluxDataBuffer 讀取到一個單一 InputStream 的有趣問題。作為解決將 FluxDataBuffer 讀取到單一 InputStream 的第一步……
Spring 與 Akka 入門
本文將重點介紹如何將 Akka 與 Spring Framework 集成,從而將 Spring 框架中的服務注入到 Akka 演員中。閲讀本文前,建議您對 Akka 的基本知識有所瞭解。Akka 是一款功能強大的應用程序。
R2DBC – 反應式關係數據庫連接
本教程將演示如何使用 R2DBC 以反應式方式執行數據庫操作。為了探索 R2DBC,我們將創建一個簡單的 Spring WebFlux REST 應用,該應用實現對單個實體的 CRUD 操作,並完全採用異步方式。
Spring 反應式編程系列
Spring WebFlux 指南 Spring WebFlux 過濾器 Spring WebFlux 中的靜態內容 Spring WebFlux 中的錯誤處理 使用 Spring WebFlux 返回 404 Spring MVC 異步與 Spring WebFlux
Spring WebClient
本教程將探討 WebClient,這是一個在 Spring 5 中引入的反應式 Web 客户端。我們還將研究 WebTestClient,這是一種專為測試設計的 WebClient。WebClient 作為一個接口,代表…
Spring WebFlux 反壓機制
Spring WebFlux 提供反應式編程給 Web 應用程序。 反應式設計的異步和非阻塞特性可以提高性能和內存利用率。 Project Reactor 提供這些能力,以高效地管理數據流。
Spring WebClient exchange() 與 retrieve() 區別詳解
WebClient 是一個接口,旨在簡化 HTTP 請求的處理過程。與 RestTemplate 相比,它是一個反應式、非阻塞的客户端,可以消費和操作 HTTP 響應。雖然設計為非阻塞,但也可用於……
Spring WebFlux 試錯重試指南
在構建分佈式雲環境中的應用程序時,我們需要設計容錯機制,這通常涉及重試。 Spring WebFlux 提供了幾個用於重試失敗操作的工具。 本教程將介紹如何添加和配置重試。
Spring WebFlux 靜態內容
在我們的Web應用程序中,有時需要提供靜態內容,例如圖像、HTML、CSS或JavaScript文件。本教程將演示如何使用Spring WebFlux提供靜態內容。我們假設我們的Web應用程序將...
Spring Webflux 和 @Cacheable 註解
本文將解釋 Spring WebFlux 如何與 @Cacheable 註解交互。首先,我們將討論常見問題及避免方法,然後介紹可用的解決方法,最後提供代碼示例。
訪問 Flux 中的第一個元素方法
本教程將探討如何訪問 Fluxwith Spring 5 WebFlux 中的第一個元素。首先,我們將使用非阻塞 API 方法,如 next() 和 take()。然後,我們將探討如何使用這些方法實現相同的結果。
Spring 中的服務器發送事件
本教程將介紹如何使用 Spring 實現基於 Server-Sent-Events 的 API。簡而言之,Server-Sent-Events (SSE) 是一種 HTTP 標準,允許 Web 應用程序處理單向事件流並接收更新。
使用反應式 Kafka 流和 Spring WebFlux 進行開發
本文將探討Reactive Kafka Streams,並將其集成到示例 Spring WebFlux 應用中,同時分析這種組合如何使我們能夠構建具有可擴展性、效率和實時性的完全響應式、數據密集型應用。
使用 zipWhen() 與 Mono
本教程將探討如何使用 zipWhen() 方法,以協調的方式組合兩個或多個 Mono 流的結果。首先,我們將進行一個快速概述。然後,我們將設置一個簡單的示例,涉及用户數據存儲和電子郵件。
Spring WebFlux 反應式流中的條件語句
在 Spring WebFlux 反應式流中運用條件語句,可以實現動態決策,處理反應式流。與命令式編程不同,反應式編程中的條件邏輯不侷限於 if-else 語句。 而是可以進行更靈活的決策。
併發 Spring WebClient 調用
在應用程序中執行HTTP請求通常是順序執行的。然而,在某些情況下,我們可能需要同時執行這些請求。例如,在從多個來源獲取數據時,我們可能需要並行執行這些請求。