WebClient

WebClient

创建&配置

创建

create()

WebClient webClient = WebClient.create()

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

builder()

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

配置

WebClient webClient = \tWebClient.builder().baseUrl(\"https://localhost:8081/v1/accounts\

请求体

body()

Mono<Account> accountMono = ...;Mono<Void> result = webClient.post()\t.uri(\"http://localhost:8081/v1/account/{id}\

syncBody()

Mono<Void> result = webClient.post()\t.uri(\"http://localhost:8081/v1/account/{id}\

Form&Multipart

Form

MultipartBodyBuilder

MultipartBodyBuilder builder = new MultipartBodyBuilder();builder.part(\"fieldPart\

错误处理

retrieve()

Flux<Account> flux = webClient.get()\t.uri(\"http://localhost:8081/v1/account?sort={sort}&direction={direction}\

exchange()

自己处理

检查状态码

构造URL

动态参数

webClient.get().uri(\"http://localhost:8081/account/{p1}/{p2}\

Map

uriBuilder

webClient.get()\t.uri(uriBuilder -> uriBuilder.path(\"/user/orders\")\t\t\t.queryParam(\"sort\

响应体

JSON序列化

Mono<Account> result = webClient.get()\t.uri(\"http://localhost:8081/v1/account/{id}\

流

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

过滤器