Spring5怎么配置WebClient

本篇內(nèi)容主要講解“Spring5怎么配置WebClient”，感興趣的朋友不妨來看看。本文介紹的方法操作簡單快捷，實(shí)用性強(qiáng)。下面就讓小編來帶大家學(xué)習(xí)“Spring5怎么配置WebClient”吧!

創(chuàng)新互聯(lián)建站專業(yè)為企業(yè)提供德化網(wǎng)站建設(shè)、德化做網(wǎng)站、德化網(wǎng)站設(shè)計、德化網(wǎng)站制作等企業(yè)網(wǎng)站建設(shè)、網(wǎng)頁設(shè)計與制作、德化企業(yè)網(wǎng)站模板建站服務(wù)，十多年德化做網(wǎng)站經(jīng)驗，不只是建網(wǎng)站，更提供有價值的思路和整體網(wǎng)絡(luò)服務(wù)。

前言

Spring5帶來了新的響應(yīng)式web開發(fā)框架WebFlux，同時，也引入了新的HttpClient框架WebClient。WebClient是Spring5中引入的執(zhí)行 HTTP 請求的非阻塞、反應(yīng)式客戶端。它對同步和異步以及流方案都有很好的支持，WebClient發(fā)布后，RestTemplate將在將來版本中棄用，并且不會向前添加主要新功能。

WebClient與RestTemplate比較

WebClient是一個功能完善的Http請求客戶端，與RestTemplate相比，WebClient支持以下內(nèi)容：

  • 非阻塞 I/O。

  • 反應(yīng)流背壓（消費(fèi)者消費(fèi)負(fù)載過高時主動反饋生產(chǎn)者放慢生產(chǎn)速度的一種機(jī)制）。

  • 具有高并發(fā)性，硬件資源消耗更少。

  • 流暢的API設(shè)計。

  • 同步和異步交互。

  • 流式傳輸支持

HTTP底層庫選擇

Spring5的WebClient客戶端和WebFlux服務(wù)器都依賴于相同的非阻塞編解碼器來編碼和解碼請求和響應(yīng)內(nèi)容。默認(rèn)底層使用Netty，內(nèi)置支持Jetty反應(yīng)性HttpClient實(shí)現(xiàn)。同時，也可以通過編碼的方式實(shí)現(xiàn)ClientHttpConnector接口自定義新的底層庫；如切換Jetty實(shí)現(xiàn)：

WebClient.builder()
    .clientConnector(new JettyClientHttpConnector())
    .build();

WebClient配置

基礎(chǔ)配置

WebClient實(shí)例構(gòu)造器可以設(shè)置一些基礎(chǔ)的全局的web請求配置信息，比如默認(rèn)的cookie、header、baseUrl等


WebClient.builder()
    .defaultCookie("test","t1")
    .defaultUriVariables(ImmutableMap.of("name","kl"))
    .defaultHeader("header","kl")
    .defaultHeaders(httpHeaders -> {
      httpHeaders.add("header1","kl");
      httpHeaders.add("header2","kl");
    })
    .defaultCookies(cookie ->{
      cookie.add("cookie1","kl");
      cookie.add("cookie2","kl");
    })
    .baseUrl("http://www.kailing.pub")
    .build();
 

底層依賴Netty庫配置

通過定制Netty底層庫，可以配置SSl安全連接，以及請求超時，讀寫超時等。這里需要注意一個問題，默認(rèn)的連接池最大連接500。獲取連接超時默認(rèn)是45000ms，你可以配置成動態(tài)的連接池，就可以突破這些默認(rèn)配置，也可以根據(jù)業(yè)務(wù)自己制定。包括Netty的select線程和工作線程也都可以自己設(shè)置。

//配置動態(tài)連接池
//ConnectionProvider provider = ConnectionProvider.elastic("elastic pool");
//配置固定大小連接池，如最大連接數(shù)、連接獲取超時、空閑連接死亡時間等
ConnectionProvider provider = ConnectionProvider.fixed("fixed", 45, 4000, Duration.ofSeconds(6));
HttpClient httpClient = HttpClient.create(provider)
    .secure(sslContextSpec -> {
      SslContextBuilder sslContextBuilder = SslContextBuilder.forClient()
          .trustManager(new File("E://server.truststore"));
      sslContextSpec.sslContext(sslContextBuilder);
    }).tcpConfiguration(tcpClient -> {
      //指定Netty的select 和 work線程數(shù)量
      LoopResources loop = LoopResources.create("kl-event-loop", 1, 4, true);
      return tcpClient.doOnConnected(connection -> {
        //讀寫超時設(shè)置
        connection.addHandlerLast(new ReadTimeoutHandler(10, TimeUnit.SECONDS))
            .addHandlerLast(new WriteTimeoutHandler(10));
      })
          //連接超時設(shè)置
          .option(ChannelOption.CONNECT_TIMEOUT_MILLIS, 10000)
          .option(ChannelOption.TCP_NODELAY, true)
          .runOn(loop);
    });

WebClient.builder()
    .clientConnector(new ReactorClientHttpConnector(httpClient))
    .build();

編解碼配置

針對特定的數(shù)據(jù)交互格式，可以設(shè)置自定義編解碼的模式，如下：

ExchangeStrategies strategies = ExchangeStrategies.builder()
    .codecs(configurer -> {
      configurer.customCodecs().decoder(new Jackson2JsonDecoder());
      configurer.customCodecs().encoder(new Jackson2JsonEncoder());
    })
    .build();
WebClient.builder()
    .exchangeStrategies(strategies)
    .build();

get請求示例

uri構(gòu)造時支持屬性占位符，真實(shí)參數(shù)在入?yún)r排序好就可以。同時可以通過accept設(shè)置媒體類型，以及編碼。最終的結(jié)果值是通過Mono和Flux來接收的，在subscribe方法中訂閱返回值。

WebClient client = WebClient.create("http://www.kailing.pub");
Mono<String> result = client.get()
    .uri("/article/index/arcid/{id}.html", 256)
    .acceptCharset(StandardCharsets.UTF_8)
    .accept(MediaType.TEXT_HTML)
    .retrieve()
    .bodyToMono(String.class);
result.subscribe(System.err::println);

如果需要攜帶復(fù)雜的查詢參數(shù)，可以通過UriComponentsBuilder構(gòu)造出uri請求地址，如：

//定義query參數(shù)
MultiValueMap<String, String> params = new LinkedMultiValueMap<>();
params.add("name", "kl");
params.add("age", "19");
//定義url參數(shù)
Map<String, Object> uriVariables = new HashMap<>();
uriVariables.put("id", 200);
String uri = UriComponentsBuilder.fromUriString("/article/index/arcid/{id}.html")

下載文件時，因為不清楚各種格式文件對應(yīng)的MIME Type，可以設(shè)置accept為MediaType.ALL，然后使用Spring的Resource來接收數(shù)據(jù)即可，如：

WebClient.create("https://kk-open-public.oss-cn-shanghai.aliyuncs.com/xxx.xlsx")
    .get()
    .accept(MediaType.ALL)
    .retrieve()
    .bodyToMono(Resource.class)
    .subscribe(resource -> {
      try {
        File file = new File("E://abcd.xlsx");
        FileCopyUtils.copy(StreamUtils.copyToByteArray(resource.getInputStream()), file);
      }catch (IOException ex){}
    });

post請求示例

post請求示例演示了一個比較復(fù)雜的場景，同時包含表單參數(shù)和文件流數(shù)據(jù)。如果是普通post請求，直接通過bodyValue設(shè)置對象實(shí)例即可。不用FormInserter構(gòu)造。

WebClient client = WebClient.create("http://www.kailing.pub");
FormInserter formInserter = fromMultipartData("name","kl")
    .with("age",19)
    .with("map",ImmutableMap.of("xx","xx"))
    .with("file",new File("E://xxx.doc"));
Mono<String> result = client.post()
    .uri("/article/index/arcid/{id}.html", 256)
    .contentType(MediaType.APPLICATION_JSON)
    .body(formInserter)
    //.bodyValue(ImmutableMap.of("name","kl"))
    .retrieve()
    .bodyToMono(String.class);
result.subscribe(System.err::println);

同步返回結(jié)果

上面演示的都是異步的通過mono的subscribe訂閱響應(yīng)值。當(dāng)然，如果你想同步阻塞獲取結(jié)果，也可以通過.block()阻塞當(dāng)前線程獲取返回值。

WebClient client =  WebClient.create("http://www.kailing.pub");
String result = client .get()
    .uri("/article/index/arcid/{id}.html", 256)
    .retrieve()
    .bodyToMono(String.class)
    .block();
System.err.println(result);

但是，如果需要進(jìn)行多個調(diào)用，則更高效地方式是避免單獨(dú)阻塞每個響應(yīng)，而是等待組合結(jié)果，如：

WebClient client =  WebClient.create("http://www.kailing.pub");
Mono<String> result1Mono = client .get()
    .uri("/article/index/arcid/{id}.html", 255)
    .retrieve()
    .bodyToMono(String.class);
Mono<String> result2Mono = client .get()
    .uri("/article/index/arcid/{id}.html", 254)
    .retrieve()
    .bodyToMono(String.class);
Map<String,String>  map = Mono.zip(result1Mono, result2Mono, (result1, result2) -> {
  Map<String, String> arrayList = new HashMap<>();
  arrayList.put("result1", result1);
  arrayList.put("result2", result2);
  return arrayList;
}).block();
System.err.println(map.toString());

Filter過濾器

可以通過設(shè)置filter攔截器，統(tǒng)一修改攔截請求，比如認(rèn)證的場景，如下示例，filter注冊單個攔截器，filters可以注冊多個攔截器，basicAuthentication是系統(tǒng)內(nèi)置的用于basicAuth的攔截器，limitResponseSize是系統(tǒng)內(nèi)置用于限制響值byte大小的攔截器

WebClient.builder()
    .baseUrl("http://www.kailing.pub")
    .filter((request, next) -> {
      ClientRequest filtered = ClientRequest.from(request)
          .header("foo", "bar")
          .build();
      return next.exchange(filtered);
    })
    .filters(filters ->{
      filters.add(ExchangeFilterFunctions.basicAuthentication("username","password"));
      filters.add(ExchangeFilterFunctions.limitResponseSize(800));
    })
    .build().get()
    .uri("/article/index/arcid/{id}.html", 254)
    .retrieve()
    .bodyToMono(String.class)
    .subscribe(System.err::println);

websocket支持

WebClient不支持websocket請求，請求websocket接口時需要使用WebSocketClient，如：

WebSocketClient client = new ReactorNettyWebSocketClient();
URI url = new URI("ws://localhost:8080/path");
client.execute(url, session ->
    session.receive()
        .doOnNext(System.out::println)
        .then()
);

到此，相信大家對“Spring5怎么配置WebClient”有了更深的了解，不妨來實(shí)際操作一番吧！這里是創(chuàng)新互聯(lián)網(wǎng)站，更多相關(guān)內(nèi)容可以進(jìn)入相關(guān)頻道進(jìn)行查詢，關(guān)注我們，繼續(xù)學(xué)習(xí)！

分享名稱：Spring5怎么配置WebClient
文章地址：http://bm7419.com/article22/gipgcc.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供電子商務(wù)、品牌網(wǎng)站建設(shè)、Google、虛擬主機(jī)、小程序開發(fā)、動態(tài)網(wǎng)站

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會在第一時間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時需注明來源： 創(chuàng)新互聯(lián)

網(wǎng)站建設(shè)網(wǎng)站維護(hù)公司