Vert.x HTTP客户端性能调优：避免高负载下的内存尖峰与崩溃

import io.vertx.core.Vertx;
import io.vertx.core.buffer.Buffer;
import io.vertx.core.http.HttpClient;
import io.vertx.core.http.HttpClientOptions;
import io.vertx.core.http.HttpMethod;
import io.vertx.core.http.RequestOptions;
import java.util.Base64;
import java.util.concurrent.TimeUnit;

public class VertxHttpClientOptimizationExample {

    public static void main(String[] args) {
        Vertx vertx = Vertx.vertx();

        // 1. 定义并配置 HttpClientOptions，启用连接复用并优化连接池参数
        HttpClientOptions options = new HttpClientOptions()
                .setKeepAlive(true) // 核心：启用连接复用，避免为每个请求创建新连接
                .setMaxPoolSize(200) // 设置最大连接池大小，根据实际负载调整
                .setIdleTimeout(60) // 连接在空闲状态下保持打开的最长时间（秒）
                .setIdleTimeoutUnit(TimeUnit.SECONDS) // 指定 idleTimeout 的时间单位
                .setConnectTimeout(5000) // 连接建立超时时间（毫秒）
                .setTcpNoDelay(true); // 启用TCP_NODELAY，减少小包延迟，对性能有益

        // 2. 使用配置创建 HttpClient 实例
        HttpClient httpClient = vertx.createHttpClient(options);

        // 3. 模拟请求发送（原问题中的代码片段逻辑）
        // 假设 payload 已经准备好，例如一个 100KB 的 Base64 编码数据
        // 在实际应用中，此 payload 会动态生成或从其他地方获取
        String largePayloadString = generateBase64Payload(100 * 1024); // 模拟生成一个 100KB 的 Base64 编码字符串
        Buffer payloadBuffer = Buffer.buffer(Base64.getDecoder().decode(largePayloadString));

        RequestOptions requestOpts = new RequestOptions()
                .setHost("localhost") // 目标主机
                .setPort(8080) // 目标端口
                .setURI("/api/data") // 请求URI
                .setMethod(HttpMethod.POST); // 请求方法

        // 发送请求
        // 在高并发场景下，此请求逻辑会被多次调用
        httpClient.request(requestOpts)
                .onSuccess(request -> {
                    System.out.println("HTTP Request created successfully. Sending payload...");
                    request.send(payloadBuffer) // 发送请求体
                            .onSuccess(response -> {
                                System.out.println("Response status: " + response.statusCode());
                                // 重要：确保读取响应体，以便连接能被正确释放回连接池
                                response.bodyHandler(body -> {
                                    System.out.println("Response body received. Connection is now eligible for reuse.");
                                    // 在这里处理响应体数据
                                });
                            })
                            .onFailure(err -> System.err.println("Failed to send request or receive response: " + err.getMessage()));
                })
                .onFailure(err -> System.err.println("Failed to create HTTP request: " + err.getMessage()));

        // 在实际应用中，您需要妥善管理 Vert.x 实例和 HttpClient 的生命周期
        // 例如，在应用关闭时调用 httpClient.close() 和 vertx.close()
        // vertx.setTimer(5000, id -> { // 示例：5秒后关闭
        //     httpClient.close();
        //     vertx.close();
        //     System.out.println("Vert.x instance closed.");
        // });
    }

    // 辅助方法：生成指定大小的 Base64 编码字符串
    private static String generateBase64Payload(int size) {
        byte[] bytes = new byte[size];
        for (int i = 0; i < size; i++) {
            bytes[i] = (byte) ('A' + (i % 26)); // 填充一些可打印字符
        }
        return Base64.getEncoder().encodeToString(bytes);
    }
}