Java中如何结合Socks5代理使用SSLSocket？现有代码抛出SSL异常

哎，这个坑我之前也踩过！你遇到的javax.net.ssl.SSLException: Unrecognized SSL message, plaintext connection?异常，核心原因是你跳过了Socks5代理的明文握手流程，直接在底层Socket上启动了SSL握手。

Socks5代理的工作逻辑是这样的：你得先和代理服务器完成一套明文的握手协商（告诉代理你要连接哪个目标地址），等代理帮你把连接打通之后，才能在这个已经建立好的通道上启动SSL加密。如果一开始就发SSL握手包，代理根本看不懂，会把它当成普通的明文请求返回错误，SSLSocket自然就识别不了这种明文响应，抛出异常。

下面是具体的解决步骤和代码示例：

第一步：先完成Socks5代理的明文握手 #

先通过普通Socket和Socks5代理完成握手，确认代理已经帮你连接到目标服务器：

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;

public class Socks5ProxyHandler {
    public static Socket establishProxyConnection(String proxyHost, int proxyPort, String targetHost, int targetPort) throws IOException {
        // 1. 连接到Socks5代理服务器
        Socket proxySocket = new Socket(proxyHost, proxyPort);
        OutputStream out = proxySocket.getOutputStream();
        InputStream in = proxySocket.getInputStream();

        // 2. 发送Socks5握手请求：版本5，1种认证方式（无认证）
        out.write(new byte[]{0x05, 0x01, 0x00});
        out.flush();

        // 3. 接收代理的握手响应，确认无认证
        byte[] handshakeResp = new byte[2];
        in.read(handshakeResp);
        if (handshakeResp[0] != 0x05 || handshakeResp[1] != 0x00) {
            throw new IOException("Socks5 proxy authentication failed");
        }

        // 4. 发送CONNECT请求，告诉代理目标地址和端口
        out.write(new byte[]{
            0x05, // 版本
            0x01, // CONNECT命令
            0x00, // 保留位
            0x03, // 域名类型（0x03表示域名）
            (byte) targetHost.length(), // 域名长度
        });
        out.write(targetHost.getBytes()); // 域名内容
        // 端口转成两个字节的大端序
        out.write((byte) (targetPort >> 8));
        out.write((byte) (targetPort & 0xFF));
        out.flush();

        // 5. 接收代理的CONNECT响应，确认连接成功
        byte[] connectResp = new byte[4];
        in.read(connectResp);
        if (connectResp[0] != 0x05 || connectResp[1] != 0x00) {
            throw new IOException("Socks5 proxy connect failed, error code: " + connectResp[1]);
        }
        // 跳过代理返回的绑定地址和端口（我们不需要）
        if (connectResp[3] == 0x03) {
            int domainLen = in.read();
            in.skip(domainLen);
        } else {
            in.skip(4);
        }
        in.skip(2);

        // 到这里，代理已经帮我们打通到目标服务器的连接了
        return proxySocket;
    }
}

第二步：在已握手的Socket上创建SSLSocket #

等代理连接建立完成后，再用这个Socket创建SSLSocket，启动SSL握手：

import javax.net.ssl.SSLSocket;
import javax.net.ssl.SSLSocketFactory;
import java.io.IOException;
import java.net.Socket;

public class SslOverSocks5Example {
    public static void main(String[] args) throws IOException {
        // 代理服务器信息
        String proxyHost = "your-proxy-host";
        int proxyPort = 1080;
        // 目标服务器信息（比如https://example.com）
        String targetHost = "example.com";
        int targetPort = 443;

        // 第一步：完成Socks5代理握手
        Socket proxySocket = Socks5ProxyHandler.establishProxyConnection(proxyHost, proxyPort, targetHost, targetPort);

        // 第二步：基于已连接的Socket创建SSLSocket
        SSLSocketFactory sslSocketFactory = (SSLSocketFactory) SSLSocketFactory.getDefault();
        // 关键：用已有的Socket创建SSLSocket，最后一个参数false表示不自动关闭底层的proxySocket
        SSLSocket sslSocket = (SSLSocket) sslSocketFactory.createSocket(
                proxySocket,
                targetHost,
                targetPort,
                false
        );

        // 启动SSL握手（可选，因为第一次读写时会自动触发，但手动调用可以提前捕获异常）
        sslSocket.startHandshake();

        // 现在就可以用sslSocket进行加密通信了，比如发送HTTP请求
        // ... 你的业务代码 ...

        // 关闭资源
        sslSocket.close();
        proxySocket.close();
    }
}

额外注意事项 #

• 协议版本兼容：如果目标服务器不支持旧的SSL协议，可以手动指定SSLSocket启用的协议，比如：sslSocket.setEnabledProtocols(new String[]{"TLSv1.2", "TLSv1.3"});
• 输入输出流的正确使用：使用SSLSocket时，要直接用它的getInputStream()和getOutputStream()，不要再用底层proxySocket的流
• 异常处理：实际代码中要添加更完善的异常捕获和资源关闭逻辑（比如用try-with-resources）

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