Spring中WebClient的創(chuàng)建和使用詳解

更新時(shí)間：2023年11月18日 09:06:29 作者：morris131

這篇文章主要介紹了Spring中WebClient的創(chuàng)建和使用詳解,在Spring5中,出現(xiàn)了Reactive響應(yīng)式編程思想,并且為網(wǎng)絡(luò)編程提供相關(guān)響應(yīng)式編程的支持,如提供了WebFlux,它是Spring提供的異步非阻塞的響應(yīng)式的網(wǎng)絡(luò)框架,需要的朋友可以參考下

前言

在Spring5中，出現(xiàn)了Reactive響應(yīng)式編程思想，并且為網(wǎng)絡(luò)編程提供相關(guān)響應(yīng)式編程的支持，如提供了WebFlux，它是Spring提供的異步非阻塞的響應(yīng)式的網(wǎng)絡(luò)框架，相比傳統(tǒng)的SpringMVC框架，可以充分利用多CPU并行處理一些功能，雖然不能提高單個(gè)請求的響應(yīng)能力，但是總體可以提高多核的服務(wù)器性能，提高系統(tǒng)吞吐量和伸縮性，特別適合于IO密集型服務(wù)。

WebClient提供的基于響應(yīng)式的非阻塞的Web請求客戶端，相對于傳統(tǒng)的RestTemplate，他不阻塞代碼、異步執(zhí)行。

使用WebClient需要引入下面的依賴：

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-webflux</artifactId>
</dependency>

WebClient的創(chuàng)建

WebClient可以直接通過new來創(chuàng)建，也可以使用構(gòu)造者模式來構(gòu)造。

package com.morris.user.demo;

import com.morris.user.entity.Order;
import org.springframework.http.HttpHeaders;
import org.springframework.http.MediaType;
import org.springframework.web.reactive.function.client.WebClient;

import java.util.Arrays;
import java.util.concurrent.TimeUnit;

/**
 * WebClient的創(chuàng)建
 */
public class WebClientDemo1 {

    public static void main(String[] args) throws InterruptedException {
        WebClient webClient = WebClient.create();
        webClient.get().uri("http://127.0.0.1:8020/order/findOrderByUserId?userId={userId}", 1).retrieve()
                .bodyToMono(Order[].class).map(Arrays::asList).subscribe(System.out::println);

        WebClient webClient2 = WebClient.builder()
                .baseUrl("http://127.0.0.1:8020")
                .defaultHeader(HttpHeaders.CONTENT_TYPE, MediaType.APPLICATION_JSON_VALUE)
                .build();
        webClient2.get().uri("/order/findOrderByUserId?userId={userId}", 1).retrieve()
                .bodyToMono(Order[].class).map(Arrays::asList).subscribe(System.out::println);
        TimeUnit.SECONDS.sleep(5);
    }
}

在應(yīng)用中使用WebClient時(shí)也許你要訪問的URL都來自同一個(gè)應(yīng)用，只是對應(yīng)不同的URI地址，這個(gè)時(shí)候可以把公用的部分抽出來定義為baseUrl，然后在進(jìn)行WebClient請求的時(shí)候只指定相對于baseUrl的URL部分即可。這樣的好處是你的baseUrl需要變更的時(shí)候可以只要修改一處即可。

WebClient發(fā)送Get請求

先創(chuàng)建個(gè)webclient.create()實(shí)例，之后調(diào)用get()、post()等調(diào)用方式，uri()指定路徑，retrieve()用來發(fā)起請求并獲得響應(yīng)，bodyToFlux(Order.class)用來將請求結(jié)果需要處理為Order數(shù)組，并包裝為Reactor的Flux對象。

如果返回結(jié)果是一個(gè)JSON字符串，可以使用bodyToMono()，將接收到的JSON字符串轉(zhuǎn)換為對應(yīng)的對象。

如果返回結(jié)果是一個(gè)JSON數(shù)組，可以使用bodyToFlux()，將接收到的JSON數(shù)組轉(zhuǎn)換為對應(yīng)的對象集合，然后依次處理每一個(gè)元素。

package com.morris.user.demo;

import com.morris.user.entity.Order;
import org.springframework.http.HttpHeaders;
import org.springframework.http.MediaType;
import org.springframework.web.reactive.function.client.WebClient;

import java.util.Arrays;
import java.util.concurrent.TimeUnit;

/**
 * WebClient發(fā)送Get請求
 */
public class WebClientGetDemo {

    public static void main(String[] args) throws InterruptedException {
        WebClient webClient = WebClient.create();
        webClient.get().uri("http://127.0.0.1:8020/order/findOrderByUserId?userId={userId}", 1).retrieve()
                .bodyToFlux(Order.class).subscribe(System.out::println);;

        // 休眠一會(huì)，否則WebClient中的線程池還沒執(zhí)行，看不到效果
        TimeUnit.SECONDS.sleep(5);
    }
}

WebClient發(fā)送Post請求

可以使用BodyInserters類提供的各種工廠方法來構(gòu)造BodyInserter對象并將其傳遞給body方法。BodyInserters類包含從Object，Publisher，Resource，F(xiàn)ormData，MultipartData等創(chuàng)建BodyInserter的方法。

package com.morris.user.demo;

import com.morris.user.entity.Order;
import org.springframework.web.reactive.function.client.WebClient;
import reactor.core.publisher.Mono;

/**
 * WebClient發(fā)送Post請求
 */
public class WebClientPostDemo {

    public static void main(String[] args) {
        WebClient webClient = WebClient.create();
        Order order = new Order();
        order.setId(1L);
        order.setUserId(666L);
        order.setGoodName("Iphone 13");
        order.setPrice(9999);
        Mono<Long> mono = webClient.post().uri("http://127.0.0.1:8020/order/saveOrder")
                .body(BodyInserters.fromValue(order))
                // .body(Mono.just(order), Order.class)
                .retrieve()
                .bodyToMono(Long.class);

        // 阻塞等待獲取結(jié)果
        System.out.println(mono.block());
    }
}

WebClient對失敗的處理

package com.morris.user.demo;

import lombok.extern.slf4j.Slf4j;
import org.springframework.http.HttpStatus;
import org.springframework.web.reactive.function.client.WebClient;
import org.springframework.web.reactive.function.client.WebClientResponseException;
import reactor.core.publisher.Mono;

/**
 * WebClient對失敗的處理
 */
@Slf4j
public class WebClientDealFailDemo {

    public static void main(String[] args) {
        WebClient webClient = WebClient.create();
        WebClient.ResponseSpec responseSpec = webClient.get().uri("http://127.0.0.1:8020/order/error")
                .retrieve();

        Mono<String> mono = responseSpec
                .onStatus(HttpStatus::is4xxClientError, resp -> {
                    log.error("error4xx:{},msg:{}",resp.statusCode().value(),resp.statusCode().getReasonPhrase());
                    return Mono.error(new RuntimeException(resp.statusCode().value() + " : " + resp.statusCode().getReasonPhrase()));
                })
                .bodyToMono(String.class)
                .doOnError(WebClientResponseException.class, err -> {
                    log.info("ERROR status:{},msg:{}",err.getRawStatusCode(),err.getResponseBodyAsString());
                    throw new RuntimeException(err.getMessage());
                })
                .onErrorReturn("fallback");

        // 阻塞等待獲取結(jié)果
        System.out.println(mono.block());
    }
}

可以使用onStatus根據(jù)響應(yīng)的status code進(jìn)行適配，可以使用doOnError對異常進(jìn)行適配，可以使用onErrorReturn返回默認(rèn)值。

exchange()

retrieve()方法是直接獲取響應(yīng)body，但是，如果需要響應(yīng)的頭信息、Cookie等，可以使用exchange方法，該方法可以訪問整個(gè)ClientResponse。由于響應(yīng)的得到是異步的，所以都可以調(diào)用block()方法來阻塞當(dāng)前程序，等待獲得響應(yīng)的結(jié)果。

package com.morris.user.demo;

import com.morris.user.entity.Order;
import org.springframework.web.reactive.function.client.WebClient;

import java.util.concurrent.TimeUnit;

/**
 * WebClient使用Exchange發(fā)送請求
 */
public class WebClientExchangeDemo {

    public static void main(String[] args) throws InterruptedException {
        WebClient webClient = WebClient.create();
        webClient.get().uri("http://127.0.0.1:8020/order/findOrderByUserId?userId={userId}", 1)
                .exchange()
                .subscribe(r -> {
                    System.out.println(r.headers());
                    r.bodyToFlux(Order.class).subscribe(System.out::println);
                });

        // 休眠一會(huì)，否則WebClient中的線程池還沒執(zhí)行，看不到效果
        TimeUnit.SECONDS.sleep(5);
    }
}

filter

WebClient也提供了Filter，對應(yīng)于org.springframework.web.reactive.function.client.ExchangeFilterFunction接口，可以攔截request，也可以攔截response。

package com.morris.user.demo;

import com.morris.user.entity.Order;
import lombok.extern.slf4j.Slf4j;
import org.springframework.web.reactive.function.client.ExchangeFilterFunction;
import org.springframework.web.reactive.function.client.WebClient;
import reactor.core.publisher.Mono;

import java.util.concurrent.TimeUnit;

/**
 * WebClient使用filter攔截器
 */
@Slf4j
public class WebClientFilterDemo {

    private static ExchangeFilterFunction logResponseStatus() {
        return ExchangeFilterFunction.ofResponseProcessor(clientResponse -> {
            log.info("Response Status {}", clientResponse.statusCode());
            return Mono.just(clientResponse);
        });
    }

    public static void main(String[] args) throws InterruptedException {
        WebClient webClient = WebClient.builder().filter(logResponseStatus()).build();
        webClient.get().uri("http://127.0.0.1:8020/order/findOrderByUserId?userId={userId}", 1)
                .exchange()
                .subscribe(r -> {
                    System.out.println(r.headers());
                    r.bodyToFlux(Order.class).subscribe(System.out::println);
                });

        // 休眠一會(huì)，否則WebClient中的線程池還沒執(zhí)行，看不到效果
        TimeUnit.SECONDS.sleep(5);
    }
}

Attributes

可以使用attribute在多個(gè)filter之間傳遞參數(shù)。

package com.morris.user.demo;

import com.morris.user.entity.Order;
import lombok.extern.slf4j.Slf4j;
import org.springframework.web.reactive.function.client.ExchangeFilterFunction;
import org.springframework.web.reactive.function.client.WebClient;
import reactor.core.publisher.Mono;

import java.util.Optional;
import java.util.concurrent.TimeUnit;

/**
 * WebClient使用attribute傳遞參數(shù)
 */
@Slf4j
public class WebClientAttributesDemo {

    private static ExchangeFilterFunction filterRequest() {
        return ExchangeFilterFunction.ofRequestProcessor(clientRequest -> {
            Optional<Object> myAttribute = clientRequest.attribute("myAttribute");
            System.out.println(myAttribute.get());
            return Mono.just(clientRequest);
        });
    }

    public static void main(String[] args) throws InterruptedException {
        WebClient webClient = WebClient.builder().filter(filterRequest()).build();
        webClient.get().uri("http://127.0.0.1:8020/order/findOrderByUserId?userId={userId}", 1)
                .attribute("myAttribute", "myAttribute")
                .exchange()
                .subscribe(r -> {
                    System.out.println(r.headers());
                    r.bodyToFlux(Order.class).subscribe(System.out::println);
                });

        // 休眠一會(huì)，否則WebClient中的線程池還沒執(zhí)行，看不到效果
        TimeUnit.SECONDS.sleep(5);
    }
}

到此這篇關(guān)于Spring中WebClient的創(chuàng)建和使用詳解的文章就介紹到這了,更多相關(guān)WebClient的創(chuàng)建和使用內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: