spring?webClient配置及使用簡單代碼示例

更新時間：2024年03月30日 08:31:51 作者：SmokyOranges

WebClient是Spring框架5.0引入的基于響應式編程模型的HTTP客戶端,它提供一種簡便的方式來處理HTTP請求和響應,支持異步和非阻塞式的請求和響應處理,下面這篇文章主要給大家介紹了關于spring?webClient配置及使用的相關資料,需要的朋友可以參考下

1.配置

import com.zty.common.util.WebUtils;
import io.netty.channel.ChannelOption;
import io.netty.handler.timeout.ReadTimeoutHandler;
import io.netty.handler.timeout.WriteTimeoutHandler;
import lombok.extern.slf4j.Slf4j;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.http.HttpHeaders;
import org.springframework.http.MediaType;
import org.springframework.http.client.reactive.ReactorClientHttpConnector;
import org.springframework.web.reactive.function.client.WebClient;
import reactor.netty.http.client.HttpClient;
import reactor.netty.resources.ConnectionProvider;

import java.time.Duration;

/**
 * WebClient配置
 * @author zty
 */
@Slf4j
@Configuration
public class WebClientConfig {

    @Bean
    public WebClient webClient(){
        //配置固定大小連接池
        ConnectionProvider provider = ConnectionProvider
                .builder("custom")
                // 等待超時時間
                .pendingAcquireTimeout(Duration.ofSeconds(10))
                // 最大連接數(shù)
                .maxConnections(200)
                // 最大空閑時間
                .maxIdleTime(Duration.ofSeconds(5))
                // 最大等待連接數(shù)量
                .pendingAcquireMaxCount(-1)
                .build();

        /**
         * doOnBind	當服務器channel即將被綁定的時候調用。
         * doOnBound	當服務器channel已經(jīng)被綁定的時候調用。
         * doOnChannelInit	當channel初始化的時候被調用。
         * doOnConnection	當一個遠程客戶端連接上的時候被調用。
         * doOnUnbound	當服務器channel解綁的時候被調用。
         */
        HttpClient httpClient = HttpClient.create(provider)
                .option(ChannelOption.CONNECT_TIMEOUT_MILLIS, 6000)
                .option(ChannelOption.SO_KEEPALIVE, true)
                .responseTimeout(Duration.ofSeconds(6))
                .keepAlive(true)
                //連接成功
                .doOnConnected(connection -> connection.addHandlerLast(new ReadTimeoutHandler(6))
                        .addHandlerLast(new WriteTimeoutHandler(6)))
                //每次請求后執(zhí)行flush，防止服務器主動斷開連接
                .doAfterRequest((httpClientRequest, connection) -> {
                    connection.channel().alloc().buffer().release();
                    connection.channel().flush();
                    connection.channel().pipeline().flush();
                });

        return WebClient.builder()
                .baseUrl("http://127.0.0.1:8080")
                .defaultHeader(HttpHeaders.CONTENT_TYPE, MediaType.APPLICATION_JSON_VALUE)
                .defaultHeader(HttpHeaders.CONNECTION, "keep-alive")
                .clientConnector(new ReactorClientHttpConnector(httpClient))
                .build();
    }
}

2.使用

import com.alibaba.fastjson2.JSON;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Component;
import org.springframework.web.reactive.function.client.WebClient;
import reactor.core.publisher.Mono;

import java.util.HashMap;

/**
 * http消息發(fā)送工具
 * @author zty
 */
@Slf4j
@Component
public class WebUtils {

    @Autowired
    WebClient webClient;

    @Async
    public void post(HashMap<String, Object> message){
        // 發(fā)送請求
        webClient.post()
                // 請求路徑
                .uri("/test")
                // 攜帶參數(shù)
                .bodyValue(JSON.toJSONString(message))
                // 獲取響應體
                .retrieve()
                // 響應數(shù)據(jù)類型轉換
                .bodyToMono(String.class)
                .doOnError(throwable -> log.info(throwable.getMessage()))
                .onErrorResume(e -> Mono.just("Error " + e.getMessage()))
                // 異步
                .subscribe();
    }
}

附：一個帶有多個查詢參數(shù)的WebClient使用示例

import org.springframework.web.reactive.function.client.WebClient;

public class ExampleWebClient {

    public static void main(String[] args) {
        WebClient client = WebClient.create("https://api.example.com");

        client.get()
              .uri(uriBuilder -> uriBuilder.path("/search")
                                           .queryParam("q", "WebClient")
                                           .queryParam("page", 1)
                                           .queryParam("size", 20)
                                           .build())
              .retrieve()
              .bodyToMono(String.class)
              .subscribe(response -> System.out.println(response));
    }
}

在這個示例中，我們使用了uri()方法來構建URI。使用了一個Lambda表達式，在其中的uriBuilder對象（UriBuilder類型）中指定了路徑和查詢參數(shù)。在這個例子中，我們將/search作為路徑，以及三個查詢參數(shù)q、page、size來進行搜索，它們的值依次為WebClient（表示搜索關鍵字為WebClient）、1、20。