SpringBoot中的響應式web應用

簡介

在Spring 5中,Spring MVC引入了webFlux的概念,webFlux的底層是基於reactor-netty來的,而reactor-netty又使用了Reactor庫。java

本文將會介紹在Spring Boot中reactive在WebFlux中的使用。react

Reactive in Spring

前面咱們講到了,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的例子,但願你們可以喜歡。數據庫

註解方式使用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());
    }
}

編程方式使用webFlux

剛剛的註解方式其實跟咱們經常使用的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());
    }
}

Spring WebFlux的測試

怎麼對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的博客

歡迎關注個人公衆號:「程序那些事」最通俗的解讀,最深入的乾貨,最簡潔的教程,衆多你不知道的小技巧等你來發現!

相關文章
相關標籤/搜索