WebFlux 请求响应接口

原创

安宁

修改于 2020-07-06 10:40:47

3K0

文章被收录于专栏：Spring Cloud 微服务Spring Cloud 微服务

简单介绍 org.springframework:spring-webflux 中的请求响应接口。

1. 请求响应模型

Figure 1. 请求响应模型

2. 客户端视角

2.1. 客户端

客户端用于发送请求获得响应。相关接口包括 ExchangeFunction 和 WebClient，WebClient 封装至 ExchangeFunction，可以通过链式写法构造并发送请求。

2.1.1. ExchangeFunction 交换函数

Figure 2. 交换函数类图

用法示例

//构造交换函数
ExchangeFunction exchangeFunction = ExchangeFunctions.create(new ReactorClientHttpConnector());
//构造请求
ClientRequest<Void> request = ClientRequest.method(HttpMethod.GET, "https://example.com/resource").build();

//发送请求并获得响应
Mono<String> result = exchangeFunction
   .exchange(request)
   .then(response -> response.bodyToMono(String.class));

2.1.2. WebClient Web 客户端

Figure 3. web客户端类图

用法示例

Mono<String> result = WebClient.builder()
        .baseUrl("https://example.com/resource")
        .build()
        .get()
        .retrieve()
        .bodyToMono(String.class);

ExchangeFunction 的分步操作，通过 WebClient 的链式操作实现。

2.2. 客户端过滤器 ExchangeFilterFunction

Figure 4. 客户端拦截器原理

在实际发出请求之后处理请求
在实际获得响应之前处理响应

用法示例（基于 ExchangeFunction ）

ExchangeFunction exchangeFunction = ExchangeFunctions.create(new ReactorClientHttpConnector());
ClientRequest<Void> request = ClientRequest.method(HttpMethod.GET, "https://example.com/resource").build();

Mono<String> result = exchangeFunction
   //添加一个过滤器，什么也没做
   .filter((clientRequest, exchangeFunction) -> exchangeFunction.exchange(clientRequest)) 
   .exchange(request)
   .then(response -> response.bodyToMono(String.class));

用法示例（基于 WebClient ）

Mono<String> result = WebClient.builder()
        .baseUrl("https://example.com/resource")
         //添加一个过滤器，什么也没做
        .filter((clientRequest, exchangeFunction) -> exchangeFunction.exchange(clientRequest))
        .build()
        .get()
        .retrieve()
        .bodyToMono(String.class);