httpclient javax.net.ssl.SSLException: closing inbound before receiving peer-CFANZ编程社区

使用 HttpClient 解决 javax.net.ssl.SSLException: closing inbound before receiving peer

概述

在使用 HttpClient 进行 HTTPS 请求时，有时会遇到 javax.net.ssl.SSLException: closing inbound before receiving peer 异常。这个异常通常是由于连接服务器时出现了一些问题，导致 SSL 握手未完成而引发的。本文将介绍整个处理过程，并提供相应的代码示例。

异常原因分析

当使用 HttpClient 发送 HTTPS 请求时，会进行 SSL 握手过程，以确保与服务器之间的安全连接。SSL 握手过程主要包括以下几个步骤：

客户端发送 ClientHello 消息，包含支持的 SSL/TLS 版本、加密算法列表等信息。
服务器收到 ClientHello 消息后，发送 ServerHello 消息，包含选择的 SSL/TLS 版本、加密算法等信息。
服务器发送证书，包含服务器的公钥及其他相关信息。
客户端验证服务器证书的合法性，并生成一个随机的 PreMasterSecret。
客户端使用服务器的公钥加密 PreMasterSecret，并发送给服务器。
服务器收到密文后使用私钥解密得到 PreMasterSecret。
客户端和服务器使用 PreMasterSecret 生成 MasterSecret，用于后续通信的加密解密。
客户端发送 Finished 消息，表示握手过程结束。
服务器发送 Finished 消息，表示握手过程结束。

以上是一个简化的 SSL 握手过程，实际过程可能会更加复杂。当出现 "javax.net.ssl.SSLException: closing inbound before receiving peer" 异常时，通常是在握手过程的某个阶段出现了问题，导致服务器或客户端关闭了连接，而对方尚未完成握手。

解决方案

下面将逐步介绍解决 "javax.net.ssl.SSLException: closing inbound before receiving peer" 异常的步骤，并给出相应的代码示例。

步骤一：设置 SSLContext

首先，我们需要创建一个 SSLContext 对象，并指定相应的 SSL 协议和信任管理器。代码如下：

SSLContext sslContext = SSLContext.getInstance("TLS");
sslContext.init(null, new TrustManager[]{new X509TrustManager() {
    @Override
    public void checkClientTrusted(X509Certificate[] x509Certificates, String s) throws CertificateException {
        // 客户端证书验证
    }

    @Override
    public void checkServerTrusted(X509Certificate[] x509Certificates, String s) throws CertificateException {
        // 服务器证书验证
    }

    @Override
    public X509Certificate[] getAcceptedIssuers() {
        return new X509Certificate[0];
    }
}}, new SecureRandom());

在上述代码中，我们使用 "TLS" 协议创建了一个 SSLContext 对象，并初始化了一个信任管理器（TrustManager）。TrustManager 是用于验证服务器证书和客户端证书的。在这里，我们使用了一个匿名内部类实现了 X509TrustManager 接口，其中的三个方法分别用于验证客户端证书、验证服务器证书和获取可接受的证书列表。

步骤二：创建 HttpClient

接下来，我们需要创建一个 HttpClient 对象，并设置相应的参数，以便进行 HTTPS 请求。代码如下：

SSLConnectionSocketFactory sslConnectionFactory = new SSLConnectionSocketFactory(sslContext);
Registry<ConnectionSocketFactory> registry = RegistryBuilder.<ConnectionSocketFactory>create()
        .register("https", sslConnectionFactory)
        .build();
PoolingHttpClientConnectionManager connectionManager = new PoolingHttpClientConnectionManager(registry);
HttpClient httpClient = HttpClientBuilder.create()
        .setConnectionManager(connectionManager)
        .build();

在上述代码中，我们创建了一个 SSLConnectionSocketFactory 对象，并将其注册到 HttpClient 的连接工厂注册表（Registry）。然后，我们使用连接工厂注册表创建一个连接管理器（PoolingHttpClientConnectionManager）。最后，我们使用连接管理器创建一个 HttpClient 对象。

步骤三：发送 HTTPS 请求

现在，我们可以使用 HttpClient 发送 HTTPS 请求了。代码如下：

HttpGet httpGet = new HttpGet("
HttpResponse response = httpClient.execute(httpGet);

在上述代码中，我们创建了一个 HttpGet 对象，并指定了请求的 URL。然后，