Java连接RabbitMQ报Connection Reset异常求助

从你的代码和堆栈信息来看，问题的核心大概率是端口不匹配导致的——你尝试用SSL连接RabbitMQ的默认非SSL端口（5672），而服务器并未在该端口启用SSL监听，直接导致握手失败、连接被重置。

最直接的修复方案：修正连接端口 #

RabbitMQ的默认AMQP SSL端口是5671，而非你代码中设置的5672（这是非SSL的默认通信端口）。只需修改代码中的端口配置：

// 把原来的5672改成5671
factory.setPort(5671);

修改后的完整代码如下：

import java.io.*;
import java.security.*;
import com.rabbitmq.client.*;

public class test {
    public static void main(String[] args) throws Exception {
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("myIP"); // 替换为真实IP
        factory.setPort(5671); // 修正为SSL默认端口
        factory.setUsername("admin");
        factory.setPassword("sesgo");
        factory.setVirtualHost("vSESGO");
        factory.useSslProtocol();
        
        Connection conn = factory.newConnection();
        Channel channel = conn.createChannel();
        
        channel.queueDeclare("rabbitmq-java-test", false, true, true, null);
        channel.basicPublish("", "rabbitmq-java-test", null, "Hello, World".getBytes());
        
        GetResponse chResponse = channel.basicGet("rabbitmq-java-test", false);
        if(chResponse == null) {
            System.out.println("No message retrieved");
        } else {
            byte[] body = chResponse.getBody();
            System.out.println("Recieved: " + new String(body));
        }
        
        channel.close();
        conn.close();
    }
}

后续验证与排查步骤 #

如果修改端口后问题仍存在，可以按以下步骤进一步定位：

1. 确认RabbitMQ服务器已启用SSL监听 #

在服务器上执行命令查看当前监听端口：

rabbitmqctl listeners

配置正确的话，你应该能看到类似这样的条目：

Listeners:
...
Interface: [::], port: 5671, protocol: amqp/ssl, purpose: AMQP 0-9-1 and AMQP 1.0 over SSL/TLS

如果没有amqp/ssl的监听，说明服务器未启用SSL，需要修改RabbitMQ配置文件（以rabbitmq.conf为例）：

listeners.ssl.default = 5671
ssl_options.cacertfile = /path/to/ca_certificate.pem
ssl_options.certfile = /path/to/server_certificate.pem
ssl_options.keyfile = /path/to/server_private_key.pem

替换为实际的证书路径后，重启RabbitMQ服务。

2. 检查SSL协议版本兼容性 #

部分情况下，JVM默认的SSL协议版本可能与RabbitMQ禁用的旧版本（如SSLv3、TLSv1.0）冲突，可以尝试指定兼容的协议版本：

// 替换原来的factory.useSslProtocol()
factory.useSslProtocol("TLSv1.2");

3. 查看RabbitMQ服务器日志 #

服务器日志会提供更详细的错误原因（比如证书不匹配、权限问题）。日志文件通常在/var/log/rabbitmq/目录下，打开rabbit@<hostname>.log，搜索SSL或handshake相关的错误信息。

4. 临时调整证书信任（仅开发环境） #

虽然你当前的代码使用了无证书验证的SSL模式（堆栈提示也提到这一点，仅适合开发），如果服务器证书存在链不完整等问题，也可能导致握手失败。可以显式添加信任所有证书的逻辑（生产环境绝对禁止使用）：

import javax.net.ssl.*;
import java.security.cert.X509Certificate;

// ... 其他代码

// 创建信任所有证书的TrustManager
TrustManager[] trustAllCerts = new TrustManager[]{
    new X509TrustManager() {
        public X509Certificate[] getAcceptedIssuers() {
            return null;
        }
        public void checkClientTrusted(X509Certificate[] certs, String authType) {}
        public void checkServerTrusted(X509Certificate[] certs, String authType) {}
    }
};

// 获取SSL上下文并设置到ConnectionFactory
SSLContext sslContext = SSLContext.getInstance("TLS");
sslContext.init(null, trustAllCerts, new SecureRandom());
factory.useSslProtocol(sslContext);

重要提示 #

堆栈中的警告需要重视：This trust manager trusts every certificate, effectively disabling peer verification. This is convenient for local development but prone to man-in-the-middle attacks.
开发环境可以临时使用无验证模式，但生产环境必须配置完整的证书验证流程，确保连接安全。

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