### Spring-webflux簡介 spring-webflux是spring在5.0版本後提供的一套響應式編程風格的web開發框架，大量測評證明，使用WebFlux開發介面能夠大幅提升介面的吞吐量。 這個框架包含了spring-framework和spring mvc，它可以運行在Netty ...
Spring-webflux簡介
spring-webflux是spring在5.0版本後提供的一套響應式編程風格的web開發框架，大量測評證明，使用WebFlux開發介面能夠大幅提升介面的吞吐量。
這個框架包含了spring-framework和spring mvc，它可以運行在Netty、Undertow以及3.1版本以上的Serlvet容器上。你可以在項目中同時使用spring-webmvc和spring-webflux，或者只用其中一個來開發web應用。
什麼是“響應式”
所謂響應式，舉個例子，當調用一個api獲取數據時，無需阻塞等待數據返回，而是當有數據返回時會進行告知。可見響應式是非阻塞的，意味著調用方法後，CPU可以去做別的事情，當接收到數據響應時CPU再回來處理，這種方式提高了系統的吞吐量。
而響應式編程，其實是為這種非同步非阻塞的流式編程制定的一套標準。流式編程已不陌生了，Java8提供的stream api就是這種風格。這套標準包括對運行環境（JVM、JavaScript）以及網路協議相關的規範。
Spring-webflux的響應式API
Spring-webflux框架是基於Reactor這個開源項目開發的。Reactor框架是跟Spring緊密配合的。
它提供了兩種API類型，分別是Mono和Flux；
// Mono一般作用於單個對象
Mono<Person> person = personDao.getPerson(personId);
// Flux一般作用於多個對象
Flux<Person> people = personDao.listAllPeople();
儘管webflux框架基於Reactor，它也能與其他的響應式框架同時使用，比如RxJava。
推薦一個開源免費的 Spring Boot 實戰項目：
選擇Spring-webmvc還是Spring-webflux呢
這兩個web框架分別代表著兩種不同類型的編程流派，官方給出了一個圖作為對比如下
根據官方的建議有以下幾點可以作為參考：
- 如果你已經使用了Spring-webmvc進行開發，並且項目運行良好，就無需更改了；何況現在大多數的三方庫都是阻塞的，並不能發揮出非阻塞的優勢。
- webflux提供了相當多的選擇；在服務層，可以使用(Netty, Tomcat, Jetty, Undertow, 和3.1版本以上的Servlet容器)作為web服務；在應用層，可以選擇用
@Controller定義還是使用函數編程定義；在編程風格上，可以選擇用Reactor、RxJava或其他。 - 如果你鐘愛Java8提供的lambda表達式這種輕量級、函數式的編程風格，那麼建議選擇用webflux；同時對於一些輕量級應用，或者複雜度比較低的微服務，建議使用webflux以便更好的進行控制。
- 在微服務架構中，可以將webmvc和webflux項目混合使用。兩個框架都可以使用
@Controller這種註解的方式，使得項目的重用更加容易。 - 評估一個項目是否應該選擇webflux的最簡單的方式是，依據項目中是否會使用很多的阻塞API，比如JDBC或者一些阻塞式的API就不適用與webflux項目。
- 如果一個webmvc項目中有很多的外部系統調用，可以試試響應式的WebClient，它能直接從Controller的方法中返迴響應式結果。
- 響應式編程的學習路線是比較陡峭的，所以如果你身在一個大型的團隊中，要考慮投入的成本；不過可以用用WebClient來體驗下響應式編程。
Spring-webflux不僅可以支持在Tomcat、Jetty以及3.1版本以上的Servlet容器上，還能夠運行在非Servlet的伺服器之上，比如Netty、Undertow等。
使用Springboot構建一個webflux應用，預設就是使用Netty，因為Netty本身就是非阻塞式的實現。
併發模型
儘管webmvc和webflux都支持使用註解來定義一個Controller，但是其實現方式完全不同。
webmvc是一個Servlet應用，實現是阻塞式IO，其維護一個線程池來處理每一個用戶請求，也就是當Servlet容器啟動時，就會創建比如10個線程出來，因此系統吞吐量的瓶頸在於有限的連接數和阻塞的請求處理過程。
webflux可以基於netty這樣的NIO網路框架，它只需要很少的幾個工作線程（Event loop worker）就能夠處理並響應請求。由於無需阻塞等待方法返回，CPU資源就得到了更好的利用。
webflux並不能讓程式運行地更快；而是提高了併發處理請求的能力，即提高了系統吞吐量。
webflux代碼示例
Talk is cheap, show me the code
下麵讓我們來看一下webflux的示例，總的來說使用上是非常便捷的。
我們用Springboot構建一個webflux應用非常簡單，僅僅需要加入這麼一個依賴
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-webflux</artifactId>
</dependency>
首先定義一個對象
public class Person {
private Integer id;
private Integer age;
private String name;
}
然後定義“PersonController”，響應式風格中不再使用@RequestMapping聲明地址映射了，而是通過RouterFunctions.route().GET()方法
@Configuration
public class PersonRouter {
@Resource
private PersonHandler personHandler;
@Bean
public RouterFunction<ServerResponse> personRoutes() {
return RouterFunctions.route()
.GET("/person/{id}", RequestPredicates.accept(MediaType.APPLICATION_JSON), personHandler::getPerson)
.GET("/person", RequestPredicates.accept(MediaType.APPLICATION_JSON), personHandler::listPeople)
.POST("/person", personHandler::createPerson)
.build();
}
}
在PersonHandler中處理對應的HTTP請求，等同於MVC架構中的Service層
@Component
public class PersonHandler {
@Resource
private PersonRepository personDao;
public Mono<ServerResponse> listPeople(ServerRequest request) {
Flux<Person> people = personDao.listAllPeople();
return ServerResponse.ok()
.contentType(MediaType.APPLICATION_JSON)
.body(people, Person.class);
}
public Mono<ServerResponse> createPerson(ServerRequest request) {
Mono<Person> person = request.bodyToMono(Person.class);
return ServerResponse.ok()
.build(personDao.savePerson(person));
}
public Mono<ServerResponse> getPerson(ServerRequest request) {
int personId = Integer.parseInt(request.pathVariable("id"));
return personDao.getPerson(personId)
.flatMap(person -> ServerResponse.ok().contentType(MediaType.APPLICATION_JSON).bodyValue(person))
.switchIfEmpty(ServerResponse.notFound().build());
}
}
通過啟動日誌可以證實Spring-webflux是預設使用Netty提供HTTP服務
項目啟動之後瀏覽器訪問http://localhost:8080/person/1就能發現，你的Spring-webflux項目已經正常工作了。
原文鏈接：https://blog.csdn.net/yasin_huang/article/details/106556935
近期熱文推薦：
1.1,000+ 道 Java面試題及答案整理(2022最新版)
4.別再寫滿屏的爆爆爆炸類了，試試裝飾器模式，這才是優雅的方式！！
覺得不錯，別忘了隨手點贊+轉發哦！
