【技术教程】RabbitMQ-涣清博客

一、RabbitMQ 基础入门

1.1 RabbitMQ 是什么

RabbitMQ 是一个开源的消息代理中间件，实现了高级消息队列协议（AMQP）。它使用 Erlang 语言开发，以其高可靠性、灵活的路由机制和易用性而闻名。在分布式系统中，RabbitMQ 扮演着消息中转站的角色，用于实现系统间的异步通信、服务解耦和流量削峰。比如在电商系统中，用户下单后，订单服务可以发送消息到 RabbitMQ，库存服务、物流服务等可以从 RabbitMQ 获取订单消息并进行相应处理，各个服务之间无需直接调用，从而实现解耦。

AMQP 协议是一个提供统一消息服务的应用层标准高级消息队列协议，它定义了一套确定的消息交换功能，也就是 “高级消息交换协议模型”，包括用于路由和存储消息的功能模块，以及在这些模块之间交换消息的规则。同时，AMQP 协议还定义了一个网络线级协议（数据传输格式），客户端应用可以通过这个协议与消息代理和它实现的 AMQP 模型进行交互通信。RabbitMQ 基于 AMQP 协议，使得不同的应用程序之间可以通过它进行可靠的消息传递，不受开发语言和平台的限制。

1.2 核心概念剖析

生产者（Producer）：发送消息的应用程序，负责创建消息并将其发送到 RabbitMQ 的交换机中。例如在一个订单系统中，订单创建的模块就是生产者，当有新订单生成时，它会将包含订单信息的消息发送给 RabbitMQ。
消费者（Consumer）：从队列接收并处理消息的应用程序。继续以上述订单系统为例，库存管理模块可以作为消费者，当它从队列中接收到订单消息时，就会根据订单信息进行库存扣减等操作。
队列（Queue）：存储消息的缓冲区，是消息的最终目的地。队列以先进先出（FIFO）的方式存储消息，多个消费者可以同时监听一个队列，一条消息只会被一个消费者消费（默认情况下）。队列支持持久化，即使 RabbitMQ 服务器重启，存储在持久化队列中的消息也不会丢失。
交换器（Exchange）：接收生产者发送的消息，并根据路由规则将消息分发到相应的队列。交换器不存储消息，如果没有匹配的队列，消息会被丢弃（或根据策略返回给生产者）。RabbitMQ 支持多种类型的交换器，每种类型对应不同的消息路由机制，如 Direct Exchange（直接交换器）、Topic Exchange（主题交换器）、Fanout Exchange（扇形交换器）和 Headers Exchange（头交换器）。
绑定（Binding）：连接 Exchange 和 Queue 的规则，定义了消息应该如何从 Exchange 路由到 Queue。在绑定过程中，会指定一个绑定键（Binding Key），交换器根据这个绑定键和自身的类型来决定将消息路由到哪些队列。
虚拟主机（Virtual Host）：提供命名空间和环境，将 Exchange、Queue 等资源进行逻辑分组。每个虚拟主机都有独立的权限控制，不同的虚拟主机之间相互隔离，就像是独立的 RabbitMQ 服务器实例。例如，开发环境和生产环境可以使用不同的虚拟主机，避免资源冲突和相互影响。

这些核心概念协同工作，生产者将消息发送到交换器，交换器根据绑定规则和自身类型将消息路由到对应的队列，消费者从队列中获取消息并进行处理，而虚拟主机则提供了资源隔离和管理的功能。

1.3 为何选择 RabbitMQ

可靠性：RabbitMQ 支持消息持久化，即将消息存储到磁盘上，保证即使服务器宕机，消息也不会丢失。同时，它还提供了传输确认机制（publisher confirm），生产者可以通过该机制确认消息是否成功发送到了 RabbitMQ 服务器；消费者端也有消息确认（acknowledgment）机制，只有当消费者成功处理消息并返回确认后，RabbitMQ 才会从队列中删除该消息，从而确保消息不会在传输或处理过程中丢失。
灵活性：通过多种 Exchange 类型（Direct、Topic、Fanout、Headers）和 Binding 规则，RabbitMQ 可以实现非常复杂的消息路由逻辑。例如，在一个电商系统中，使用 Topic Exchange 可以根据不同的订单类型（如普通订单、团购订单、促销订单等）将订单消息路由到不同的队列，以便不同的业务模块进行处理。
扩展性：RabbitMQ 支持集群部署，通过增加节点可以实现水平扩展，提高系统的吞吐量和可用性。在集群模式下，多个 RabbitMQ 节点可以协同工作，共同处理消息，并且可以实现数据的复制和备份，当某个节点出现故障时，其他节点可以继续提供服务。
跨平台支持：RabbitMQ 提供了丰富的客户端支持，几乎支持所有主要的编程语言，如 Java、Python、.NET、Ruby、PHP 等。这使得不同技术栈的项目都可以方便地集成 RabbitMQ，实现消息通信功能。
丰富的插件体系：RabbitMQ 拥有强大的插件系统，通过插件可以扩展其功能，如实现延迟队列、消息追踪、监控报警等功能。例如，使用延迟队列插件可以实现订单超时未支付自动取消等业务场景。

与其他消息队列相比，如 Kafka 在高吞吐量的日志收集和大数据处理场景表现出色，但在消息可靠性和复杂路由方面相对较弱；ActiveMQ 功能全面但性能和扩展性不如 RabbitMQ；RocketMQ 在分布式事务和顺序消息处理上有优势，但使用和部署相对复杂。而 RabbitMQ 在可靠性、灵活性和易用性等方面表现较为均衡，适用于大多数企业级应用场景，特别是对消息可靠性和路由灵活性要求较高的场景

二、环境搭建与准备

2.1 安装 RabbitMQ

Windows 系统：

首先，RabbitMQ 是用 Erlang 语言开发的，所以需要先安装 Erlang 环境。前往 Erlang Solutions 官网（https://www.erlang-solutions.com/resources/download.html）下载适合 Windows 系统的 Erlang 安装包，例如otp_win64_XXX.exe（XXX 代表版本号）。下载完成后，双击安装包进行安装，安装过程中按照提示逐步完成，如选择安装路径、接受许可协议等。
下载 RabbitMQ 安装包，从 RabbitMQ 官方网站（https://www.rabbitmq.com/download.html）获取rabbitmq-server-XXX.exe（XXX 为版本号）。运行安装程序，在安装向导中，点击 “Next” 按钮，可选择默认安装路径，也可自定义路径。然后按照提示完成安装。
安装完成后，打开命令提示符，切换到 RabbitMQ 的安装目录下的sbin目录（例如C:\Program Files\RabbitMQ Server\rabbitmq_server-XXX\sbin）。运行命令rabbitmq-plugins enable rabbitmq_management，启用 RabbitMQ 的管理插件，该插件允许通过 Web 界面管理 RabbitMQ。
启动 RabbitMQ 服务，可以在 “服务” 中找到 “RabbitMQ” 服务并启动，也可以在命令提示符中运行rabbitmq-service start。

Linux 系统（以 Ubuntu 为例）：

添加 Erlang Solutions 仓库，通过以下命令实现：

wget https://packages.erlang-solutions.com/erlang-solutions_2.0_all.deb
sudo dpkg -i erlang-solutions_2.0_all.deb
复制

更新软件源并安装 Erlang：

sudo apt update

sudo apt install esl-erlang
复制

安装 Socat，Socat 是一个用于建立双向字节流通道的工具，RabbitMQ 需要它。执行命令sudo apt install socat。
添加 RabbitMQ 官方密钥和仓库：

wget -O- https://github.com/rabbitmq/signing-keys/releases/download/2.0/rabbitmq-release-signing-key.asc | sudo apt-key add -
echo "deb https://dl.bintray.com/rabbitmq-erlang/debian $(lsb_release -cs) erlang" | sudo tee /etc/apt/sources.list.d/bintray.rabbitmq.list
复制

更新软件源并安装 RabbitMQ：

sudo apt update
sudo apt install rabbitmq-server
复制

启动 RabbitMQ 服务，使用命令sudo systemctl start rabbitmq-server，并设置开机自启sudo systemctl enable rabbitmq-server。同时可以通过sudo systemctl status rabbitmq-server查看服务状态。

在安装过程中，可能会遇到依赖问题。比如在 Linux 系统中，如果安装的 Erlang 版本不符合 RabbitMQ 的要求，可能导致安装失败。此时需要根据 RabbitMQ 官方文档中对 Erlang 版本的要求，重新安装适配版本的 Erlang。如安装过程中提示缺少某些依赖库，可根据错误提示使用包管理器进行安装，例如sudo apt install（Ubuntu）或sudo yum install（CentOS）。

2.2 安装客户端库

Python（使用 pika 库）：
- 如果已经安装了 Python 和 pip（Python 的包管理工具），在命令行中运行pip install pika即可完成安装。如果使用的是虚拟环境，确保在激活虚拟环境后执行安装命令。
- 如果需要离线安装，可在有网络的环境中使用pip download pika命令下载 pika 库及其依赖项，将下载的文件传输到目标机器，然后在目标机器上运行pip install pika-*.whl（*匹配下载的具体版本号）进行安装。
Java（使用 amqp-client 库）：
- 如果使用 Maven 项目，在pom.xml文件中添加以下依赖：

<dependency>
    <groupId>com.rabbitmq</groupId>
    <artifactId>amqp-client</artifactId>
    <version>5.14.2</version> <!-- 可根据实际情况选择版本 -->
</dependency>

如果使用 Gradle 项目，在build.gradle文件中添加依赖：

implementation 'com.rabbitmq:amqp-client:5.14.2'

添加依赖后，构建项目时会自动下载并引入amqp-client库。

2.3 配置 RabbitMQ

端口配置：RabbitMQ 默认使用 5672 端口进行 AMQP 协议通信，15672 端口用于管理界面（前提是启用了rabbitmq_management插件）。如果这些端口被占用，可以修改配置文件来更改端口。在 Windows 系统中，配置文件通常位于C:\Program Files\RabbitMQ Server\rabbitmq_server-XXX\etc\rabbitmq目录下的rabbitmq.conf文件；在 Linux 系统中，位于/etc/rabbitmq/rabbitmq.conf。例如，将 AMQP 端口修改为 5673，可以在配置文件中添加或修改listeners.tcp.default = 5673。
用户权限设置：
- RabbitMQ 默认有一个guest用户，密码也是guest，但该用户默认只能从本地访问。为了安全和远程访问，通常需要创建新用户。以 Windows 系统为例，打开命令提示符，切换到 RabbitMQ 的sbin目录，使用以下命令创建用户：rabbitmqctl add_user username password，其中username是用户名，password是密码。例如rabbitmqctl add_user myuser mypassword。
- 设置用户角色，RabbitMQ 有多种角色，如administrator（超级管理员）、management（普通管理者，可登录管理控制台）等。使用命令rabbitmqctl set_user_tags username tag来设置角色，例如rabbitmqctl set_user_tags myuser administrator。
- 设置用户权限，针对某个虚拟主机（默认为/）设置用户对队列、交换器等资源的权限，命令为rabbitmqctl set_permissions -p virtual_host username “configure” “write” “read”。例如，为myuser用户在/虚拟主机上设置所有权限：rabbitmqctl set_permissions -p / myuser “.” “.” “.*”。
虚拟主机配置：虚拟主机用于将 RabbitMQ 的资源进行逻辑隔离。可以创建新的虚拟主机，使用命令rabbitmqctl add_vhost vhost_name，例如rabbitmqctl add_vhost myvhost。然后可以为虚拟主机分配用户权限，以确保不同的业务或应用之间的资源隔离和安全访问。

通过合理配置 RabbitMQ 的端口、用户权限和虚拟主机，可以使 RabbitMQ 在安全且高效的环境中运行，满足不同应用场景的需求。

文章版权归作者所有，未经允许请勿转载。

THE END