rabbitmq federation 实现跨机房消息同步的核心在于服务端配置而非 java 代码，java 应用只需按常规方式访问本地交换器和队列；需在上下游节点启用插件、保持 vhost/交换器/队列名称一致、下游配置 upstream 和匹配 policy，生产者发消息到本地交换器即自动同步，消费者可选择本地消费同步副本或上游消费原始消息。
Java 应用通过 RabbitMQ Federation 插件实现跨机房消息同步，核心不是在 Java 代码里“写同步逻辑”，而是先在 RabbitMQ 服务端正确配置 Federation，再让 Java 生产者/消费者像访问本地队列一样自然收发——Federation 在后台自动完成跨机房消息流转。关键在于服务端配置要对，Java 端只需按常规方式操作本地交换器和队列。
服务端必须提前配好 Federation（Java 不参与这步）
Federation 是 RabbitMQ 插件行为，Java SDK 本身不感知联邦。必须在目标机房（下游，如深圳）的 RabbitMQ 节点上完成以下配置：
- 启用插件：
rabbitmq-plugins enable rabbitmq_federation rabbitmq_federation_management（两台机房节点都要执行） - 确保上下游 vhost 名称、交换器名、队列名完全一致（例如都叫
/prod、fed.direct、order.queue） - 在下游节点（深圳）配置 upstream：填写上游节点（北京）的 AMQP 地址，如
amqp://admin:pass@10.1.2.100:5672 - 添加 Policy：匹配需要联邦的资源，例如 pattern
^fed\.，定义为federation-upstream类型，指定 upstream 名称
Java 生产者发消息：只连本地 broker，无需改代码
深圳的业务系统（Java）仍连接深圳本地的 RabbitMQ，像往常一样发消息到本地交换器即可：
Alibabacloud Sdk Client Initialization For Java
下载
在 Java 中初始化和管理阿里云 SDK客户端。包括单例模式、线程安全、endpoint 与 region 配置、VPC 终端节点、同步与异步等。
- 创建连接时 host 填深圳节点 IP（如
10.1.2.200），不是北京节点 - 声明交换器
fed.direct（与北京同名）、发布消息带 routing key（如order.created） - Federation 插件会自动捕获该消息，通过 upstream 连接转发到北京的同名交换器
Java 消费者收消息：可选择本地或远程消费
有两种典型模式，Java 侧写法不同：
-
下游消费（推荐）：深圳消费者连深圳 broker，绑定本地队列
order.queue到fed.direct。Federation 已将北京产生的消息同步过来，深圳消费者直接消费本地副本，低延迟 - 上游消费：北京消费者连北京 broker，消费原始消息；深圳消费者若也想读同一份数据，需额外在深圳声明同名队列并绑定——Federation 不自动创建下游队列，需手动声明或靠 Policy 触发自动创建
验证与常见问题
配置生效后，可通过管理界面检查 Federation link 状态（绿色表示连接正常），并在上下游分别查看队列消息数是否趋同。注意：
- 消息是单向异步复制，不保证强实时（通常毫秒级延迟）
- 上游交换器类型需支持绑定（如 direct、topic），fanout 也可用但 routing key 无意义
- 若 Java 报连接拒绝或 404，大概率是 vhost 不一致、用户权限不足（需 administrator 或对应 vhost 权限），或 Policy 未生效
Java免费学习笔记：立即使用
解锁 Java 大师之旅：从入门到精通的终极指南
