前面的文章給大家介紹了 SpringBoot 的應(yīng)用 web 類型推斷，并且結(jié)合了 Reactive web 類型給大家分析了一下 SpringBoot 是如何進(jìn)行 web 類型推斷和創(chuàng)建內(nèi)置 web 服務(wù)器的。

有小伙伴在后臺(tái)留言就問(wèn)了 Servlet web 我們天天使用很熟悉，那什么是 Reactive web 呢？?jī)烧叩膮^(qū)別是啥？今天阿粉就給大家介紹一下。

Servlet 與 Reactive 技術(shù)棧

打開(kāi) Spring 的官方文檔我們?cè)?nbsp;Reactive 一欄中可以看到下面的架構(gòu)圖，其中可以很明顯的看到 Reactive 的技術(shù)棧跟 Servlet 技術(shù)棧是完全并行的。意思是說(shuō)我們?nèi)粘ｉ_(kāi)發(fā)的 Servlet web 類型只是一半的內(nèi)容，還有另外一半世界就是 Reactive，兩者對(duì)應(yīng)的依賴如下所示。

<!--Servlet web 依賴-->
<dependency>
   <groupId>org.springframework.boot</groupId>
   <artifactId>spring-boot-starter-web</artifactId>
</dependency>
<!--Reactive web 依賴-->
<dependency>
   <groupId>org.springframework.boot</groupId>
   <artifactId>spring-boot-starter-webflux</artifactId>
</dependency>

servlet-reactive

通過(guò)架構(gòu)圖我們可以知道常用的 Servlet web 就是我們經(jīng)常說(shuō)的 Spring MVC，底層的技術(shù)棧支持 JDBC 等，而 Reactive web 就是 Spring WebFlux 底層的持久層支持 Mongo 等但是不支持 JDBC。

什么是 Spring WebFlux

由上圖我們看到 Spring WebFlux 是一個(gè)異步非阻塞式的 Web 框架，它能夠充分利用多核 CPU 的硬件資源去處理大量的并發(fā)請(qǐng)求。相對(duì)于 Spring MVC 來(lái)說(shuō)的話，Spring MVC 構(gòu)建于 Servlet API 之上，使用的是同步阻塞式 I/O 模型。

由于 Spring WebFlux 底層是使用響應(yīng)式編程，基于事件的異步驅(qū)動(dòng)，所以可以在很大程度上提升系統(tǒng)的吞吐量。但是要知道這并不會(huì)縮短請(qǐng)求的響應(yīng)時(shí)間，只是提升吞吐量。

而且根據(jù)上面的架構(gòu)圖我們可以發(fā)現(xiàn)，Spring WebFlux 底層的持久層是不支持 JDBC 的，也就是說(shuō)不支持 MySQL 等事務(wù)性數(shù)據(jù)庫(kù)，

舉個(gè)栗子

前面說(shuō)了這么多那 Spring WebFlux 到底是怎么開(kāi)發(fā)的呢？下來(lái)通過(guò)一個(gè)簡(jiǎn)單的 case 來(lái)給大家演示一下。在演示之前通過(guò)官方文檔我們可以發(fā)現(xiàn)，Spring WebFlux 和 Spring MVC 是可以共用很多組件的，比如 @Controller，Tomcat 等，但是也會(huì)存在很多差異。

Spring 官方 Reactive 地址為：https://docs.spring.io/spring-framework/docs/current/reference/html/web-reactive.html

springmvc-springwebflux

基于我們之前的 demo-reactive 項(xiàng)目的代碼，或者小伙伴也可以在 starter.spring.io 上面下載一個(gè) SpringBoot 的項(xiàng)目代碼，增加上 spring-boot-starter-webflux 依賴即可。

定義 DTO

package com.example.reactive.demoreactive.dto;

public class User {
  private String name;
  private int age;

 //省略 getter setter
}

定義 Controller

package com.example.reactive.demoreactive.controller;

import com.example.reactive.demoreactive.dto.User;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.bind.annotation.RestController;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;

import java.util.ArrayList;
import java.util.List;


@RestController
public class UserController {

  @GetMapping("/hello")
  public String sayHello(){
    return "hello";
  }

  @GetMapping("/user/get")
  public Mono<User> getUser(){
    User user = new User();
    user.setName("Java極客技術(shù)");
    user.setAge(18);
    return Mono.just(user);
  }

  @GetMapping("/user/list")
  public Flux<List<User>> getAllUser() {
    User user = new User();
    user.setName("Java極客技術(shù)");
    user.setAge(18);
    List<User> list = new ArrayList<>();
    list.add(user);
    return Flux.just(list);
  }
}

隨后啟動(dòng)我們的服務(wù)，再通過(guò)瀏覽器訪問(wèn)我們的接口就可以了。

上面三個(gè)接口的訪問(wèn)結(jié)果如下：

hello

user-get

user-list

可以看到我們?cè)跒g覽器可以正常獲取到數(shù)據(jù)，上面的代碼跟我們平時(shí)寫 SpringMVC 的代碼很相似，不太一樣的地方是有兩個(gè)類 Mono 和 FLux。

關(guān)于 Mono 和 Flux 是反應(yīng)式編程的概念，Mono 是返回 0 或 1 個(gè)元素，F(xiàn)lux 是返回 0 - N 個(gè)元素，更詳細(xì)的內(nèi)容大家可以通過(guò)官方文檔 https://projectreactor.io/docs/core/release/api/  來(lái)查看。

總結(jié)

雖然從上面的寫法來(lái)看，Spring WebFlux 的寫法與 SpringMVC 的寫法沒(méi)有很大的區(qū)別，但是兩者的底層機(jī)制是完全不一樣的，而且技術(shù)棧也不完全相同，所以大家在日常技術(shù)選型的時(shí)候需要根據(jù)實(shí)際情況去選擇。

阿粉這里給出的建議就是，如果當(dāng)下的項(xiàng)目就是 SpringMVC 的，那么不要想著換成 Spring WebFlux 架構(gòu)，因?yàn)闆](méi)必要，如果說(shuō)要新開(kāi)發(fā)一個(gè)項(xiàng)目，需要高吞吐量而且底層也不依賴事務(wù)性數(shù)據(jù)庫(kù)的話，那么可以嘗試使用一下 Spring WebFlux。