Spring框架配置RabbitMQ连接时如何自定义设置SSLContext

1. 核心思路 #

Spring AMQP的默认连接工厂是自动装配的，你只需要自定义CachingConnectionFactory Bean，将自己生成的SSLContext注入到RabbitMQ的客户端连接配置中即可，原有@RabbitListener的逻辑完全不需要改动。

2. 完整实现代码 #

首先构造你需要的SSLContext，这里的SSLContext生成逻辑可以根据你自己的证书来源灵活调整，不需要依赖JKS格式：

import com.rabbitmq.client.ConnectionFactory;
import org.springframework.amqp.rabbit.connection.CachingConnectionFactory;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

import javax.net.ssl.SSLContext;

@Configuration
public class RabbitMqSslConfig {

    @Value("${spring.rabbitmq.host}")
    private String rabbitHost;
    @Value("${spring.rabbitmq.port}")
    private int rabbitPort;
    @Value("${spring.rabbitmq.username}")
    private String rabbitUsername;
    @Value("${spring.rabbitmq.password}")
    private String rabbitPassword;
    @Value("${spring.rabbitmq.virtual-host:/}")
    private String rabbitVhost;

    @Bean
    public CachingConnectionFactory rabbitConnectionFactory() throws Exception {
        // 1. 调用你自定义的SSLContext构造逻辑
        SSLContext sslContext = buildCustomSslContext();
        
        // 2. 配置RabbitMQ原生连接工厂
        ConnectionFactory rabbitClientFactory = new ConnectionFactory();
        rabbitClientFactory.setHost(rabbitHost);
        rabbitClientFactory.setPort(rabbitPort);
        rabbitClientFactory.setUsername(rabbitUsername);
        rabbitClientFactory.setPassword(rabbitPassword);
        rabbitClientFactory.setVirtualHost(rabbitVhost);
        // 注入自定义SSLContext
        rabbitClientFactory.useSslProtocol(sslContext);
        
        // 3. 包装为Spring的缓存连接工厂返回
        return new CachingConnectionFactory(rabbitClientFactory);
    }

    // 自定义SSLContext构造逻辑，可按需修改
    private SSLContext buildCustomSslContext() throws Exception {
        // 示例1：测试环境跳过证书校验（生产环境不建议使用）
        // TrustManager[] trustAllCerts = new TrustManager[]{
        //     new X509TrustManager() {
        //         public java.security.cert.X509Certificate[] getAcceptedIssuers() {
        //             return null;
        //         }
        //         public void checkClientTrusted(java.security.cert.X509Certificate[] certs, String authType) {
        //         }
        //         public void checkServerTrusted(java.security.cert.X509Certificate[] certs, String authType) {
        //         }
        //     }
        // };
        // SSLContext sc = SSLContext.getInstance("TLSv1.3");
        // sc.init(null, trustAllCerts, new java.security.SecureRandom());
        // return sc;
        
        // 示例2：生产环境可在这里实现读取PEM格式证书/私钥、对接证书管理服务获取证书等逻辑，不需要转成JKS
        return SSLContext.getDefault();
    }

    // 如果你项目中用到RabbitTemplate可以配置该Bean，不需要则可以省略
    @Bean
    public RabbitTemplate rabbitTemplate(CachingConnectionFactory connectionFactory) {
        return new RabbitTemplate(connectionFactory);
    }
}

3. 配置文件调整 #

application.properties里只需要保留基础连接配置即可，不需要配置任何JKS相关的SSL参数：

spring.rabbitmq.host=你的RabbitMQ服务地址
spring.rabbitmq.port=5671
spring.rabbitmq.username=连接用户名
spring.rabbitmq.password=连接密码
spring.rabbitmq.virtual-host=/

注意事项 #

• 原有@RabbitListener注解的消息监听逻辑完全不需要修改，Spring会自动使用你自定义的连接工厂创建连接
• SSLContext的构造逻辑可以完全自定义，支持PEM、PKCS12等任意格式的证书，也可以对接内部证书管理系统动态获取证书，不受Spring Boot默认JKS配置的限制

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