点击上方蓝色字体，选择“设为星标”
回复”云原生“获取基础架构实践
Webclient 使用场景
前面介绍了 什么是阻塞、非阻塞，以及对应的客户端库，非阻塞在高并发、内存不足的情况下，还是一个不错的选择，当被访问者的服务响应很慢、或者自己在请求对方时，并不是很想知道对方返回的结果，都可以使用 Webclient 来进行非阻塞式请求。下面紧接着讲非阻塞客户端库 Webclient如何实现增删改查。
Webclient 的RestFul 请求
一、RESTful风格与HTTP method
熟悉RESTful风格的朋友，应该了解RESTful风格API使用HTTP method表达对资源的操作。
| 常用HTTP方法 | RESTful风格语义（操作） |
|---|---|
| POST | 新增、提交数据 |
| DELETE | 删除数据 |
| PUT | 更新、修改数据 |
| GET | 查询、获取数据 |
下面我们就来讲下这些资源场景的使用方式。
POST
POST等常见使用如下方法：
block()阻塞获取响应结果的方法
subscribe()非阻塞异步结果订阅方法
retrieve(）获取HTTP响应体，exchange()除了获取HTTP响应体，还可以获取HTTP 状态码、headers、cookies等HTTP报文信息。
使用Mono接收单个对象的响应结果，使用Flux接收集合类对象的响应结果。
占位符语法传参方式
模拟表单提交数据
public?void?testFormSubmit()?{
????MultiValueMap<String,?String>?map?=?new?LinkedMultiValueMap<>();
????map.add("username",?"damoin");
????map.add("UID",?"11024319902323");
????Mono<String>?mono?=?webClientBuilder.build().post()
????????????????????.uri("http://rest-service-service/add")
????????????????????.contentType(MediaType.APPLICATION_FORM_URLENCODED)
????????????????????.body(BodyInserters.fromFormData(map))
????????????????????.retrieve()
????????????????????.bodyToMono(String.class);
????System.out.println(mono.block());
}如上所示，在提交表单的时候，需要说明表单数据类型，以及表单的具体数据，我们知道：常见的表单数据都是以map形式存在，在请求后要想获取响应返回，可以使用retrieve函数，同时可以借助Mono来对返回结果进行类型转换，如果是单个对象使用Mono，如果是集合流，可以使用Flux。同时，如果想要阻塞拿到返回结果的信息，可以通过block函数来处理。
传输对象以JSON数据形式发送
public?void?testPostJson()?{
????SysUser?user?=?new?SysUser();
????user.setRealName("dwdwdww");
????user.setPhone("32323232");
????Mono<String>?mono?=?webClientBuilder.build()
????????????????????.post()
????????????????????.uri("http://rest-service-service/add")
????????????????????.contentType(MediaType.APPLICATION_JSON)
????????????????????.bodyValue(user)
????????????????????.retrieve()
????????????????????.bodyToMono(String.class);
????System.out.println(mono.block());
????}这里将传输的数据以Json格式来进行发送给对方，同样需要注明数据类型MediaType.APPLICATION_JSON，其它的函数都是跟上面一样。
模拟向服务端发送JSON字符串数据
如果有时候对方需要的不是一个JSON对象，可能是需要一个JSON字符串，那怎么办呢？
public?void?testPostJsonStr()?{
????String?jsonStr?=?"{\"realName\":?\"damon\",\"phone\":?\"32323232\"}";
????Mono<String>?mono?=?webClientBuilder.build().post()
????????????????????.uri("http://rest-service-service/add")
????????????????????.contentType(MediaType.APPLICATION_JSON)
????????????????????.body(BodyInserters.fromValue(jsonStr))
????????????????????.retrieve()
????????????????????.bodyToMono(String.class);
????//?输出结果
????System.out.println(mono.block());
}此时，数据类型同样还是 MediaType.APPLICATION_JSON，但传输的是JSON串。
DELETE
使用 DELETE方法去删除资源，删除一个已经存在的资源，使用webClient的delete()方法。该方法会向URL代表的资源发送一个HTTP DELETE方法请求：
public?void?testDelete()??{
??webClientBuilder.build()
??.delete()
??.uri("http://rest-service-service/1");
}PUT
修改一个已经存在的资源，使用webClient的put()方法。该方法会向URL代表的资源发送一个HTTP PUT方法请求：
public?void?testPut()?{
????????SysUser?user?=?new?SysUser();
????????user.setRealName("dwdwdww");
????????user.setPhone("32323232");
????????Mono<String>?mono?=?webClientBuilder.build()
????????????????????????.put()
????????????????????????.uri("http://rest-service-service/1")
????????????????????????.contentType(MediaType.APPLICATION_JSON)
????????????????????????.bodyValue(user).retrieve().bodyToMono(String.class);
????????System.out.println(mono.block());
}这里以传json数据的格式来进行发送修改，修改完成后返回修改结果信息。
GET
新增完数据后，我们来查看数据对象，如果是一个对象数据的话，可以使用 Mono：
@GetMapping(value?=?"/getClientResByWebClient2",?produces?=?MediaType.TEXT_EVENT_STREAM_VALUE)
????public?Mono<String>?getClientResByWebClient2()?throws?Exception?{
?????????????Mono<String>?resp?=?webClientBuilder.build()
?????????????.get()
?????????????.uri("http://diff-ns-service-service/all/getService")
?????????????.retrieve().bodyToMono(String.class);
?????????????//.exchange().flatMap(clientResp?->?clientResp.bodyToMono(String.class));
????????????resp.subscribe(body?->?System.out.println(body));
????????????return?resp;
????}如果是多个对象，那就是集合集，此时需要用Flux来获取：
public?void?testFlux()?{
????Flux<SysUser>?flux?=?webClientBuilder.build()
??????????????.get()
??????????????.uri("http://diff-ns-service-service/all")
??????????????.retrieve()
??????????????.bodyToFlux(SysUser.class);
??????List<SysUser>?li?=?flux.collectList().block();
??????assert?li?!=?null;
??????System.out.println("li集合元素数量："?+?li.size());
}下面给大家介绍一本好书《深入了解分布式事务》，该书在当当网目前销售火热，有原理加实战，感兴趣可以点击下方链接购买。
开源项目
??实践项目代码开源：https://gitee.com/damon_one/microservice-k8s
欢迎大家star、fork，欢迎联系我，一起学习。
号内回复“云原生”，获取云原生基础架构实践电子书
云原生社区合肥站
云原生社区合肥站正式启动啦，欢迎Base合肥、关注云原生、长期从事云原生的同志们踊跃加入，云原生社区合肥站会因为你们的加入而变得更加美好~
详情参见Issue：https://github.com/cloudnativeto/community/issues/107
欢迎关注个站
往期回顾
ArrayList、LinkedList 你真的了解吗？
浅谈 Java 集合 | 底层源码解析
Spring Cloud Kubernetes之实战一配置管理
Spring Cloud Kubernetes之实战二服务注册与发现
Spring Cloud Kubernetes之实战三网关Gateway
点击?"damon8.cn"?获取更好的阅读体验！
??给个「在看」，是对我最大的支持??