Jersey client 2.25.1使用HTTPS(证书)进行多线程访问

import javax.net.ssl.*;
import java.io.FileInputStream;
import java.security.KeyStore;

public class SSLUtils {
    public static SSLContext createSSLContext(String trustStorePath, String trustStorePassword) throws Exception {
        // 加载信任库
        KeyStore trustStore = KeyStore.getInstance(KeyStore.getDefaultType());
        try (FileInputStream fis = new FileInputStream(trustStorePath)) {
            trustStore.load(fis, trustStorePassword.toCharArray());
        }

        // 创建TrustManagerFactory
        TrustManagerFactory tmf = TrustManagerFactory.getInstance(TrustManagerFactory.getDefaultAlgorithm());
        tmf.init(trustStore);

        // 创建SSLContext
        SSLContext sslContext = SSLContext.getInstance("TLS");
        sslContext.init(null, tmf.getTrustManagers(), null);

        return sslContext;
    }
}

import org.glassfish.jersey.client.ClientConfig;
import org.glassfish.jersey.client.JerseyClientBuilder;
import javax.net.ssl.SSLContext;

public class SecureJerseyClientFactory {
    private final SSLContext sslContext;

    public SecureJerseyClientFactory(SSLContext sslContext) {
        this.sslContext = sslContext;
    }

    public javax.ws.rs.client.Client createClient() {
        ClientConfig config = new ClientConfig();
        config.property(ClientProperties.SSL_CONTEXT, sslContext);
        return JerseyClientBuilder.createClient(config);
    }
}

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;

public class MultiThreadedHttpsClient {
    public static void main(String[] args) throws Exception {
        // 创建SSL上下文
        SSLContext sslContext = SSLUtils.createSSLContext("path/to/truststore.jks", "truststorePassword");

        // 创建客户端工厂
        SecureJerseyClientFactory clientFactory = new SecureJerseyClientFactory(sslContext);

        // 创建线程池
        ExecutorService executorService = Executors.newFixedThreadPool(10);

        for (int i = 0; i < 10; i++) {
            executorService.submit(() -> {
                try (javax.ws.rs.client.Client client = clientFactory.createClient()) {
                    // 使用客户端进行HTTPS请求
                    // 例如：client.target("https://example.com/api").request().get();
                }
            });
        }

        // 关闭线程池
        executorService.shutdown();
        executorService.awaitTermination(1, TimeUnit.MINUTES);
    }
}