springvboot怎么用ssl连接rabbitmq

要使用 SSL 连接 RabbitMQ，您需要执行以下步骤：

1. 创建 SSL 证书和密钥

您需要创建一个 SSL 证书和密钥来加密和保护消息传输。您可以使用 OpenSSL 工具创建证书和密钥。以下是一个示例命令：

openssl req -x509 -nodes -newkey rsa:2048 -keyout rabbitmq.key -out rabbitmq.crt -days 365

这个命令将创建一个私钥文件 rabbitmq.key 和一个证书文件 rabbitmq.crt，这些文件将在后面的步骤中使用。

2. 将证书和密钥添加到 RabbitMQ

将证书和密钥添加到 RabbitMQ 中，以便 RabbitMQ 可以使用它们来加密和保护消息传输。您可以使用 RabbitMQ 的 Web 界面或者命令行工具来添加证书和密钥。

在 Web 界面中，转到 Admin -> Certificates，然后单击 Add a Certificate。输入证书和密钥的名称，然后将证书和密钥的内容复制粘贴到相应的文本框中。

在命令行中，您可以使用以下命令向 RabbitMQ 添加证书和密钥：

sudo rabbitmqctl add_vhost <vhost-name>
sudo rabbitmqctl set_permissions -p <vhost-name> ".*" ".*" ".*"
sudo rabbitmqctl set_parameter -p <vhost-name> ssl_certfile /path/to/rabbitmq.crt
sudo rabbitmqctl set_parameter -p <vhost-name> ssl_keyfile /path/to/rabbitmq.key

其中 `<vhost-name>` 是您要使用 SSL 连接的 vhost 名称，`/path/to/rabbitmq.crt` 和 `/path/to/rabbitmq.key` 是您在第一步中创建的证书和密钥的路径。

3. 配置 Spring Boot 应用程序

在 Spring Boot 应用程序中，您需要将 RabbitMQ 连接工厂配置为使用 SSL 连接。以下是一个示例配置：

@Configuration
public class RabbitConfig {

    @Value("${spring.rabbitmq.host}")
    private String rabbitmqHost;

    @Value("${spring.rabbitmq.port}")
    private int rabbitmqPort;

    @Value("${spring.rabbitmq.username}")
    private String rabbitmqUsername;

    @Value("${spring.rabbitmq.password}")
    private String rabbitmqPassword;

    @Value("${spring.rabbitmq.virtual-host}")
    private String rabbitmqVirtualHost;

    @Value("${rabbitmq.ssl.enabled}")
    private boolean sslEnabled;

    @Value("${rabbitmq.ssl.cert-path}")
    private String sslCertPath;

    @Value("${rabbitmq.ssl.key-path}")
    private String sslKeyPath;

    @Bean
    public ConnectionFactory connectionFactory() throws Exception {
        CachingConnectionFactory connectionFactory = new CachingConnectionFactory(rabbitmqHost, rabbitmqPort);
        connectionFactory.setUsername(rabbitmqUsername);
        connectionFactory.setPassword(rabbitmqPassword);
        connectionFactory.setVirtualHost(rabbitmqVirtualHost);

        if (sslEnabled) {
            SSLContext sslContext = SSLContextBuilder.create()
                    .loadKeyMaterial(ResourceUtils.getFile(sslCertPath), "".toCharArray(), "".toCharArray())
                    .loadTrustMaterial(ResourceUtils.getFile(sslCertPath)).build();
            connectionFactory.useSslProtocol(sslContext);
        }

        return connectionFactory;
    }

    @Bean
    public RabbitTemplate rabbitTemplate() throws Exception {
        RabbitTemplate rabbitTemplate = new RabbitTemplate(connectionFactory());
        return rabbitTemplate;
    }

}

在此示例中，我们使用 `CachingConnectionFactory` 创建连接工厂，并设置 RabbitMQ 的主机名、端口、用户名和密码。我们还设置了虚拟主机名称。

如果 `sslEnabled` 属性为 true，则我们使用 `SSLContextBuilder` 创建 SSL 上下文，并将其传递给连接工厂的 `useSslProtocol` 方法。

最后，我们创建一个 RabbitTemplate bean，它使用我们刚刚创建的连接工厂。

4. 测试 SSL 连接

现在您已经准备好使用 SSL 连接 RabbitMQ 了。您可以使用 RabbitTemplate 发送和接收消息，并确保 SSL 连接正常工作。