首页  思维导图  详情

WebClient

2019-07-18 17:03:21   6  举报





AI智能生成

Spring5 WebClient总结

Spring5

WebClient总结

作者其他创作

大纲/内容

创建&配置

创建

create()

WebClient webClient = WebClient.create()

WebClient webClient =
WebClient.create("https://localhost:8081/v1/accounts");

builder()

WebClient webClient = WebClient.builder().build();

配置

WebClient webClient =
WebClient.builder().baseUrl("https://localhost:8081/v1/accounts")
.defaultHeader(HttpHeaders.CONTENT_TYPE, "application/json")
.defaultHeader(HttpHeaders.USER_AGENT, "Reactive WebClient")
.build();

请求体

body()

Mono<Account> accountMono = ...;
Mono<Void> result = webClient.post()
.uri("http://localhost:8081/v1/account/{id}", id)
.contentType(MediaType.APPLICATION_JSON)
.body(accountMono, Account.class)
.retrieve()
.bodyToMono(Void.class);

syncBody()

Mono<Void> result = webClient.post()
.uri("http://localhost:8081/v1/account/{id}", id)
.contentType(MediaType.APPLICATION_JSON)
.syncBody(account)
.retrieve()
.bodyToMono(Void.class);

Form&Multipart

Form

MultiValueMap<String, String> map = new LinkedMultiValueMap<>();
map.add("username", "zhangsan");
map.add("password", "1234.abcd");

Mono<String> mono = webClient.post()
.uri("http://localhost:8081/login")
.synBody(map)
.retrieve()
.bodyToMono(String.class);

MultipartBodyBuilder

MultipartBodyBuilder builder = new MultipartBodyBuilder();
builder.part("fieldPart", "fieldValue");
builder.part("filePart", new FileSystemResource("logo.png"));
builder.part("jsonPart", new Account("zhangsan"));

MultiValueMap<String, HttpEntity<?>> parts = builder.build();

错误处理

retrieve()

Flux<Account> flux = webClient.get()
.uri("http://localhost:8081/v1/account?sort={sort}&direction={direction}", "updated", "desc")
.retrieve()
.onStatus(HttpStatus::is4xxClientError, clientResponse -> Mono.error(new MyCustomClientException()))
.onStatus(HttpStatus::is5xxServerError, clientResponse -> Mono.error(new MyCustomClientException()))
.bodyToFlux(Account.class);

exchange()

自己处理

检查状态码

构造URL

动态参数

webClient.get().uri("http://localhost:8081/account/{p1}/{p2}", "var1", "var2");

Map

Map<String, Object> uriVariables = new HashMap<>();
uriVariables.put("p1", "var1");
uriVariables.put("p2", 1);
webClient.get().uri("http://localhost:8081/account/{p1}/{p2}", uriVariables);

uriBuilder

webClient.get()
.uri(uriBuilder -> uriBuilder.path("/user/orders")
.queryParam("sort", "updated").queryParam("direction", "desc").build())

响应体

retrieve()

JSON序列化

Mono<Account> result = webClient.get()
.uri("http://localhost:8081/v1/account/{id}", id)
.accept(MediaType.APPLICATION_JSON)
.retrieve()
.bodyToMono(Account.class);

流

Flux<Account> result = webClient.get()
.uri("http://localhost:8081/v1/accounts")
.accept(MediaType.TEXT_EVENT_STREAM)
.retrieve()
.bodyToFlux(Account.class);

exchange()

Mono<Account> result = webClient.get()
.uri("http://localhost:8081/v1/account/{id}", id)
.accept(MediaType.APPLICATION_JSON)
.exchange()
.flatMap(response -> response.bodyToMono(Account.class));

过滤器

private ExchangeFilterFunction logRequest() {
return (clientRequest, next) -> {
logger.info("Request:{}{}", clientRequest.method(), clientRequest.url());
clientRequest.headers().forEach((name, values) -> {
values.forEach(value -> {
logger.info("{}={}", name, value);
});
});
return next.exchange(clientRequest);
};
}

WebClient webClient = WebClient.builder()
.filter(logRequest())
.build();