spring-webflux是spring在5.0版本後提供的一套響應式編程風格的web開發框架。
這個框架包含了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-webmvc還是Spring-webflux呢
這兩個web框架分別代表着兩種不同類型的編程流派，官方給出了一個圖作為對比如下
根據官方的建議有以下幾點可以作為參考：
Spring-webflux不僅可以支持在Tomcat、Jetty以及3.1版本以上的Servlet容器上，還能夠運行在非Servlet的服務器之上，比如Netty、Undertow等。
使用Springboot構建一個webflux應用，默認就是使用Netty，因為Netty本身就是非阻塞式的實現。面試寶典：https://www.yoodb.com
並發模型
儘管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的示例，總的來說使用上是非常便捷的。面試寶典：https://www.yoodb.com
我們用Springboot構建一個webflux應用非常簡單，僅僅需要加入這麼一個依賴
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-webflux</artifactId></dependency>
首先定義一個對象
publicclassPerson{privateIntegerid;privateIntegerage;privateStringname;}
然後定義「PersonController」，響應式風格中不再使用@RequestMapping聲明地址映射了，而是通過RouterFunctions.route().GET()方法
@ConfigurationpublicclassPersonRouter{@ResourceprivatePersonHandlerpersonHandler;@BeanpublicRouterFunction<ServerResponse>personRoutes(){returnRouterFunctions.route().GET("/person/{id}",Requestpdicates.accept(MediaType.APPLICATION_JSON),personHandler::getPerson).GET("/person",Requestpdicates.accept(MediaType.APPLICATION_JSON),personHandler::listPeople).POST("/person",personHandler::createPerson).build();}}
在PersonHandler中處理對應的HTTP請求，等同於MVC架構中的Service層
@ComponentpublicclassPersonHandler{@ResourceprivatePersonRepositorypersonDao;publicMono<ServerResponse>listPeople(ServerRequestrequest){Flux<Person>people=personDao.listAllPeople();returnServerResponse.ok().contentType(MediaType.APPLICATION_JSON).body(people,Person.class);}publicMono<ServerResponse>createPerson(ServerRequestrequest){Mono<Person>person=request.bodyToMono(Person.class);returnServerResponse.ok().build(personDao.savePerson(person));}publicMono<ServerResponse>getPerson(ServerRequestrequest){intpersonId=Integer.parseInt(request.pathVariable("id"));returnpersonDao.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項目已經正常工作了。
作者：yasin�
https://blog.csdn.net/yasin_huang/article/details/106556935
最近有很多人問，有沒有讀者交流群！加入方式很簡單，公眾號Java精選，回復「加群」，即可入群！
Java精選面試題（微信小程序）：3000+道面試題，包含Java基礎、並發、JVM、線程、MQ系列、Redis、Spring系列、Elasticsearch、Docker、K8s、Flink、Spark、架構設計等，在線隨時刷題！
特別推薦：專注分享最前沿的技術與資訊，為彎道超車做好準備及各種開源項目與高效率軟件的公眾號，「大咖筆記」，專注挖掘好東西，非常值得大家關注。點擊下方公眾號卡片關注。
留言列表