点击上方蓝色字体,选择“设为星标”
回复”云原生“获取基础架构实践
前面介绍了 什么是阻塞、非阻塞,以及对应的客户端库,非阻塞在高并发、内存不足的情况下,还是一个不错的选择,当被访问者的服务响应很慢、或者自己在请求对方时,并不是很想知道对方返回的结果,都可以使用 Webclient 来进行非阻塞式请求。下面紧接着讲非阻塞客户端库 Webclient如何实现增删改查。
熟悉RESTful风格的朋友,应该了解RESTful风格API使用HTTP method表达对资源的操作。
常用HTTP方法 | RESTful风格语义(操作) |
---|---|
POST | 新增、提交数据 |
DELETE | 删除数据 |
PUT | 更新、修改数据 |
GET | 查询、获取数据 |
下面我们就来讲下这些资源场景的使用方式。
POST等常见使用如下方法:
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
函数来处理。
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字符串,那怎么办呢?
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方法去删除资源,删除一个已经存在的资源,使用webClient的delete()方法。该方法会向URL代表的资源发送一个HTTP DELETE方法请求:
public void testDelete() {
webClientBuilder.build()
.delete()
.uri("http://rest-service-service/1");
}
修改一个已经存在的资源,使用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数据的格式来进行发送修改,修改完成后返回修改结果信息。
新增完数据后,我们来查看数据对象,如果是一个对象数据的话,可以使用 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());
}