引导者# RabbitMQ with Docker## 简介RabbitMQ 是一个开源的消息代理和队列服务器，用于在应用程序之间传递消息。它支持多种消息协议，并提供了丰富的功能来实现可靠的消息传递。Docker 是一个开源的容器化平台，可以将应用程序及其依赖项打包到一个可移植的容器中，从而简化部署和管理过程。本文将介绍如何使用 Docker 来部署 RabbitMQ。## 安装与配置### 安装 Docker在开始之前，请确保已经在您的机器上安装了 Docker。如果尚未安装，可以参考 Docker 官方文档进行安装。### 拉取 RabbitMQ 镜像使用以下命令从 Docker Hub 拉取 RabbitMQ 的官方镜像：```bash docker pull rabbitmq:3.8-management ```这里我们使用的是 RabbitMQ 3.8 版本，并且包含了 Web 管理界面。### 运行 RabbitMQ 容器使用以下命令启动 RabbitMQ 容器：```bash docker run -d --name rabbitmq-server -p 5672:5672 -p 15672:15672 rabbitmq:3.8-management ```- `-d` 参数表示容器将在后台运行。 - `--name` 参数指定容器名称为 `rabbitmq-server`。 - `-p` 参数将主机的端口映射到容器的端口，其中 `5672` 是 RabbitMQ 的默认端口，`15672` 是 Web 管理界面的端口。### 访问管理界面打开浏览器并访问 `http://localhost:15672`，使用默认用户名 `guest` 和密码 `guest` 登录。请注意，默认情况下，`guest` 用户只能从本地登录，如果您需要远程访问，请创建一个新的用户。## 配置 RabbitMQ### 创建新用户为了安全起见，建议创建一个新的用户并赋予其管理员权限：```bash docker exec -it rabbitmq-server rabbitmqctl add_user myuser mypassword docker exec -it rabbitmq-server rabbitmqctl set_user_tags myuser administrator docker exec -it rabbitmq-server rabbitmqctl set_permissions -p / myuser ".
" ".
" ".
" ```- `add_user` 命令用于添加新用户。 - `set_user_tags` 命令用于设置用户角色。 - `set_permissions` 命令用于授予用户对所有虚拟主机的所有权限。### 修改配置文件您还可以通过修改 RabbitMQ 的配置文件来进一步定制 RabbitMQ 的行为。首先找到配置文件路径：```bash docker inspect -f '{{range .Mounts}}{{if eq .Destination "/etc/rabbitmq"}}{{.Source}}{{end}}{{end}}' rabbitmq-server ```然后编辑配置文件，例如：```bash docker exec -it rabbitmq-server bash -c "echo '[{rabbit, [{loopback_users, []}]}].' > /etc/rabbitmq/rabbitmq.config" ```这将允许非本地用户连接到 RabbitMQ 服务。## 使用示例### 生产者以下是一个简单的 Python 生产者示例，使用 Pika 库发布消息到 RabbitMQ：```python import pikaconnection = pika.BlockingConnection(pika.ConnectionParameters('localhost', 5672, '/', pika.PlainCredentials('myuser', 'mypassword'))) 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() ```### 消费者以下是一个简单的 Python 消费者示例，接收并打印来自 RabbitMQ 的消息：```python import pikaconnection = pika.BlockingConnection(pika.ConnectionParameters('localhost', 5672, '/', pika.PlainCredentials('myuser', 'mypassword'))) channel = connection.channel()channel.queue_declare(queue='hello')def callback(ch, method, properties, body):print(" [x] Received %r" % body)channel.basic_consume(queue='hello', on_message_callback=callback, auto_ack=True) print(' [
] Waiting for messages. To exit press CTRL+C') channel.start_consuming() ```## 结论通过使用 Docker 部署 RabbitMQ，您可以轻松地管理和扩展消息传递系统。希望本文能帮助您快速入门 RabbitMQ 并将其集成到您的项目中。
RabbitMQ with Docker
简介RabbitMQ 是一个开源的消息代理和队列服务器，用于在应用程序之间传递消息。它支持多种消息协议，并提供了丰富的功能来实现可靠的消息传递。Docker 是一个开源的容器化平台，可以将应用程序及其依赖项打包到一个可移植的容器中，从而简化部署和管理过程。本文将介绍如何使用 Docker 来部署 RabbitMQ。
安装与配置
安装 Docker在开始之前，请确保已经在您的机器上安装了 Docker。如果尚未安装，可以参考 Docker 官方文档进行安装。
拉取 RabbitMQ 镜像使用以下命令从 Docker Hub 拉取 RabbitMQ 的官方镜像：```bash docker pull rabbitmq:3.8-management ```这里我们使用的是 RabbitMQ 3.8 版本，并且包含了 Web 管理界面。
运行 RabbitMQ 容器使用以下命令启动 RabbitMQ 容器：```bash docker run -d --name rabbitmq-server -p 5672:5672 -p 15672:15672 rabbitmq:3.8-management ```- `-d` 参数表示容器将在后台运行。 - `--name` 参数指定容器名称为 `rabbitmq-server`。 - `-p` 参数将主机的端口映射到容器的端口，其中 `5672` 是 RabbitMQ 的默认端口，`15672` 是 Web 管理界面的端口。
访问管理界面打开浏览器并访问 `http://localhost:15672`，使用默认用户名 `guest` 和密码 `guest` 登录。请注意，默认情况下，`guest` 用户只能从本地登录，如果您需要远程访问，请创建一个新的用户。
配置 RabbitMQ
创建新用户为了安全起见，建议创建一个新的用户并赋予其管理员权限：```bash docker exec -it rabbitmq-server rabbitmqctl add_user myuser mypassword docker exec -it rabbitmq-server rabbitmqctl set_user_tags myuser administrator docker exec -it rabbitmq-server rabbitmqctl set_permissions -p / myuser ".*" ".*" ".*" ```- `add_user` 命令用于添加新用户。 - `set_user_tags` 命令用于设置用户角色。 - `set_permissions` 命令用于授予用户对所有虚拟主机的所有权限。
修改配置文件您还可以通过修改 RabbitMQ 的配置文件来进一步定制 RabbitMQ 的行为。首先找到配置文件路径：```bash docker inspect -f '{{range .Mounts}}{{if eq .Destination "/etc/rabbitmq"}}{{.Source}}{{end}}{{end}}' rabbitmq-server ```然后编辑配置文件，例如：```bash docker exec -it rabbitmq-server bash -c "echo '[{rabbit, [{loopback_users, []}]}].' > /etc/rabbitmq/rabbitmq.config" ```这将允许非本地用户连接到 RabbitMQ 服务。
使用示例
生产者以下是一个简单的 Python 生产者示例，使用 Pika 库发布消息到 RabbitMQ：```python import pikaconnection = pika.BlockingConnection(pika.ConnectionParameters('localhost', 5672, '/', pika.PlainCredentials('myuser', 'mypassword'))) 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() ```
消费者以下是一个简单的 Python 消费者示例，接收并打印来自 RabbitMQ 的消息：```python import pikaconnection = pika.BlockingConnection(pika.ConnectionParameters('localhost', 5672, '/', pika.PlainCredentials('myuser', 'mypassword'))) channel = connection.channel()channel.queue_declare(queue='hello')def callback(ch, method, properties, body):print(" [x] Received %r" % body)channel.basic_consume(queue='hello', on_message_callback=callback, auto_ack=True) print(' [*] Waiting for messages. To exit press CTRL+C') channel.start_consuming() ```
结论通过使用 Docker 部署 RabbitMQ，您可以轻松地管理和扩展消息传递系统。希望本文能帮助您快速入门 RabbitMQ 并将其集成到您的项目中。
