什么是 RabbitMQ？

RabbitMQ 是一个广泛使用的开源消息代理软件，旨在实现消息的可靠传递和分发。它由 Pivotal 公司基于 Erlang 语言开发，支持 AMQP（Advanced Message Queuing Protocol）协议。

RabbitMQ 在分布式系统中扮演着消息中间件的角色，帮助不同的应用程序和服务之间进行异步通信。

RabbitMQ 提供高效、可靠的消息传递，支持多种模式如点对点、发布/订阅等。其功能包括消息持久化、确认机制、灵活路由和多协议支持，广泛应用于企业级解决方案。

核心特性

1. 可靠性保证

持久化机制：支持消息和队列持久化到磁盘。
消息确认：ACK 机制确保消息处理的可靠性。
发布确认：Publisher Confirms 保证消息发送可靠性。
高可用性：支持镜像队列、主从架构、集群部署。

2. 灵活的消息路由

多种交换机类型：
- Direct Exchange：直接匹配。
- Topic Exchange：模式匹配。
- Fanout Exchange：广播模式。
- Headers Exchange：属性匹配。
绑定(Binding)机制：灵活的消息路由规则。

3. 多协议支持

AMQP（核心协议）
MQTT（物联网场景）
STOMP（简单文本协议）
HTTP（REST API）
WebSocket（Web 实时通信）

4. 管理与监控

可视化管理界面
完善的监控指标
丰富的管理 API
细粒度的权限控制

核心组件

1. Producer（生产者）

描述：发送消息到 RabbitMQ。

2. Exchange（交换机）

描述：接收生产者发送的消息，并根据路由规则将消息分发到队列中。
类型：
- Direct：基于完全匹配的路由键。
- Fanout：广播消息到所有绑定的队列。
- Topic：基于模式匹配的路由键。
- Headers：基于消息头的属性。

3. Queue（队列）

描述：存储消息，等待消费者处理。

4. Consumer（消费者）

描述：从队列中接收并处理消息。

5. Binding（绑定）

描述：连接交换机和队列，定义消息路由规则。

6. Routing Key（路由键）

描述：消息的标签，用于交换机将消息路由到正确的队列。

7. RabbitMQ Broker

描述：核心服务，管理消息的接收、路由和传递。

工作原理

消息生产：
- 生产者创建消息并发送到 RabbitMQ。
- 消息通过网络连接到达 RabbitMQ Broker。
消息路由：
- 交换机根据绑定和路由键决定消息的去向。
- 消息被路由到一个或多个队列。
消息存储：
- 队列负责存储消息，直到消费者准备好处理。
- 支持持久化以防止数据丢失。
消息消费：
- 消费者从队列中获取消息进行处理。
- 处理完成后，消费者发送确认（ACK）以告知 RabbitMQ 消息已成功处理。
消息确认与重发：
- 如果消费者未能确认消息，RabbitMQ 可以重新投递消息。
- 支持死信队列（DLQ）处理无法投递的消息。

应用场景

1. 异步处理

RabbitMQ 作为成熟的企业级消息中间件，在众多领域都有广泛应用：

金融行业：订单处理、支付流程、风控系统。
电商领域：订单系统、库存系统、物流系统。
物联网：设备通信、数据采集、实时监控。
社交应用：消息推送、通知系统。
视频服务：视频转码、弹幕系统。

2. 系统解耦

服务间通信：微服务架构中的异步通信。
事件驱动：基于事件的系统集成。
数据同步：跨系统数据一致性维护。

3. 流量控制

削峰填谷：处理突发流量。
限流保护：保护系统稳定性。
任务调度：分布式任务处理。