rabbitmq不支持跨集群消息同步，但可通过联邦（面向交换器/队列元数据延伸，pull-based）和shovel（通用搬运，支持过滤/转换/跨协议）实现单向异步转发；二者均非强一致，不替代镜像队列，需配合幂等消费与tls加密。
RabbitMQ 本身不支持传统意义上的“集群间消息同步”（即跨集群复制队列内容或投递状态），但可通过 联邦（Federation） 和 Shovel 两种机制实现跨集群的消息流转，它们本质是**单向、异步、基于 AMQP 协议的转发**，而非强一致的实时同步。关键要区分：联邦面向交换器/队列元数据与消息路由逻辑的延伸；Shovel 更灵活，适用于任意源/目标，包括不同版本或协议的 broker。
联邦（Federation）：跨集群的逻辑拓扑延伸
联邦允许一个集群中的交换器或队列“连接”到另一个集群的上游交换器或队列，从而让消息自动从上游拉取（pull-based）。它不复制已有消息，只转发新到达的、符合绑定规则的消息。
- 启用插件：
rabbitmq-plugins enable rabbitmq_federation rabbitmq_federation_management - 配置上游（upstream）：在下游集群定义上游集群的 URI、认证、心跳等，例如：
{"uri": "amqp://user:pass@10.0.1.10:5672", "expires": 3600000} - 对交换器联邦：下游交换器声明为
federated类型，并绑定到上游交换器（通过federation-upstream参数指定） - 对队列联邦：需上游队列启用
queue-federated策略，并在下游队列设置x-federation-upstream参数指向已定义的 upstream
Shovel：通用消息搬运工，支持更复杂场景
Shovel 插件适合需要定制化转发逻辑的场景，比如跨版本、跨协议（AMQP 0.9.1 ↔ AMQP 1.0）、按条件过滤、或从队列到交换器的转换。它以消费者-生产者模式工作，持续从源拉取消息并推送到目标。
- 启用插件：
rabbitmq-plugins enable rabbitmq_shovel rabbitmq_shovel_management - 配置方式分静态（
shovel.conf）和动态（HTTP API 或管理界面），推荐用策略或 API 动态管理 - 关键参数包括：
sources（含 uri、queue、prefetch_count）、destinations（uri、exchange、routing_key）、ack_mode（on_publish或on_confirm） - 注意：Shovel 不保证 exactly-once，重试可能导致重复；建议配合幂等消费者使用
不能替代集群复制的常见误区
联邦和 Shovel 都不是镜像队列（Mirrored Queues）的跨集群版。镜像仅限同一集群内节点间高可用，而联邦/Shovel 是松耦合的广域网级集成方案。
- 消息不会反向同步：下游产生的消息默认不会回流上游
- 无事务/两阶段提交支持：无法保障跨集群的原子性操作
- 网络中断时消息暂存于上游队列，恢复后继续拉取；但若上游消息被消费或过期，则丢失
- 延迟不可避免：受网络往返、broker 负载、prefetch 设置影响，通常毫秒至秒级
选型建议与实用技巧
根据业务语义决定用联邦还是 Shovel：
- 若希望下游“透明接入”上游的交换器拓扑（如多区域共享同一事件总线），优先用 交换器联邦
- 若需过滤、重路由、格式转换、或对接非 RabbitMQ 系统（如 Kafka 消费端再转投 RabbitMQ），选 Shovel
- 生产环境务必配置 TLS 加密通信、合理设置
heartbeat和connection_timeout - 监控关键指标：shovel/federation link 状态、unacked 消息数、reconnect count —— 可通过
/api/federation-links或/api/shovelsREST 接口获取
