Spring 賭上未來一擊，推出回應式框架 WebFlux，代碼更優雅，性能更強！-有解無憂

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 實戰專案：

https://github.com/javastacks/spring-boot-best-practice

選擇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最新版)

2.勁爆！Java 協程要來了，，，

3.Spring Boot 2.x 教程，太全了！

4.別再寫滿屏的爆爆爆炸類了，試試裝飾器模式，這才是優雅的方式！！

5.《Java開發手冊（嵩山版）》最新發布，速速下載！

覺得不錯，別忘了隨手點贊+轉發哦！

轉載請註明出處，本文鏈接：https://www.uj5u.com/houduan/556213.html

標籤：其他

上一篇：解鎖高質量檔案轉換：通過Java應用程式免費將PDF轉換為XPS

下一篇：返回列表