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();

1
package geektime.spring.reactor.webclient;
2

3
import geektime.spring.reactor.webclient.model.Coffee;
4
import lombok.extern.slf4j.Slf4j;
5
import org.joda.money.CurrencyUnit;
6
import org.joda.money.Money;
7
import org.springframework.beans.factory.annotation.Autowired;
8
import org.springframework.boot.ApplicationArguments;
9
import org.springframework.boot.ApplicationRunner;
10
import org.springframework.boot.Banner;
11
import org.springframework.boot.WebApplicationType;
12
import org.springframework.boot.autoconfigure.SpringBootApplication;
13
import org.springframework.boot.builder.SpringApplicationBuilder;
14
import org.springframework.context.annotation.Bean;
15
import org.springframework.http.MediaType;
16
import org.springframework.web.reactive.function.client.WebClient;
17
import reactor.core.publisher.Mono;
18
import reactor.core.scheduler.Schedulers;
19

20
import java.util.concurrent.CountDownLatch;
21

22
@SpringBootApplication
23
@Slf4j
24
public class WebclientDemoApplication implements ApplicationRunner {
25
  @Autowired
26
  private WebClient webClient;
27

28
  public static void main(String[] args) {
29
    new SpringApplicationBuilder(WebclientDemoApplication.class)
30
        .web(WebApplicationType.NONE)
31
        .bannerMode(Banner.Mode.OFF)
32
        .run(args);
33
  }
34

35
  @Bean
36
  public WebClient webClient(WebClient.Builder builder) {
37
    return builder.baseUrl("http://localhost:8080").build();
38
  }
39

40
  @Override
41
  public void run(ApplicationArguments args) throws Exception {
42
    CountDownLatch cdl = new CountDownLatch(2);
43

44
    webClient.get()
45
        .uri("/coffee/{id}", 1)
46
        .accept(MediaType.APPLICATION_JSON_UTF8)
47
        .retrieve()
48
        .bodyToMono(Coffee.class)
49
        .doOnError(t -> log.error("Error: ", t))
50
        .doFinally(s -> cdl.countDown())
51
        .subscribeOn(Schedulers.single())
52
        .subscribe(c -> log.info("Coffee 1: {}", c));
53

54
    Mono<Coffee> americano = Mono.just(
55
        Coffee.builder()
56
            .name("americano")
57
            .price(Money.of(CurrencyUnit.of("CNY"), 25.00))
58
            .build()
59
    );
60
    webClient.post()
61
        .uri("/coffee/")
62
        .body(americano, Coffee.class)
63
        .retrieve()
64
        .bodyToMono(Coffee.class)
65
        .doFinally(s -> cdl.countDown())
66
        .subscribeOn(Schedulers.single())
67
        .subscribe(c -> log.info("Coffee Created: {}", c));
68

69
    cdl.await();
70

71
    webClient.get()
72
        .uri("/coffee/")
73
        .retrieve()
74
        .bodyToFlux(Coffee.class)
75
        .toStream()
76
        .forEach(c -> log.info("Coffee in List: {}", c));
77
  }
78
}