使用 Docker 快速入门 RabbitMQ：安装与基本操作

引言

RabbitMQ 是一个流行的开源消息代理软件，它支持多种消息协议，并且易于部署和使用。Docker 作为一个轻量级容器化平台，可以简化 RabbitMQ 的安装和部署过程。本文将引导你通过 Docker 快速安装 RabbitMQ，并进行一些基本操作。

RabbitMQ 简介

RabbitMQ 是一个遵循 AMQP（高级消息队列协议）的消息代理，它提供了可靠、容错的消息队列功能。RabbitMQ 可以用于多种场景，包括任务分发、事件驱动架构、应用解耦等。

RabbitMQ 的核心概念

生产者（Producer）：发送消息的一方。
消费者（Consumer）：接收消息的一方。
队列（Queue）：消息的存储地，直到它们被消费者处理。
交换机（Exchange）：接收生产者的消息，并将它们路由到一个或多个队列。
绑定（Binding）：交换机和队列之间的虚拟连接，定义了消息如何从交换机路由到队列。

安装前的准备

在开始安装之前，请确保你已经安装了 Docker，并且 Docker 服务正在运行。

检查 Docker 状态

docker --version
docker info

使用 Docker 安装 RabbitMQ

1. 拉取 RabbitMQ 镜像

Docker Hub 上提供了官方的 RabbitMQ 镜像，我们可以直接拉取。

docker pull rabbitmq:3-management

这个镜像包含了 RabbitMQ 服务以及管理界面。

2. 运行 RabbitMQ 容器

运行一个 RabbitMQ 容器，并映射默认的 5672（AMQP 协议）、15672（管理界面）端口到宿主机。

docker run -d --name rabbitmq -p 5672:5672 -p 15672:15672 rabbitmq:3-management

3. 验证 RabbitMQ 容器运行状态

使用以下命令检查容器是否正在运行：

docker ps

RabbitMQ 基本操作

访问管理界面

打开浏览器，访问 http://localhost:15672，使用默认的用户名 guest 和密码 guest 登录。

创建一个新的用户

登录管理界面。
点击 “Admin” 下的 “Users”。
点击 “Add a user” 并填写新用户的用户名和密码。

创建一个新的虚拟主机

在管理界面，点击 “Admin” 下的 “Virtual hosts”。
点击 “Add a virtual host” 并填写虚拟主机的名称。

设置用户权限

在 “Users” 页面，选择你创建的用户。
在 “Permissions” 标签页，设置用户对特定虚拟主机的配置、写入和读取权限。

发送和接收消息

使用 RabbitMQ 提供的各种客户端库，你可以在应用程序中发送和接收消息。以下是使用 Python 客户端库 pika 的一个简单示例：

import pika# 连接到 RabbitMQ 服务器
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()# 声明一个队列
channel.queue_declare(queue='hello')# 定义一个回调函数来处理接收到的消息
def callback(ch, method, properties, body):print(f" [x] Received {body}")# 告诉 RabbitMQ 使用我们的回调函数来接收消息
channel.basic_consume(queue='hello', on_message_callback=callback, auto_ack=True)print(' [*] Waiting for messages. To exit press CTRL+C')
channel.start_consuming()