Vert.x HTTP客户端在高并发大负载下内存飙升及优化策略

httpClient
    .request(requestOpts)
    .onSuccess(
        request -> {
            request.send(payload);
        }
    );

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;

public class OptimizedHttpClientExample {

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

        // 配置 HttpClientOptions
        HttpClientOptions options = new HttpClientOptions()
            .setPipelining(true) // 启用HTTP管线化，进一步优化性能
            .setKeepAlive(true) // 关键：启用连接复用
            .setMaxPoolSize(200) // 根据实际需求调整最大连接池大小
            .setKeepAliveTimeout(60) // 连接空闲60秒后关闭
            .setIdleTimeout(30) // 连接30秒无数据传输后关闭
            .setConnectTimeout(5000) // 连接超时时间
            .setDefaultPort(8080) // 默认端口
            .setDefaultHost("localhost"); // 默认主机

        HttpClient httpClient = vertx.createHttpClient(options);

        // 模拟高并发请求
        String largePayload = generateLargePayload(100 * 1024); // 100KB payload
        Buffer payloadBuffer = Buffer.buffer(Base64.getEncoder().encodeToString(largePayload.getBytes()));

        for (int i = 0; i < 30000; i++) { // 模拟30K RPM
            RequestOptions requestOpts = new RequestOptions()
                .setMethod(HttpMethod.POST)
                .setURI("/your/api/path");

            httpClient.request(requestOpts)
                .onSuccess(request -> {
                    request.send(payloadBuffer.copy()) // 注意：每次发送都需要一个新的Buffer副本
                           .onSuccess(response -> {
                               // 处理响应
                               // System.out.println("Response status: " + response.statusCode());
                               response.bodyHandler(body -> {
                                   // System.out.println("Response body: " + body.toString());
                               });
                           })
                           .onFailure(err -> {
                               System.err.println("Request failed: " + err.getMessage());
                           });
                })
                .onFailure(err -> {
                    System.err.println("Failed to create request: " + err.getMessage());
                });
        }

        // vertx.close(); // 实际应用中在适当时候关闭Vert.x实例
    }

    private static String generateLargePayload(int size) {
        StringBuilder sb = new StringBuilder(size);
        for (int i = 0; i < size; i++) {
            sb.append('a');
        }
        return sb.toString();
    }
}