RabbitMQ 核心概念与架构
RabbitMQ 是一个开源的、跨平台的消息队列中间件，基于 AMQP（高级消息队列协议）标准实现。它广泛应用于分布式系统中，负责实现异步通信、解耦、流量削峰和任务分发等功能。
简单来说，RabbitMQ 就像一个邮局，在不同程序或服务之间可靠地传递消息。发送方（生产者）和接收方（消费者）无需直接交互，只需通过 RabbitMQ 进行中转。
核心功能与特点
核心功能
- 消息存储与转发：生产者将消息发送到 RabbitMQ，系统暂存并根据规则路由到对应的消费者。
- 多协议支持：虽然基于 AMQP，但也支持 MQTT、STOMP 等协议，适配不同场景。
- 灵活的路由规则：通过交换机和队列的绑定关系，实现复杂的消息分发逻辑。
- 消息确认机制：确保消息不丢失，支持生产者确认和消费者确认。
- 高可用与集群：支持镜像队列和集群部署，保障服务可靠性。
核心优势
- 解耦：生产者和消费者互不感知，降低模块依赖。
- 异步通信：发送后无需等待处理结果，提高响应速度。
- 流量削峰：突发流量时暂存消息，避免下游服务崩溃。
- 可靠性：支持持久化、重试和死信队列机制。
- 跨语言/平台：提供多种语言客户端，适配不同技术栈。
核心概念解析
- 生产者（Producer）：发送消息的应用程序，将消息发布到交换机。
- 消费者（Consumer）：接收消息的应用程序，从队列中获取并处理。
- 队列（Queue）：消息的存储容器，实际存放消息的地方。
- 交换机（Exchange）：接收消息并根据路由规则分发给队列。常见类型包括 Direct（直连）、Topic（主题）、Fanout（广播）和 Headers（头部）。
- 绑定（Binding）：连接交换机和队列的规则，定义哪些消息应被路由到哪个队列。
工作流程示例
以 Direct 交换机为例：
- 生产者将消息发送到指定交换机，并指定路由键（如
order.create）。 - 交换机根据绑定规则将消息路由到匹配的队列。
- 队列存储消息，等待消费者拉取。
- 消费者获取消息并进行业务处理。
环境搭建与安装
Linux 下安装 RabbitMQ
1. 安装服务
sudo apt install rabbitmq-server
2. 启动与状态检查
sudo systemctl start rabbitmq-server
sudo systemctl status rabbitmq-server
确保状态显示为 active (running)。
3. 创建管理员用户
默认 guest 用户权限较低，建议创建专用管理员。
sudo rabbitmqctl add_user root 123456
rabbitmqctl set_user_tags root administrator
rabbitmqctl set_permissions -p / root
