什么是 RabbitMQ？
RabbitMQ 是一个的开源消息代理软件，旨在实现消息的可靠传递和分发。它由 Pivotal 公司基于 Erlang 语言开发，支持 AMQP（Advanced Message Queuing Protocol）协议。
主要特性
可靠性
- 支持消息持久化（持久化队列和消息）。
- 提供消息确认机制（ACK/NACK）。
- 提供高可用性队列（HA queues）。
灵活路由
- 支持多种交换器类型，满足不同场景下的路由需求。
支持多种协议
- 默认支持 AMQP，还支持 MQTT、STOMP 等协议。
易扩展性
- 支持集群部署和分布式架构。
多语言支持
- 提供多种语言客户端库，如 Java、Python、Go、C# 等。
监控与管理
- 提供强大的管理界面和命令行工具，支持插件扩展。
核心组件
Producer（生产者）
- 负责发送消息到 RabbitMQ 的应用程序。生产者将消息发送到特定的交换机（Exchange）。
Exchange（交换机）
- 接收来自生产者的消息，并根据一定的路由规则将消息转发到一个或多个队列。
- RabbitMQ 支持多种类型的交换机，包括 Direct、Fanout、Topic 和 Headers。
Queue（队列）
- 存储消息的地方，消费者从队列中获取消息进行处理。队列是 RabbitMQ 的核心组件之一，确保消息的可靠传递。
Consumer（消费者）
- 从队列中接收和处理消息的应用程序。消费者可以是单个应用程序，也可以是多个应用程序的组合。
Binding（绑定）
- 用于将交换机和队列连接起来的规则。绑定定义了消息如何从交换机路由到队列。
Message（消息）
- 在 RabbitMQ 中传递的数据单元，包含了实际的数据内容和一些元数据。
Routing Key（路由键）
- 消息从交换机路由到队列时使用的关键字。
Virtual Host（虚拟主机）
- RabbitMQ 中的逻辑隔离单位，包含独立的交换机、队列和绑定。
- 拥有独立的权限控制，不同虚拟主机之间完全隔离。
- 默认为 "/"。
Channel（信道）
- 一个 TCP 连接内的轻量级逻辑连接，供生产者或消费者使用。
工作流程
生产者（Producer）发送消息到交换机（Exchange）
交换机根据绑定关系（Binding）和路由规则（Routing）将消息分发给相应的队列（Queue）
消息存储在队列中等待被消费
消费者（Consumer）以下两种方式之一获取消息：
- 推送模式：消息代理主动将消息推送给订阅的消费者
- 拉取模式：消费者主动从队列中拉取消息
常见应用场景
- 异步任务处理
- 将耗时操作异步化，提升系统响应速度
- 典型场景：订单处理、邮件发送、短信通知等
- 优势：提高用户体验，系统吞吐量提升
- 系统解耦
- 通过消息队列实现系统间的松耦合
- 各子系统独立演进，互不影响
- 便于系统扩展和维护
- 流量削峰填谷
- 应对突发流量，保护后端系统
- 通过队列缓冲，平滑处理请求
- 避免系统过载，提高稳定性
- 日志聚合
- 统一收集分布式系统的日志
- 集中处理和分析
- 便于问题排查和监控
- 事件驱动架构
- 实现微服务间的事件通知
- 支持复杂业务流程的解耦
- 提高系统的可扩展性和维护性