Exchanger用于双机热备心跳状态对调，核心是两节点周期性交换健康状态，但仅作轻量级握手同步，需配合ZooKeeper等机制实现完整高可用。
Java 中用 Exchanger 配合定时线程池实现双机热备的心跳状态对调，核心思路是：两台服务节点（A 和 B）周期性地通过 Exchanger 交换各自当前的健康状态（如是否存活、负载、版本号等），从而快速感知对方状态变化，辅助故障转移决策。但需注意：Exchanger 本身不解决高可用、网络分区或主从选举问题，它只是轻量级状态同步工具，必须配合其他机制（如 ZooKeeper、数据库选主、或应用层心跳超时判定）才能构成完整热备方案。
1. Exchanger 的作用与适用边界
Exchanger<T> 是一个用于两个线程之间**成对同步交换数据**的阻塞协调器。在双机热备场景中，它天然适配“两节点互换状态”这一语义：
- 每次交换必须由双方线程同时调用
exchange()才能完成；任一方超时或中断，另一方会抛出异常或阻塞等待（取决于是否设超时）。 - 它不保证状态最终一致，也不重试或持久化——仅做一次“握手式”交换，适合低延迟、高频率、轻量级的状态快照传递。
- 不能用于多节点或动态扩缩容场景；若某节点宕机，另一节点的
exchange()将一直阻塞（除非设超时），需靠定时任务自身的异常处理兜底。
2. 定时线程池 + Exchanger 的典型结构
每台机器启动一个独立的定时任务，固定周期（如 2 秒）执行一次状态交换：
- 本地构建当前心跳状态对象（如
HeartbeatStatus），含时间戳、本机 IP、健康标记、序列号等。 - 调用
exchanger.exchange(localStatus, 3, TimeUnit.SECONDS)—— 设置合理超时（略大于间隔），避免单点卡死拖垮整个调度。 - 捕获
TimeoutException或InterruptedException，视为对端失联，触发本地降级逻辑（如切换为“主”角色、告警、关闭写入等）。 - 成功交换后，更新本地缓存的对端状态，并根据双方状态做业务判断（例如：仅当双方都健康时维持双写；一方异常则自动切流）。
3. 关键代码示意（简化版）
假设两节点共用同一个 Exchanger<HeartbeatStatus> 实例（可通过共享内存、RPC、或 Spring Bean 注入等方式传递；实际部署中更推荐基于 Netty/HTTP 的轻量 RPC 代替共享 Exchanger，因 JVM 隔离限制）：
立即学习“Java免费学习笔记（深入）”；
// 状态类（需序列化，若跨 JVM 则必须走网络）
public class HeartbeatStatus implements Serializable {
private String host;
private long timestamp;
private boolean isHealthy;
private int version;
}
// 定时任务（每台机器各运行一份）
ScheduledExecutorService scheduler = Executors.newSingleThreadScheduledExecutor();
Exchanger<HeartbeatStatus> exchanger = new Exchanger<>();
scheduler.scheduleAtFixedRate(() -> {
HeartbeatStatus local = new HeartbeatStatus()
.setHost("192.168.1.10") // 本机IP
.setTimestamp(System.currentTimeMillis())
.setHealthy(checkLocalHealth()) // 自检逻辑
.setVersion(1);
try {
HeartbeatStatus remote = exchanger.exchange(local, 3, TimeUnit.SECONDS);
updateRemoteStatus(remote); // 更新对端状态缓存
if (!remote.isHealthy()) {
triggerFailover(); // 启动本地接管流程
}
} catch (TimeoutException e) {
log.warn("No response from peer, assuming offline");
handlePeerLost();
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
}
}, 0, 2, TimeUnit.SECONDS);
4. 生产注意事项
- 不要跨 JVM 共享 Exchanger 实例：Exchanger 是 JVM 内存级同步工具，无法跨进程。真实双机部署必须改用 TCP/HTTP/RPC 实现类似语义（如 A 调用 B 的 /heartbeat 接口传状态并获取 B 的状态）。
- 状态交换 ≠ 故障转移决策：仅靠一次交换失败不能立即切主，应累积 N 次超时、结合本地探活（如 ping、端口检测）、日志水位等多维度判断，防止误切。
- 避免状态对象过大或耗时构造：心跳交换应在毫秒级完成，状态对象建议扁平、只含必要字段，禁止在 exchange 前做 DB 查询或远程调用。
- 超时设置要谨慎：超时值应略大于网络 RTT + 本地处理耗时（如 3s），太短易抖动，太长影响故障发现速度。
