RabbitMQ消息加密Ubuntu如何实现

ubuntu

小樊

2025-11-27 05:08:38

栏目: 网络安全

在Ubuntu上实现RabbitMQ消息加密，可以通过以下几个步骤来完成：

1. 安装RabbitMQ

首先，确保你已经在Ubuntu上安装了RabbitMQ。你可以使用以下命令来安装：

sudo apt update
sudo apt install rabbitmq-server

2. 启用SSL/TLS

RabbitMQ支持通过SSL/TLS来加密消息传输。以下是启用SSL/TLS的步骤：

生成SSL证书和密钥

你可以使用OpenSSL来生成自签名的SSL证书和密钥：

sudo openssl req -newkey rsa:2048 -new -nodes -x509 -days 3650 -keyout /etc/rabbitmq/ssl/rabbitmq.key -out /etc/rabbitmq/ssl/rabbitmq.crt

按照提示输入相关信息，例如国家、组织名称等。

配置RabbitMQ使用SSL/TLS

编辑RabbitMQ的配置文件 /etc/rabbitmq/rabbitmq.conf，添加以下内容：

listeners.ssl.default = 5671
ssl_options.cacertfile = /etc/rabbitmq/ssl/rabbitmq.crt
ssl_options.certfile = /etc/rabbitmq/ssl/rabbitmq.crt
ssl_options.keyfile = /etc/rabbitmq/ssl/rabbitmq.key
ssl_options.verify = verify_peer
ssl_options.fail_if_no_peer_cert = true

3. 配置防火墙

确保防火墙允许RabbitMQ的SSL端口（默认是5671）：

sudo ufw allow 5671/tcp

4. 重启RabbitMQ服务

应用配置更改并重启RabbitMQ服务：

sudo systemctl restart rabbitmq-server

5. 客户端配置

在客户端应用程序中，你需要配置RabbitMQ连接以使用SSL/TLS。以下是一个Python示例，使用pika库：

import pika

credentials = pika.PlainCredentials('guest', 'guest')
parameters = pika.ConnectionParameters(
    host='localhost',
    port=5671,
    ssl=True,
    ssl_options={
        'ca_certs': '/etc/rabbitmq/ssl/rabbitmq.crt',
        'certfile': '/etc/rabbitmq/ssl/client.crt',
        'keyfile': '/etc/rabbitmq/ssl/client.key'
    }
)

connection = pika.BlockingConnection(parameters)
channel = connection.channel()

# 声明一个队列
channel.queue_declare(queue='hello')

# 发送消息
channel.basic_publish(exchange='', routing_key='hello', body='Hello World!')

print(" [x] Sent 'Hello World!'")

connection.close()

6. 验证SSL/TLS连接

你可以使用openssl命令来验证SSL/TLS连接：

openssl s_client -connect localhost:5671 -cert /etc/rabbitmq/ssl/client.crt -key /etc/rabbitmq/ssl/client.key -CAfile /etc/rabbitmq/ssl/rabbitmq.crt

如果连接成功，你应该会看到一些SSL握手信息。

通过以上步骤，你可以在Ubuntu上实现RabbitMQ消息的加密传输。