近年來，響應式編程在開發者社區和客戶中很受歡迎，由於其以聲明的方式構建應用程序的能力，而不是強制，形成更加敏感和有彈性的應用。 Spring 5 將反應系統納入其核心框架的事實已經顯示出向聲明式編程的範式轉變。
響應式編程管理數據生產者和消費者之間的異步數據流，它們需要以流暢的方式對數據進行響應。所以，響應式編程都是異步和事件驅動的流暢應用程序，需要少量的線程進行縮放。
響應式編程很難構建基於線程的架構，由於在基於共享可變狀態、線程和鎖的應用程序擴展過程中涉及到高度複雜性。
在響應式編程的上下文中，“在流中有數據時，所有事物都是流並以流暢方式行為。”
高層次的抽象與響應式編程導致了代碼可讀性的提高，因此開發人員可以主要關注定義業務邏輯的事件的相互依存性。
在高度並發的環境中，響應模式自然地適合於消息處理，這是一個常見的企業用例。
由於執行反壓力的特性，響應式方法最適合控制生產者和消費者之間的流量，這將有助於避免內存不足。
對於一個或幾個線程，IO綁定任務可以通過異步和非阻塞方式執行，而且不阻塞當前線程。
在高交互和實時應用程序或任何操作/事件時，都可能觸發多個連接子系統的通知，在這種情況下響應式編程可以更有效的進行管理。
“響應流”定義一個API 規範，其中包含一組最小的接口，這些接口公開了定義非阻塞反壓力的數據流的操作和實體的方法。
隨著反壓力的引入，響應流允許用戶控制來自出版商的數據交換速率。
響應流API java.util.concurrent.flow 已正式成為java 9 的一部分。
響應流主要用作互操作層。
Spring-Web-Reactive 模塊和Spring MVC 都支持相同的@Controller 編程，但Spring-Web-Reactive 是在Reactive 和非阻塞引擎上執行的。
遵循這個文檔，見：
http://docs.spring.io/spring-framework/docs/5.0.0.BUILD-SNAPSHOT/spring-framework-reference/html/web-reactive.html
Spring-Web-Reactive 模塊和Spring MVC 共享許多通用的算法，但Spring-Web-Reactive 模塊已經重新定義了許多Spring MVC 契約，例如HandlerMapping和HandlerAdapter，以使它們變得異步和非阻塞，以及啟用響應式HTTP 請求和響應（以RouterFunction 和HandlerFunction 的形式）。
除了現有的RestTemplate 外，新的響應式WebClient 也在Spring 5 中引入。
支持響應式編程的HTTP 客戶端（例如Reactor、Netty、Undertow）已經採用了一系列響應式的ClientHttpRequest 和ClientHttpResponse 抽象，它們將請求和響應體作為Flux <DataBuffer> 公開，並且在讀寫端提供全面的背壓支持。
Spring 5 Framework 引入了Reactor，作為Reactive Streams 規範的實現。
Reactor 是用於在JVM 上構建非阻塞應用程序的下一代Reactive 庫。
Reactor 擴展了基本的Reactive Streams Publisher 契約，並定義了Flux 和Mono API 類型，分別為0..N 和0..1 的數據序列提供聲明性操作。
Spring Web Reactive 使用Servlet 3.1 提供了非阻塞I/O，並運行在Servlet 3.1 容器上。
Spring WebFlux 提供了兩種編程模型可供選擇。
Spring 5 包含了Spring Web Reactive（在spring-web-reactive 模塊下）和Spring Web MVC（在spring-webmvc 模塊下）。
雖然Spring Web Reactive 和Spring Web MVC 模塊共享了很多算法，但是由於Spring Web Reactive 能夠在響應式的非阻塞Reactive Streams HTTP 適配器層上運行，因此它們之間不共享代碼。
Spring MVC 執行需要Servlet 容器，而Spring Web Reactive 也可以在非Servlet 運行時上運行，比如在Netty 和Undertow 上運行。
如果對具有輕量級、函數式的Web 框架的非阻塞Web 棧的必要要求，並與Java 8 lambda 或Kotlin一起使用，則應該考慮從Spring MVC 應用程序切換到Spring Web Reactive。
這是一個2.0.0 M5 版本的pom.xml ，依賴於WebFiux。
<parent> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-parent</artifactId> <version>2.0.0.M5</version></parent><dependencies> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-webflux</artifactId> </dependency></dependencies>
傳統方法VS. 響應方法
在傳統方法中，執行將被阻塞，並將一直等到您的服務執行完成為止。在下面的代碼中，在第一個print 語句之後，程序執行將被阻塞並等待服務執行完成。在服務執行完成後，將恢復程序執行，並執行第二個print 語句。
@GetMapping("/traditional")public List < Product > getAllProducts() { System.out.println("Traditional way started"); List < Product > products = prodService.getProducts("traditional"); System.out.println("Traditional way completed"); return products;}在響應方法中，程序執行將繼續，而不用等待服務執行的完成。在下面的代碼中，在第一個print 語句之後，第二個print 語句將以非阻塞的方式執行，而無需等待服務執行的完成。 Flux stream 將隨著產品數據的可用性而被填充。
@GetMapping(value = "/reactive", .TEXT_EVENT_STREAM_VALUE)public Flux < Product > getAll() { System.out.println("Reactive way using Flux started"); Flux < Product > fluxProducts = prodService.getProductsStream("Flux"); System.out.println("Reactive way using Flux completed"); return fluxProducts;}除了現有的RestTemplate 之外，Spring 5 還引入了Reactive WebClient。
ClientHttpRequest 和ClientHttpResponse 抽象將請求和響應主體使用Flux <DataBuffer> 公開，並在讀和寫端提供完全背壓支持。
來自Spring Core 的編碼器和解碼器抽像也用在客戶端，用於將字節序的Flus 序列化或發序列化成類型對象。
下面是一個Reactive WebClient 的示例，它調用終端並接收及處理Reactive Stream Flux 對象。
@GetMapping("/accounts/{id}/alerts")public Flux < Alert > getAccountAlerts(@PathVariable Long id) { WebClient webClient = new WebClient(new ReactorClientHttpConnector()); return this.repository.getAccount(id).flatMap(account -> webClient.perform(get("/alerts/{key}", account.getKey())).extract(bodyStream(Alert.class)));}以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持武林網。