解耦互联服务

假设您有一个后端服务需要向最终用户发送通知。目前有两种通知渠道：电子邮件和移动端推送通知。

后端将通知发布到两个队列，每个渠道一个。负责管理邮件和推送通知的程序订阅它们感兴趣的队列，并在通知到达时立即进行处理。

➡ 优势

• RabbitMQ 可以缓冲负载峰值。
• 您可以在不中断整个服务的情况下，对通知管理器进行维护。

远程过程调用 (RPC)

假设您经营一家音乐厅。演出门票通过多个网站和实体售票亭销售。所有渠道的订单必须经过复杂处理，以根据余票情况确定客户是否成功购票。网站或售票亭要求以极短的时间获得订单响应。

订单被发布到带有关联 ID (Correlation ID) 的 RabbitMQ 队列中。推送订单的调用者随后订阅另一个队列，并等待带有相同关联 ID 的回复。

为了实现低延迟，经典队列 (Classic Queue) 是不错的选择，但它牺牲了一定的安全性——调用者仍需具备重试机制。如果订单绝对不能丢失，您可能更倾向于结合使用确认机制和仲裁队列 (Quorum Queues)，以确保消息在确认后是安全的。

这种拓扑结构允许订单处理序列化，从而实现“先到先得”的服务顺序，从而无需使用事务。

➡ 优势

• RabbitMQ 客户端可以同时充当发布者和消费者。
• RabbitMQ 可用于分发 RPC 调用。

流处理

假设您运营一个视频平台。当用户上传新视频并安全存储后，您需要完成多项任务：运行上传后分析、转码出低画质版本、通知订阅了作者的其他用户等。

上传服务将“新视频”事件追加到 RabbitMQ 流 (Stream) 中。多个后端应用可以独立订阅该流并读取新事件。用户需要立即收到通知，但上传后分析可以稍后在每天一次的批处理中执行。

➡ 优势

• 流非常高效，且无需复制消息。
• 消费者可以在流中前后切换，即使存在多个并发消费者也互不影响。

物联网 (IoT)

假设您提供跨星系的包裹递送服务。您拥有一群太空无人机，需要定期将状态上报给位于 Kepler-438 b 系外行星上的服务器。遗憾的是，网络连接状况并不理想……

每架太空无人机都运行一个本地 RabbitMQ 独立节点，用于缓存上报数据，直到能够与上游 RabbitMQ 建立连接。

当行星对齐（连接恢复）时，无人机的 RabbitMQ 会将所有报告“铲”（Shovel）送至上游 RabbitMQ。

➡ 优势

• 通过使用 Shovel 和 Federation 等功能，RabbitMQ 的部署方式可以串联起来，以满足服务的各种需求。
• MQTT 非常适合处理数百万级的并发连接。