RabbitMQ

RabbitMQ 是一个开源的消息队列和流媒体代理，由 Broadcom 提供企业级商业支持。它支持 AMQP 1.0、MQTT 5.0 等多种开放协议，并拥有丰富的客户端库，兼容多种编程语言。RabbitMQ 以高可靠性、灵活性和可扩展性著称，被全球数百万开发者用于构建分布式系统。

核心功能

• 消息路由与过滤：通过交换机、队列和绑定键实现灵活的消息分发，支持直接、主题、扇形等路由模式。
• 多种协议支持：原生支持 AMQP 0-9-1、AMQP 1.0、MQTT 5.0、STOMP 等，确保异构系统互操作性。
• 集群与高可用：支持镜像队列和仲裁队列，可在集群间复制消息以保障数据安全。
• 流式处理：引入流队列，支持大规模事件驱动和实时数据管道，消费者可回溯或并发读取。
• 管理与监控：提供 Web 管理界面和 REST API，集成 Prometheus、Grafana 等监控工具。

适用场景

• 微服务解耦：异步通信，削峰填谷，提升系统弹性。
• 任务调度：将耗时任务放入队列，后台 Worker 异步处理。
• RPC 调用：利用请求-回复模式实现同步调用。
• 流处理：适用于日志聚合、指标收集和事件溯源。
• IoT：支持大量并发连接，结合 MQTT 协议处理设备数据。

使用方式

下载并安装 RabbitMQ 服务器，或使用 Docker 容器运行。通过 Web 管理界面或命令行启用管理插件。在应用中集成官方客户端库（如 Java、Python、.NET 等）进行生产/消费消息。根据需求配置交换机、队列和绑定关系，设置死信队列、延迟队列等高级特性。

注意事项

默认客户端使用 5672 端口，管理界面使用 15672 端口，需在防火墙中开放。集群部署时应使用仲裁队列代替镜像队列以获取更好性能。消息持久化会降低吞吐量，需在可靠性中权衡平衡。