如何在非响应式Web栈中不依赖Webflux使用WebClient及替代方案？

其实WebClient本身是Spring Framework 5.x及以上版本中spring-web模块的一部分，并非Webflux专属——Webflux只是帮你自动配置了WebClient的默认实例而已。所以即使你的服务没基于响应式Web栈，也能手动配置使用WebClient，步骤如下：

1. 引入正确的依赖 #

如果是Spring Boot项目，不需要引入spring-boot-starter-webflux，只需要保留spring-boot-starter-web（或者单独引入spring-web依赖）。如果需要JSON编解码支持，确保项目里有Jackson相关依赖（Spring Boot默认已经包含）。

Maven依赖示例：

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
</dependency>
<!-- 如果需要更灵活的编解码，可单独引入 -->
<dependency>
    <groupId>org.springframework</groupId>
    <artifactId>spring-web</artifactId>
</dependency>

2. 手动创建WebClient实例 #

你可以直接通过WebClient.create()快速创建实例，或者用WebClient.builder()做更细致的配置（比如基础URL、默认请求头、自定义编解码器等）。示例代码：

import org.springframework.web.reactive.function.client.WebClient;
import reactor.core.publisher.Mono;

public class CustomHttpClient {
    private final WebClient webClient;

    // 构造方法中初始化WebClient
    public CustomHttpClient() {
        this.webClient = WebClient.builder()
                .baseUrl("https://your-api-base-url.com")
                .defaultHeader("Content-Type", "application/json")
                // 可添加自定义编解码器、拦截器等
                .build();
    }

    // 示例：发起GET请求获取数据
    public Mono<String> fetchApiData(String endpoint) {
        return webClient.get()
                .uri(endpoint)
                .retrieve()
                .bodyToMono(String.class);
    }
}

注意事项 #

如果你的服务是同步栈，使用Mono/Flux时要注意线程阻塞问题：

• 若要在同步代码中获取结果，可以调用block()方法，但要避免在主线程或IO线程中调用，防止阻塞整个服务；
• 更推荐用subscribe()异步处理结果，或者结合Spring的@Async注解来异步执行响应式逻辑。

替代的响应式HTTP客户端 #

如果不想用Spring的WebClient，也有很多成熟的响应式HTTP客户端可选：

Reactor Netty HttpClient #

WebClient默认的底层实现就是Reactor Netty，你可以直接使用它的原生HttpClient，无需依赖Spring，轻量且纯响应式：

import reactor.netty.http.client.HttpClient;
import reactor.core.publisher.Mono;

public class ReactorNettyExample {
    public Mono<String> getRemoteData() {
        return HttpClient.create()
                .get()
                .uri("https://api.example.com/data")
                .responseContent()
                .aggregate()
                .asString();
    }
}

Vert.x Web Client #

Vert.x提供的轻量级响应式Web客户端，支持异步和非阻塞，适合非Spring栈的项目：

import io.vertx.core.Vertx;
import io.vertx.ext.web.client.WebClient;
import reactor.core.publisher.Mono;

public class VertxWebClientDemo {
    public Mono<String> fetchRemoteData() {
        Vertx vertx = Vertx.vertx();
        WebClient client = WebClient.create(vertx);
        
        return Mono.create(sink -> {
            client.get(443, "api.example.com", "/data")
                  .ssl(true)
                  .send()
                  .onSuccess(response -> sink.success(response.bodyAsString()))
                  .onFailure(sink::error);
        });
    }
}

OkHttp + Reactor适配器 #

OkHttp是非常流行的同步HTTP客户端，通过Reactor的适配器可以将其包装为响应式客户端，适合已经在使用OkHttp的项目：

import okhttp3.OkHttpClient;
import okhttp3.Request;
import reactor.core.publisher.Mono;
import reactor.adapter.rxjava.RxJava2Adapter;
import io.reactivex.Single;

public class OkHttpReactorClient {
    private final OkHttpClient okHttpClient = new OkHttpClient();

    public Mono<String> getApiResponse() {
        Request request = new Request.Builder()
                .url("https://api.example.com/data")
                .build();
        
        // 将OkHttp的同步调用包装为RxJava Single，再转为Reactor Mono
        Single<String> responseSingle = Single.fromCallable(() -> {
            try (okhttp3.Response response = okHttpClient.newCall(request).execute()) {
                return response.body().string();
            }
        });
        
        return RxJava2Adapter.singleToMono(responseSingle);
    }
}

内容的提问来源于stack exchange，提问作者Rui Chen