在Spring 5中,Spring MVC引入了webFlux的概念,webFlux的底層是基於reactor-netty來的,而reactor-netty又使用了Reactor庫。java
本文將會介紹在Spring Boot中reactive在WebFlux中的使用。react
前面咱們講到了,webFlux的基礎是Reactor。 因而Spring Boot其實擁有了兩套不一樣的web框架,第一套框架是基於傳統的Servlet API和Spring MVC,第二套是基於最新的reactive框架,包括 Spring WebFlux 和Spring Data的reactive repositories。git
咱們用上面的一張圖能夠清晰的看到兩套體系的不一樣。github
對於底層的數據源來講,MongoDB, Redis, 和 Cassandra 能夠直接以reactive的方式支持Spring Data。而其餘不少關係型數據庫好比Postgres, Microsoft SQL Server, MySQL, H2 和 Google Spanner 則能夠經過使用R2DBC 來實現對reactive的支持。web
而Spring Cloud Stream甚至能夠支持RabbitMQ和Kafka的reactive模型。spring
下面咱們將會介紹一個具體的Spring Boot中使用Spring WebFlux的例子,但願你們可以喜歡。數據庫
要使用Spring WebFlux,咱們須要添加以下的依賴:編程
<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-webflux</artifactId> </dependency>
只用註解的方式和普通的Spring MVC的方式很相似,咱們可使用@RestController表示是一個rest服務,可使用 @GetMapping("/hello") 來表示一個get請求。springboot
不一樣之處在於,咱們請求的產生方式和返回值。app
熟悉Reactor的朋友可能都知道,在Reactor中有兩種產生序列的方式,一種是Flux一種是Mono,其中Flux表示1或者多,而Mono表示0或者1。
看一下咱們的Controller該怎麼寫:
@RestController public class WelcomeController { @GetMapping("/hello") public Mono<String> hello() { return Mono.just("www.flydean.com"); } @GetMapping("/hellos") public Flux<String> getAll() { //使用lambda表達式 return Flux.fromStream(Stream.of("www.flydean.com","flydean").map(String::toLowerCase)); } }
這個例子中,咱們提供了兩個get方法,第一個是hello,直接使用Mono.just返回一個Mono。
第二個方法是hellos,經過Flux的一系列操做,最後返回一個Flux對象。
有了Mono對象,咱們怎麼取出裏面的數據呢?
public class WelcomeWebClient { private WebClient client = WebClient.create("http://localhost:8080"); private final Mono<ClientResponse> result = client.get() .uri("/hello") .accept(MediaType.TEXT_PLAIN) .exchange(); public String getResult() { return " result = " + result.flatMap(res -> res.bodyToMono(String.class)).block(); } }
咱們經過WebClient來獲取get的結果,經過exchange將其轉換爲ClientResponse。
而後提供了一個getResult方法從result中獲取最終的返回結果。
這裏,咱們先調用FlatMap對ClientResponse進行轉換,而後再調用block方法,產生一個新的subscription。
最後,咱們看一下Spring Boot的啓動類:
@Slf4j @SpringBootApplication public class Application { public static void main(String[] args) { SpringApplication.run(Application.class, args); WelcomeWebClient welcomeWebClient = new WelcomeWebClient(); log.info("react result is {}",welcomeWebClient.getResult()); } }
剛剛的註解方式其實跟咱們經常使用的Spring MVC基本上是同樣的。
接下來,咱們看一下,若是是以編程的方式來編寫上面的邏輯應該怎麼處理。
首先,咱們定義一個處理hello請求的處理器:
@Component public class WelcomeHandler { public Mono<ServerResponse> hello(ServerRequest request) { return ServerResponse.ok().contentType(MediaType.TEXT_PLAIN) .body(BodyInserters.fromValue("www.flydean.com!")); } }
和普通的處理同樣,咱們須要返回一個Mono對象。
注意,這裏是ServerRequest,由於WebFlux中沒有Servlet。
有了處理器,咱們須要寫一個Router來配置路由:
@Configuration public class WelcomeRouter { @Bean public RouterFunction<ServerResponse> route(WelcomeHandler welcomeHandler) { return RouterFunctions .route(RequestPredicates.GET("/hello"). and(RequestPredicates.accept(MediaType.TEXT_PLAIN)), welcomeHandler::hello); } }
上面的代碼將/hello和welcomeHandler::hello進行了綁定。
WelcomeWebClient和Application是和第一種方式是同樣的。
public class WelcomeWebClient { private WebClient client = WebClient.create("http://localhost:8080"); private Mono<ClientResponse> result = client.get() .uri("/hello") .accept(MediaType.TEXT_PLAIN) .exchange(); public String getResult() { return " result = " + result.flatMap(res -> res.bodyToMono(String.class)).block(); } }
public class Application { public static void main(String[] args) { SpringApplication.run(Application.class, args); WelcomeWebClient welcomeWebClient = new WelcomeWebClient(); log.info("react result is {}",welcomeWebClient.getResult()); } }
怎麼對webFlux代碼進行測試呢?
本質上是和WelcomeWebClient的實現是同樣的,咱們去請求對應的對象,而後檢測其返回值,最後判斷返回值是否咱們所期待的內容。
以下所示:
@ExtendWith(SpringExtension.class) @SpringBootTest(webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT) public class WelcomeRouterTest { @Autowired private WebTestClient webTestClient; @Test public void testHello() { webTestClient .get().uri("/hello") .accept(MediaType.TEXT_PLAIN) .exchange() .expectStatus().isOk() .expectBody(String.class).isEqualTo("www.flydean.com!"); } }
webFlux使用了Reactor做爲底層的實現,和一般咱們習慣的web請求方式是有很大不一樣的,可是經過咱們的Spring框架,能夠儘可能保證原有的代碼編寫風格和習慣。
只須要在個別部分作微調。但願你們可以經過這個簡單的例子,熟悉Reactive的基本編碼實現。
本文的例子能夠參考:springboot-reactive-web
本文做者:flydean程序那些事本文連接:http://www.flydean.com/springboot-reactive-web/
本文來源:flydean的博客
歡迎關注個人公衆號:「程序那些事」最通俗的解讀,最深入的乾貨,最簡潔的教程,衆多你不知道的小技巧等你來發現!