spring-boot之webflux简单入门

前言

昨天我们通过一个简单实例，演示了webflux与WebMVC的简单区别，同时也展示了webflux的基本工作流程，今天我来继续学习webflux的相关知识。

今天我们学习的重点是webflux的客户端，我们想通过webflux客户端来了解webflux的相关基础知识，包括接口请求方式、响应类别、传参等

webflux客户端

简单示例

webflux的客户端用起来很方便，也很简单，我们先看这样一段代码：

 WebClient client = WebClient.create("http://localhost:8999");
        Mono<String> stringMono = client.get()
                .uri("/webflux/hi")
                .attribute("name", "syske")
                .accept(MediaType.APPLICATION_JSON)
                .retrieve()
                .bodyToMono(String.class);
        String block = stringMono.block();
        System.out.println("返回结果：" + block);

第一行代码就是实例化一个weClient对象，需要注意的是，这里实例化的时候，也可以不指定服务器地址，如果不指定服务器地址的话，就需要我们在uri方法中指定完整的接口地址：

WebClient client = WebClient.create();
        Mono<String> stringMono = client.get()
                .uri("http://localhost:8999/webflux/hi")
                ···

如果不指定服务器地址，且uri填写相对接口地址，则会报如下错误信息：

示例讲解

下面我们就来详细解释下上面webfluxClient的代码。

请求类型

client.get()表示创建一个get请求对象（本质上是一个RequestHeadersUriSpec对象），他还支持post、put、delete和options，也就是我们restful的所有协议。

对于不同的请求类型，我们配置的请求参数是不一样的，但是uri方法都是通用的。

`get`客户端配置

当然，还有很多配置项是不一样的，在上面的示例中，我们是get请求，我们可以配置如下参数：

请求地址中的参数：也就是url中的参数，可以通过attributes方法设置

Mono<String> stringMono = client.get()
                .uri("/webflux/hi")
                .attribute("name", "syske")
                ···

cookie信息

Mono<String> stringMono = client.get()
                .uri("/webflux/hi")
                .cookie("syske", "yyds")
                ···

响应头的字符编码

Mono<String> stringMono = client.get()
                .uri("/webflux/hi")
                .acceptCharset(Charset.defaultCharset())
                ···

设置响应类型

也就是我们常用的媒体类型，包括application/json、application/pdf、text/html、image/jpeg等待

Mono<String> stringMono = client.get()
                .uri("/webflux/hi")
    .accept(MediaType.APPLICATION_JSON)
    ···

获取响应设置对象

Mono<String> stringMono = client.get()
                .uri("/webflux/hi")
    .retrieve()
    ···

配置响应对象

这里配置的类型要与服务器端对应，否则会在类型转换时报错

Mono<String> stringMono = client.get()
                .uri("/webflux/hi")
    .bodyToMono(String.class);
    ···

执行调用，获取响应数据

经过我的测试，我发现真正调用服务器是在我们执行block方法之后，之前的操作都是未来配置客户端请求数据。

String block = stringMono.block();

post客户端配置

对于post配置，除了我们前面和get一样的配置外（get的都支持），它还支持以下参数：

设置请求头类型

Mono<String> stringMono2 = client.post()                
        .uri("/webflux/hi")                
        .acceptCharset(Charset.defaultCharset())                
        .header("token:1234567")    
        .contentType(MediaType.APPLICATION_JSON)

设置其他请求头信息

Mono<String> stringMono2 = client.post()                
    .uri("/webflux/hi")    
    .headers(httpHeaders -> {                    
        httpHeaders.add(HttpHeaders.ACCEPT_CHARSET, "UTF-8");                
    })

好了，客户端的相关配置就先到这里吧，下面简单测试下。

测试

下面我们分别运行get和post两种客户端，访问我们的两个接口，看下效果。

首选是我们的接口，第一个是get接口，第二个是post接口：

接口路由配置

测试代码如下

 public static void main(String[] args) {        
   WebClient client = WebClient.create("http://localhost:8999");        
   Mono<String> stringMono = client.get()                
       .uri("/webflux/hi")                
       .acceptCharset(Charset.defaultCharset())                
       .header("token:1234567")                
       .cookie("syske", "yyds")                
       .attribute("name", "syske")                
       .accept(MediaType.APPLICATION_JSON)                
       .retrieve()                
       .bodyToMono(String.class);        
       String block = stringMono.block();        
       System.out.println("返回结果：" + block);   

   Mono<String> stringMono2 = client.post()                
       .uri("/webflux/hi2")                
       .acceptCharset(Charset.defaultCharset())                
       .header("token:1234567")                
       .headers(httpHeaders -> {                    
           httpHeaders.add(HttpHeaders.ACCEPT_CHARSET, "UTF-8");                
       })                
       .contentType(MediaType.APPLICATION_JSON)                
       .cookie("syske", "yyds")                
       .attribute("name", "syske")                
       .accept(MediaType.APPLICATION_JSON)                
       .retrieve()                
       .bodyToMono(String.class);        
   String block1 = stringMono2.block();        
   System.out.println("block1" + block1);    
 }