4. RabbitMQ 安装与配置

文档摘要

RabbitMQ 安装与配置 RabbitMQ 安装与配置详解 4.1 引言在开始之前，让我们简要回顾一下 RabbitMQ 的核心概念。RabbitMQ 是一个开源的消息代理和队列服务器，它实现了高级消息队列协议 (AMQP)。其核心功能在于接收和转发消息，使得不同的应用程序、服务甚至系统之间能够异步地进行通信。理解 RabbitMQ 的消息特性（如消息的持久性、路由、确认机制等）对于后续的配置工作至关重要，因为配置的最终目标是保障这些特性的有效实现。本章将涵盖以下关键内容：安装 RabbitMQ: 详细介绍在不同操作系统（包括 Linux、macOS 和 Windows）下安装 RabbitMQ 的步骤，包括使用包管理器、Docker 等多种方式。

4. RabbitMQ 安装与配置

4. RabbitMQ 安装与配置详解

4.1 引言

在开始之前，让我们简要回顾一下 RabbitMQ 的核心概念。RabbitMQ 是一个开源的消息代理和队列服务器，它实现了高级消息队列协议 (AMQP)。其核心功能在于接收和转发消息，使得不同的应用程序、服务甚至系统之间能够异步地进行通信。理解 RabbitMQ 的消息特性（如消息的持久性、路由、确认机制等）对于后续的配置工作至关重要，因为配置的最终目标是保障这些特性的有效实现。

本章将涵盖以下关键内容：

安装 RabbitMQ: 详细介绍在不同操作系统（包括 Linux、macOS 和 Windows）下安装 RabbitMQ 的步骤，包括使用包管理器、Docker 等多种方式。
基本配置: 深入讲解 RabbitMQ 的配置文件 rabbitmq.conf，包括其结构、常用配置项（如端口、节点名称、日志设置等）的含义和配置方法。
高级配置: 探讨更高级的配置选项，例如虚拟主机 (Virtual Hosts)、用户和权限管理、策略 (Policies)、资源限制 (Resource Limits) 以及集群配置的基础概念。
安全配置: 强调 RabbitMQ 的安全配置，包括防火墙设置、用户权限管理、SSL/TLS 加密等，确保消息传递的安全性。
监控与管理: 介绍如何通过 RabbitMQ Management UI 和命令行工具 rabbitmqctl 监控和管理 RabbitMQ 服务器。

通过本章的学习，读者将能够掌握 RabbitMQ 的安装和配置技能，为后续深入应用 RabbitMQ 打下坚实的基础。

4.2 安装 RabbitMQ

RabbitMQ 的安装过程相对简单，但在不同操作系统上略有差异。以下将分别介绍在主流操作系统上的安装方法。

4.2.1 前提条件

在安装 RabbitMQ 之前，需要确保系统已安装 Erlang/OTP。RabbitMQ 是用 Erlang 语言开发的，Erlang/OTP 是其运行环境。

检查 Erlang/OTP 版本兼容性: RabbitMQ 官方文档会列出推荐的 Erlang/OTP 版本。请务必查阅官方文档，选择与你的 RabbitMQ 版本兼容的 Erlang/OTP 版本。

你可以通过以下命令检查 Erlang 是否已安装以及版本信息：


erl -version

如果未安装 Erlang/OTP，或者版本不符合要求，请先安装或升级 Erlang/OTP。

4.2.2 Linux 系统安装 (以 Ubuntu/Debian 为例)

在基于 Debian 的 Linux 发行版（如 Ubuntu）上，可以使用 apt 包管理器进行安装。

步骤 1: 添加 RabbitMQ APT 仓库

为了方便安装 RabbitMQ 以及后续的版本更新，建议添加 RabbitMQ 官方 APT 仓库。


sudo apt-get update
sudo apt-get install apt-transport-https ca-certificates
sudo apt-get update
sudo apt-get install curl
curl -s https://packagecloud.io/install/repositories/rabbitmq/rabbitmq-server/script.deb.sh | sudo bash

这个脚本会自动配置 RabbitMQ 的 APT 仓库。

步骤 2: 安装 RabbitMQ Server

添加仓库后，即可使用 apt-get install 命令安装 RabbitMQ Server。


sudo apt-get install rabbitmq-server

安装过程中，apt 会自动处理依赖关系，包括 Erlang/OTP（如果尚未安装）。

步骤 3: 启动 RabbitMQ Server

安装完成后，RabbitMQ Server 会自动启动。你可以使用 systemctl 命令管理 RabbitMQ 服务。

启动 RabbitMQ:


sudo systemctl start rabbitmq-server

停止 RabbitMQ:


sudo systemctl stop rabbitmq-server

重启 RabbitMQ:


sudo systemctl restart rabbitmq-server

查看 RabbitMQ 服务状态:


sudo systemctl status rabbitmq-server

步骤 4: 启用 RabbitMQ Management Plugin (可选但推荐)

RabbitMQ Management Plugin 提供了一个 Web UI，用于监控和管理 RabbitMQ 服务器。强烈建议启用此插件。


sudo rabbitmq-plugins enable rabbitmq_management

启用插件后，访问 http://localhost:15672 (默认端口)，使用默认用户名 guest 和密码 guest 登录 (出于安全考虑，生产环境应立即修改默认用户名和密码)。

4.2.3 macOS 系统安装 (使用 Homebrew)

在 macOS 系统上，推荐使用 Homebrew 包管理器进行安装。

步骤 1: 安装 Erlang/OTP (如果未安装)


brew install erlang

步骤 2: 安装 RabbitMQ Server


brew install rabbitmq

步骤 3: 启动 RabbitMQ Server

使用 Homebrew 安装的 RabbitMQ 可以通过以下命令启动：


brew services start rabbitmq

停止 RabbitMQ:


brew services stop rabbitmq

重启 RabbitMQ:


brew services restart rabbitmq

步骤 4: 启用 RabbitMQ Management Plugin (可选但推荐)

与 Linux 类似，在 macOS 上也需要手动启用 Management Plugin。


rabbitmq-plugins enable rabbitmq_management

然后访问 http://localhost:15672 登录 Management UI。

4.2.4 Windows 系统安装

在 Windows 系统上安装 RabbitMQ，需要先安装 Erlang/OTP for Windows。

步骤 1: 安装 Erlang/OTP for Windows

访问 Erlang Solutions 官网的 Erlang/OTP 下载页面 (https://www.erlang-solutions.com/downloads/).
下载适用于 Windows 的 Erlang/OTP 安装程序 (选择与你的 Windows 版本对应的版本)。
运行安装程序，按照提示完成安装。确保在安装过程中将 Erlang 的 bin 目录添加到系统环境变量 PATH 中。

步骤 2: 安装 RabbitMQ Server for Windows

访问 RabbitMQ 官网的 Windows 安装页面 (https://www.rabbitmq.com/installing-windows.html).
下载 RabbitMQ Server for Windows 的安装程序。
运行安装程序，按照提示完成安装。

步骤 3: 启动 RabbitMQ Service

安装完成后，RabbitMQ Service 会自动安装，但可能需要手动启动。

启动 RabbitMQ Service: 在 Windows 服务管理器中找到 "RabbitMQ" 服务，右键选择 "启动"。
停止 RabbitMQ Service: 在 Windows 服务管理器中找到 "RabbitMQ" 服务，右键选择 "停止"。
重启 RabbitMQ Service: 在 Windows 服务管理器中找到 "RabbitMQ" 服务，右键选择 "重启"。

步骤 4: 启用 RabbitMQ Management Plugin (可选但推荐)

打开命令提示符 (以管理员身份运行)，导航到 RabbitMQ 的 sbin 目录 (通常在 C:\Program Files\RabbitMQ Server\rabbitmq_server-版本号\sbin )，然后执行以下命令：


rabbitmq-plugins enable rabbitmq_management

然后访问 http://localhost:15672 登录 Management UI。

4.2.5 Docker 安装 (跨平台通用)

使用 Docker 安装 RabbitMQ 是一个跨平台且便捷的方式，尤其适合快速部署和测试环境。

步骤 1: 拉取 RabbitMQ Docker 镜像


docker pull rabbitmq:management

rabbitmq:management 镜像包含了 RabbitMQ Server 和 Management Plugin。

步骤 2: 运行 RabbitMQ Docker 容器


docker run -d --name my-rabbit -p 5672:5672 -p 15672:15672 rabbitmq:management

-d: 后台运行容器。
--name my-rabbit: 为容器命名为 my-rabbit。
-p 5672:5672: 将容器的 5672 端口 (AMQP 端口) 映射到宿主机的 5672 端口。
-p 15672:15672: 将容器的 15672 端口 (Management UI 端口) 映射到宿主机的 15672 端口。
rabbitmq:management: 使用的镜像名称。

步骤 3: 访问 RabbitMQ Management UI

容器启动后，访问 http://localhost:15672 登录 Management UI。默认用户名和密码仍然是 guest/guest。

Docker 安装优势:

隔离性: Docker 容器提供了隔离的环境，避免与宿主机系统或其他应用程序冲突。
便捷性: 安装和启动 RabbitMQ 非常快速，只需几条 Docker 命令。
一致性: 在不同操作系统和环境中，使用 Docker 部署的 RabbitMQ 环境保持一致。

4.3 基本配置详解

RabbitMQ 的主要配置文件是 rabbitmq.conf。此文件位于不同的操作系统上位置有所不同。

Linux (Debian/Ubuntu): /etc/rabbitmq/rabbitmq.conf
macOS (Homebrew): /usr/local/etc/rabbitmq/rabbitmq.conf
Windows: %AppData%\RabbitMQ\rabbitmq.conf (例如 C:\Users\YourUsername\AppData\Roaming\RabbitMQ\rabbitmq.conf)
Docker: 配置文件通常在容器内部，可以通过挂载卷的方式进行配置。

4.3.1 `rabbitmq.conf` 文件结构与语法

rabbitmq.conf 文件采用 高级 Erlang 配置格式 (Advanced Erlang Configuration Format)。它基于 Erlang 语法，但为了方便配置，通常以 类 ini 格式 或 YAML 格式 编写，RabbitMQ 会自动将其转换为 Erlang 格式。

类 ini 格式示例:


listeners.tcp.default = 5672
loopback_users.guest = false
default_vhost = my_default_vhost

YAML 格式示例 (更推荐):


listeners:
  - port: 5672
    protocol: amqp
loopback_users:
  - guest
default_vhost: my_default_vhost

配置项语法:

键值对: 使用 键 = 值 (ini 格式) 或 键: 值 (YAML 格式) 的形式配置。
层级结构: 使用点号 . (ini 格式) 或缩进 (YAML 格式) 表示层级关系。
注释: 使用 # (ini 格式) 或 # (YAML 格式) 表示注释。
列表: 使用逗号 , 分隔 (ini 格式) 或 - 开头的列表项 (YAML 格式)。

4.3.2 常用配置项详解

以下是一些常用的 rabbitmq.conf 配置项，及其含义和配置方法。

4.3.2.1 `listeners` - 监听器配置

listeners 配置项定义了 RabbitMQ Server 监听客户端连接的端口和协议。

listeners.tcp.default (ini) 或 listeners: (YAML): 配置 TCP 监听器。
- port: 监听端口号，默认为 5672 (AMQP 协议)。
- protocol: 协议类型，默认为 amqp。
- ip: 监听 IP 地址，默认为 :: (监听所有 IPv4 和 IPv6 地址)。可以设置为 0.0.0.0 (监听所有 IPv4 地址) 或具体的 IP 地址。
- ssl_options: SSL/TLS 配置选项 (将在安全配置章节详细介绍)。

示例 (YAML):


listeners:
  - port: 5672
    protocol: amqp
    ip: 0.0.0.0  # 监听所有 IPv4 地址
  - port: 5671
    protocol: amqp
    ssl_options:
      certfile: "/path/to/server_cert.pem"
      keyfile: "/path/to/server_key.pem"
      verify: verify_peer
      fail_if_no_peer_cert: true

4.3.2.2 `loopback_users` - 回环连接用户配置

loopback_users 配置项定义了只允许本地回环连接的用户列表。默认情况下，guest 用户只允许本地回环连接，这是一个安全限制。

loopback_users.guest = false (ini) 或 loopback_users: (YAML): 禁用 guest 用户的回环连接限制，允许远程连接。
loopback_users = [] (ini) 或 loopback_users: [] (YAML): 禁用所有用户的回环连接限制。
loopback_users = [username1, username2, ...] (ini) 或 loopback_users: [username1, username2, ...] (YAML): 只允许指定用户进行回环连接。

示例 (YAML):


loopback_users: []  # 允许所有用户远程连接

安全提示: 在生产环境中，强烈建议不要禁用 guest 用户的回环连接限制，并 立即删除或修改 默认的 guest 用户密码。应该创建具有适当权限的专用用户进行远程连接。

4.3.2.3 `default_vhost` - 默认虚拟主机配置

default_vhost 配置项设置默认的虚拟主机名称。虚拟主机 (Virtual Hosts) 提供了逻辑隔离，允许多个应用程序共享同一个 RabbitMQ Server，但彼此之间相互隔离。

default_vhost = vhost_name (ini) 或 default_vhost: vhost_name (YAML): 设置默认虚拟主机名称。

示例 (YAML):


default_vhost: my_app_vhost

4.3.2.4 `default_user` 和 `default_pass` - 默认用户配置 (不推荐使用)

default_user 和 default_pass 配置项设置默认的用户名和密码。强烈不建议在生产环境中使用默认用户，应立即删除或修改默认用户密码，并创建专用用户。

default_user = username (ini) 或 default_user: username (YAML): 设置默认用户名。
default_pass = password (ini) 或 default_pass: password (YAML): 设置默认密码。

示例 (YAML) - 仅供演示，生产环境请勿使用:


default_user: my_admin
default_pass: my_secret_password

4.3.2.5 `log` - 日志配置

log 配置项控制 RabbitMQ Server 的日志行为。

log.dir (ini) 或 log.dir: (YAML): 设置日志文件目录，默认为 ${RABBITMQ_HOME}/var/log/rabbitmq。
log.console (ini) 或 log.console: (YAML): 是否输出日志到控制台，默认为 true。
log.level (ini) 或 log.level: (YAML): 日志级别，可选值包括 none, error, warning, info, debug，默认为 info。

示例 (YAML):


log:
  dir: /var/log/rabbitmq  # 自定义日志目录
  console: false           # 关闭控制台日志输出
  level: warning           # 设置日志级别为 warning

4.3.2.6 `cluster_formation` - 集群配置 (基础)

cluster_formation 配置项用于配置 RabbitMQ 集群。集群可以提高可用性和吞吐量。

cluster_formation.peer_discovery_backend (ini) 或 cluster_formation.peer_discovery_backend: (YAML): 集群节点发现后端，可选值包括 classic_config, classic_membership, rabbit_peer_discovery_k8s, rabbit_peer_discovery_aws, rabbit_peer_discovery_etcd, rabbit_peer_discovery_dns_record 等。
cluster_formation.classic_config.nodes (ini) 或 cluster_formation.classic_config.nodes: (YAML): 当 peer_discovery_backend 为 classic_config 时，指定集群节点列表。

示例 (YAML) - 基于静态节点列表的集群配置 (仅供演示，生产环境建议使用更动态的发现机制):


cluster_formation:
  peer_discovery_backend: classic_config
  classic_config:
    nodes:
      - rabbit@node1
      - rabbit@node2
      - rabbit@node3

集群配置将在后续高级配置章节进一步探讨。

4.3.3 应用配置更改

修改 rabbitmq.conf 文件后，需要 重启 RabbitMQ Server 才能使配置生效。


sudo systemctl restart rabbitmq-server  # Linux
brew services restart rabbitmq        # macOS
# Windows: 在服务管理器中重启 RabbitMQ 服务
docker restart my-rabbit             # Docker

4.4 高级配置概览

除了基本配置外，RabbitMQ 还提供了许多高级配置选项，以满足更复杂的需求。以下简要介绍一些关键的高级配置领域。

4.4.1 虚拟主机 (Virtual Hosts)

虚拟主机提供了 逻辑隔离，允许多个独立的 RabbitMQ 环境共享同一个物理 RabbitMQ Server。每个虚拟主机拥有独立的交换机 (Exchanges)、队列 (Queues)、绑定 (Bindings) 和权限设置。

应用场景:

多租户环境: 为不同的租户或应用程序提供独立的 message broker 环境。
开发、测试、生产环境隔离: 在同一个 RabbitMQ Server 上创建不同的虚拟主机，用于不同的环境。
项目或团队隔离: 为不同的项目或团队提供独立的 message broker 空间。

配置与管理:

创建虚拟主机: 可以使用 rabbitmqctl add_vhost <vhost_name> 命令或 Management UI 创建虚拟主机。
设置虚拟主机权限: 可以使用 rabbitmqctl set_permissions -p <vhost_name> <user> <configure> <write> <read> 命令或 Management UI 设置用户在虚拟主机上的权限。
连接到虚拟主机: 客户端连接时，需要在连接 URI 中指定虚拟主机名称。

4.4.2 用户和权限管理

RabbitMQ 提供了完善的用户和权限管理机制，用于控制用户对 RabbitMQ 资源的访问权限。

用户管理:

添加用户: rabbitmqctl add_user <username> <password>
删除用户: rabbitmqctl delete_user <username>
修改用户密码: rabbitmqctl change_password <username> <new_password>
设置用户标签 (Tags): rabbitmqctl set_user_tags <username> <tag> ... (例如 administrator, management, monitoring)

权限管理:

设置虚拟主机权限: rabbitmqctl set_permissions -p <vhost_name> <user> <configure> <write> <read>
- <configure>: 配置权限 (交换机和队列的创建、删除等)。
- <write>: 写权限 (发布消息到交换机)。
- <read>: 读权限 (从队列消费消息)。
清除虚拟主机权限: rabbitmqctl clear_permissions -p <vhost_name> <user>
查看用户权限: rabbitmqctl list_user_permissions <username>

最佳实践:

最小权限原则: 为用户分配最小必要的权限。
避免使用默认用户: 删除或修改默认的 guest 用户，并创建专用用户。
使用用户标签: 使用用户标签进行角色管理，简化权限管理。

4.4.3 策略 (Policies)

策略 (Policies) 提供了一种动态配置交换机和队列行为的方式，而无需修改应用程序代码。策略可以根据模式匹配 (pattern matching) 应用于交换机和队列，实现诸如消息 TTL (Time-To-Live)、队列类型 (Queue Type)、死信交换机 (Dead-Letter Exchange) 等高级特性。

策略类型:

消息 TTL (message-ttl): 设置消息在队列中的存活时间。
队列 TTL (expires): 设置队列的存活时间，队列在一段时间后自动删除。
队列类型 (queue-mode): 设置队列模式，例如 default (内存和磁盘存储) 或 lazy (消息主要存储在磁盘上，减少内存占用)。
死信交换机 (dead-letter-exchange): 设置死信交换机，用于接收被拒绝、过期或超过队列长度限制的消息。
队列长度限制 (max-length, max-length-bytes): 限制队列的最大消息数量或总字节数。
镜像队列 (ha-mode): 配置队列镜像，提高队列的可用性。

配置与管理:

添加策略: rabbitmqctl set_policy -p <vhost_name> <policy_name> <pattern> <definition> [priority] [apply-to]
- <pattern>: 正则表达式，用于匹配交换机或队列名称。
- <definition>: JSON 格式的策略定义，包含策略类型和参数。
- [priority]: 策略优先级，数字越大优先级越高，默认为 0。
- [apply-to]: 策略应用对象，可选值 queues, exchanges, all，默认为 queues。
删除策略: rabbitmqctl clear_policy -p <vhost_name> <policy_name>
查看策略: rabbitmqctl list_policies -p <vhost_name>

示例: 设置队列 my_queue 的消息 TTL 为 60 秒。


rabbitmqctl set_policy -p my_vhost message-ttl "my_queue" '{"message-ttl":60000}' --apply-to queues

4.4.4 资源限制 (Resource Limits)

RabbitMQ 提供了资源限制机制，用于防止单个连接、通道或队列过度消耗服务器资源，保障系统的稳定性。

资源限制类型:

连接限制: 限制单个连接的通道数量。
通道限制: 限制单个通道的未确认消息数量 (prefetch count)。
队列限制: 限制队列的最大长度、消息大小、内存占用等。
全局资源限制: 限制 RabbitMQ Server 的总连接数、通道数、队列数等。

配置与管理:

资源限制通常通过 rabbitmq.conf 配置文件或策略进行配置。例如，可以使用策略设置队列的最大长度，可以使用 rabbitmq.conf 配置全局连接限制。

4.4.5 集群配置 (深入)

RabbitMQ 集群将多个 RabbitMQ 节点连接在一起，形成一个逻辑上的 Broker。集群提供了 高可用性 和 扩展性。

集群类型:

经典集群 (Classic Cluster): 所有节点共享元数据，任何节点都可以处理所有队列。
仲裁队列 (Quorum Queues): 基于 Raft 算法的队列类型，提供更强的数据一致性和可靠性，但性能略低于经典镜像队列。
流 (Streams): 用于高扇出、高吞吐量场景的新型消息队列，支持消息持久化和回放。

集群部署方式:

静态节点列表 (Classic Config): 在 rabbitmq.conf 中静态配置集群节点列表。
DNS 记录 (DNS Record): 使用 DNS SRV 记录或 A 记录进行节点发现。
Kubernetes (Kubernetes): 在 Kubernetes 环境中使用 RabbitMQ Cluster Operator 或 Helm Chart 部署集群。
AWS (AWS): 使用 AWS 插件或 EC2 用户数据进行节点发现。
Etcd/Consul (Etcd/Consul): 使用 Etcd 或 Consul 进行节点发现。

集群配置将在后续更深入的 RabbitMQ 主题中详细探讨。

4.5 安全配置

RabbitMQ 的安全配置至关重要，尤其是在生产环境中。以下是一些关键的安全配置措施。

4.5.1 防火墙配置

配置防火墙，只允许必要的端口对外开放。

5672 (AMQP 端口): 客户端连接端口。
5671 (AMQP over TLS 端口): 客户端 TLS 连接端口 (如果启用 TLS)。
15672 (Management UI 端口): Management UI 访问端口 (如果启用 Management Plugin)。
4369 (Erlang 端口映射器): 集群内部节点通信端口 (集群环境需要开放)。
25672 (Erlang 分布式端口): 集群内部节点通信端口 (集群环境需要开放)。

建议: 根据实际需求，只开放必要的端口，并限制访问来源 IP 地址。

4.5.2 SSL/TLS 加密

启用 SSL/TLS 加密，保护客户端和 RabbitMQ Server 之间的通信安全。

配置步骤:

生成 SSL/TLS 证书和密钥: 可以使用 openssl 等工具生成自签名证书或从证书颁发机构 (CA) 获取证书。
配置 rabbitmq.conf: 在 listeners 配置项中配置 ssl_options，指定证书文件、密钥文件、验证模式等。

示例 (YAML):


listeners:
  - port: 5671
    protocol: amqp
    ssl_options:
      certfile: "/path/to/server_cert.pem"
      keyfile: "/path/to/server_key.pem"
      verify: verify_peer
      fail_if_no_peer_cert: true

SSL/TLS 配置选项:

certfile: 服务器证书文件路径。
keyfile: 服务器密钥文件路径。
cacertfile: CA 证书文件路径 (用于验证客户端证书)。
verify: 证书验证模式，可选值包括 verify_none, verify_peer, verify_peer_and_die

作者与出处

原作者：灏天文库

来源：灏天文库

原文： https://aiknowledge.cn/collection/216-rabbitmq%E6%B6%88%E6%81%AF%E9%98%9F%E5%88%97%E5%AE%9E%E6%88%98%E6%95%99%E7%A8%8B

整理：灏天文库整理

由灏天文库平台收录，内容或由平台用户上传，仅供学习交流

4. RabbitMQ 安装与配置

文档摘要