参考链接

[URI Links——Spring/WebServlet](https://docs.spring.io/spring/docs/5.2.6.RELEASE/spring-framework-reference/web.html#mvc-uri-building)

WebClient——Spring/Web on Reactive Stack

玩转Spring全家桶——极客时间@丁雪丰

Spring之WebClient

概述

WebClient包含在SpringWebflux中。SpringMVC和SpringWebFlux都是MVC框架，SpringWebFlux从官方文档的说明上是一种非阻塞式栈web框架。

1
//实例创建
2
WebClient.create();
3
WebClient.builder();
4
//发起请求
5
get();
6
post();
7
put();
8
delete();
9
patch();
10
//基本用法
11
//获得结果
12
retrieve();
13
exchange();
14
//处理Http Status
15
onStatus();
16
//应答正文
17
bodyToMono();
18
bodyToFlux();

Getting Started

```java package geektime.spring.reactor.webclient;

import geektime.spring.reactor.webclient.model.Coffee; import lombok.extern.slf4j.Slf4j; import org.joda.money.CurrencyUnit; import org.joda.money.Money; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.ApplicationArguments; import org.springframework.boot.ApplicationRunner; import org.springframework.boot.Banner; import org.springframework.boot.WebApplicationType; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.boot.builder.SpringApplicationBuilder; import org.springframework.context.annotation.Bean; import org.springframework.http.MediaType; import org.springframework.web.reactive.function.client.WebClient; import reactor.core.publisher.Mono; import reactor.core.scheduler.Schedulers;

import java.util.concurrent.CountDownLatch;

@SpringBootApplication @Slf4j public class WebclientDemoApplication implements ApplicationRunner { @Autowired private WebClient webClient;

1
public static void main(String[] args) {
2
  new SpringApplicationBuilder(WebclientDemoApplication.class)
3
      .web(WebApplicationType.NONE)
4
      .bannerMode(Banner.Mode.OFF)
5
      .run(args);
6
}
7

8
@Bean
9
public WebClient webClient(WebClient.Builder builder) {
10
  return builder.baseUrl("http://localhost:8080").build();
11
}
12

13
@Override
14
public void run(ApplicationArguments args) throws Exception {
15
  CountDownLatch cdl = new CountDownLatch(2);
16

17
  webClient.get()
18
      .uri("/coffee/{id}", 1)
19
      .accept(MediaType.APPLICATION_JSON_UTF8)
20
      .retrieve()
21
      .bodyToMono(Coffee.class)
22
      .doOnError(t -> log.error("Error: ", t))
23
      .doFinally(s -> cdl.countDown())
24
      .subscribeOn(Schedulers.single())
25
      .subscribe(c -> log.info("Coffee 1: {}", c));
26

27
  Mono<Coffee> americano = Mono.just(
28
      Coffee.builder()
29
          .name("americano")
30
          .price(Money.of(CurrencyUnit.of("CNY"), 25.00))
31
          .build()
32
  );
33
  webClient.post()
34
      .uri("/coffee/")
35
      .body(americano, Coffee.class)
36
      .retrieve()
37
      .bodyToMono(Coffee.class)
38
      .doFinally(s -> cdl.countDown())
39
      .subscribeOn(Schedulers.single())
40
      .subscribe(c -> log.info("Coffee Created: {}", c));
41

42
  cdl.await();
43

44
  webClient.get()
45
      .uri("/coffee/")
46
      .retrieve()
47
      .bodyToFlux(Coffee.class)
48
      .toStream()
49
      .forEach(c -> log.info("Coffee in List: {}", c));
50
}

}

1
<h3 id="KV15H"></h3>