Spring Boot无法连接AmazonMQ(RabbitMQ)问题求助

本地可正常连接RabbitMQ，但Spring Boot连接AmazonMQ时抛出EOFException，配置如下：

spring.rabbitmq.ssl.enabled=true
spring.rabbitmq.host=<host>
spring.rabbitmq.port=<port>
spring.rabbitmq.username=<username>
spring.rabbitmq.password=<password>
spring.rabbitmq.virtual-host=vhost

核心错误栈片段：

Caused by: java.io.EOFException: null
    at java.io.DataInputStream.readFully(DataInputStream.java:197) ~[na:1.8.0_342]
    at java.io.DataInputStream.readFully(DataInputStream.java:169) ~[na:1.8.0_342]
    at com.rabbitmq.client.impl.Frame.readFrom(Frame.java:113) ~[amqp-client-5.14.2.jar:5.14.2]

解决方案 #

1. 确认端口配置正确性 #

AmazonMQ的RabbitMQ实例SSL端口固定为5671（AMQP over TLS），非SSL端口为5672。若开启spring.rabbitmq.ssl.enabled=true，必须确保端口设置为5671，避免混用非SSL端口导致连接中断。

2. 补充SSL信任配置 #

AmazonMQ使用AWS官方信任证书，需根据环境配置证书验证：

• 生产环境：配置JVM加载AWS根证书，或通过属性指定信任库（若使用自定义证书）：

spring.rabbitmq.ssl.trust-store=classpath:aws-root-ca.p12
spring.rabbitmq.ssl.trust-store-password=<证书库密码>
spring.rabbitmq.ssl.trust-store-type=PKCS12

• 测试环境（临时验证）：临时禁用证书验证（不推荐生产使用），需自定义ConnectionFactory：

import org.springframework.amqp.rabbit.connection.CachingConnectionFactory;
import org.springframework.amqp.rabbit.connection.ConnectionFactory;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

import javax.net.ssl.SSLContext;
import javax.net.ssl.TrustManager;
import javax.net.ssl.X509TrustManager;
import java.security.cert.X509Certificate;

@Configuration
public class RabbitMqSslConfig {

    @Bean
    public ConnectionFactory connectionFactory() throws Exception {
        CachingConnectionFactory factory = new CachingConnectionFactory();
        factory.setHost("<host>");
        factory.setPort(5671);
        factory.setUsername("<username>");
        factory.setPassword("<password>");
        factory.setVirtualHost("vhost");
        factory.setSslEnabled(true);
        
        // 禁用证书验证（仅测试用）
        SSLContext sslContext = SSLContext.getInstance("TLS");
        sslContext.init(null, new TrustManager[]{new X509TrustManager() {
            public void checkClientTrusted(X509Certificate[] certs, String authType) {}
            public void checkServerTrusted(X509Certificate[] certs, String authType) {}
            public X509Certificate[] getAcceptedIssuers() { return new X509Certificate[0]; }
        }}, new java.security.SecureRandom());
        factory.setSslContext(sslContext);
        
        return factory;
    }
}

3. 核对虚拟主机配置 #

AmazonMQ的虚拟主机需提前在控制台创建，确保配置中的spring.rabbitmq.virtual-host与控制台创建的名称完全一致（RabbitMQ虚拟主机区分大小写）。

4. 检查网络与安全组 #

• 确认Spring Boot应用所在网络可访问AmazonMQ实例的5671端口，检查AWS安全组是否允许应用IP/网段入站访问该端口。
• 若应用部署在AWS内部，需验证VPC对等连接、网络ACL配置是否正确。

5. 验证客户端版本兼容性 #

Spring Rabbit 2.4.5对应AMQP客户端5.14.2，与AmazonMQ默认的RabbitMQ 3.8+版本兼容，但如果版本差距过大可能引发握手问题。可尝试升级Spring Rabbit到对应分支的最新稳定版本（如2.4.x系列）。

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