RabbitMQ 简介
RabbitMQ 是一个开源的、跨平台的消息队列中间件，基于 AMQP（高级消息队列协议）标准实现，由 Erlang 语言编写。它在分布式系统中广泛用于异步通信、解耦、流量削峰和任务分发。
简单来说，RabbitMQ 就像是一个'邮局'，负责在不同程序或服务之间可靠地传递消息。发送方（生产者）和接收方（消费者）无需直接交互，只需通过 RabbitMQ 进行中转。
核心功能与特点
- 消息存储与转发：生产者将消息发送到 RabbitMQ，它暂存并根据规则路由到对应的消费者。
- 多协议支持：虽然基于 AMQP，但也支持 MQTT、STOMP 等协议。
- 灵活的路由规则：通过交换机和队列的绑定关系，实现复杂的消息分发逻辑。
- 消息确认机制：确保消息不丢失，支持生产者确认和消费者确认。
- 高可用与集群：支持镜像队列和集群部署，保障服务可靠性。
它的核心优势在于解耦（生产者和消费者互不依赖）、异步通信（提高响应速度）、流量削峰（避免下游服务被压垮）以及跨语言/平台的支持。
核心概念
- 生产者（Producer）：发送消息的应用程序，将消息发布到交换机中。
- 消费者（Consumer）：接收消息的应用程序，从队列中获取并处理。
- 队列（Queue）：消息的存储容器，实际存放消息的地方。
- 交换机（Exchange）：接收生产者发送的消息，根据路由规则分发到不同的队列。常见类型包括 Direct（直连）、Topic（主题）、Fanout（广播）和 Headers（头部）。
- 绑定（Binding）：连接交换机和队列的规则，定义哪些消息应该被路由到哪个队列。
工作流程（以 Direct 交换机为例）
- 生产者将消息发送到指定的交换机，并指定路由键（例如
order.create）。 - 交换机根据绑定规则，将消息路由到对应的队列。
- 队列存储消息，等待消费者拉取。
- 消费者从队列中获取消息并处理。
安装与配置
1. 安装 RabbitMQ
在 Linux 环境下，可以使用以下命令安装：
sudo apt install rabbitmq-server
启动并检查状态：
# 启动服务
sudo systemctl start rabbitmq-server
# 查看状态（确保显示 active (running)）
sudo systemctl status rabbitmq-server
