Java高频面试题：Zookeeper集群数据是如何同步的？

大家好，我是锋哥。今天分享关于【Java高频面试题：Zookeeper集群数据是如何同步的？】面试题 。希望对大家有帮助；

Java高频面试题：Zookeeper集群数据是如何同步的？

1️⃣ Zookeeper 集群概念回顾

• Zookeeper 是一个分布式协调服务，通常用来管理配置、命名服务、分布式锁等。
• 集群模式下（称为ensemble），Zookeeper 集群通常由奇数个节点组成（3、5、7 节点最常见），保证多数派（quorum）原则。
• 每个节点都有完整的数据副本，称为ZNode 数据树。

所以核心问题是：多个副本如何保持一致？这就是 Zookeeper 的数据同步机制。

2️⃣ 数据同步的核心机制：Zab 协议

Zookeeper 使用Zab（ZooKeeper Atomic Broadcast）协议来保证数据一致性。Zab 是一种原子广播协议，类似于 Raft 或 Paxos。它的核心作用是保证所有事务（写操作）在集群节点中按相同顺序执行。

2.1 节点角色

• Leader：负责接收客户端写请求，生成事务 ID（zxid），广播给 Follower。
• Follower：接收 Leader 的事务提议（proposal），同步到本地数据。
• Observer（可选）：不参与投票，但接收数据更新，减少负载。

3️⃣ 数据同步流程（写操作）

假设客户端向集群写入数据（比如创建一个 znode），整个同步流程如下：

步骤 1：客户端请求写操作

• 客户端连接到任意节点（Leader 或 Follower）。
• 如果连接到 Follower，Follower 会转发请求给 Leader。

步骤 2：Leader 生成事务 ID（zxid）

• 每个写操作都会分配一个全局递增的 zxid（事务 ID）。
• zxid 保证了集群中的操作顺序。

步骤 3：Leader 广播提议（Proposal）

• Leader 将事务提议广播给所有 Follower。
• 这叫“提议阶段”（proposal phase）。

步骤 4：Follower 记录提议

• Follower 收到提议后，会写入本地事务日志（transaction log）。
• 然后向 Leader 发送ACK确认。

步骤 5：Leader 等待多数 ACK

• Leader 等到大多数节点（quorum）确认。
• 一旦获得多数 ACK，Leader 就发送COMMIT 指令。

步骤 6：Follower 应用事务

• Follower 收到 COMMIT 后，将事务写入内存数据树。
• 同时写入本地磁盘快照和日志。
• 此时事务完成，客户端收到响应。

⚡ 关键点：写操作只有在多数派确认后才算完成。这保证了即使部分节点宕机，集群数据依然一致。

4️⃣ 数据同步（Follower 启动或滞后同步）

有两种情况需要同步：

4.1 新节点加入

• 新节点启动时，需要全量同步（snapshot）Leader 的当前数据树。
• 先从 Leader 拷贝最新快照（snapshot），然后从日志中应用增量事务。

4.2 节点滞后

• 如果某个 Follower 落后，它会向 Leader 请求缺失的事务记录。
• Leader 将这些缺失的事务发送给 Follower，Follower 按顺序应用。
• 这叫同步补全（catch-up）。

5️⃣ 读操作的同步

• 默认读操作可以由任何节点直接返回最新的数据，称为最终一致性读。
• 如果需要强一致性读，可以客户端请求Leader读取，保证返回最新提交的事务。

6️⃣ 数据持久化与恢复

• Zookeeper 会将事务日志写入磁盘。
• 定期生成快照（snapshot），减少恢复时的日志重放量。
• 集群重启或节点故障时，可以从快照 + 日志恢复数据。

7️⃣ 总结

1. Zookeeper 的数据同步靠Zab 协议实现原子广播。
2. 写操作经过Leader 提议 → Follower ACK → Leader COMMIT → Follower 应用流程。
3. 集群保证多数派提交，确保一致性。
4. 节点启动或滞后时可以通过全量或增量同步追赶数据。
5. 读操作可弱一致或强一致。