ZooKeeper 临时节点在会话结束后的行为及 Watch 机制处理 -

题目

ZooKeeper 临时节点在会话结束后的行为及 Watch 机制处理

信息

类型：问答
难度：⭐⭐

考点

临时节点特性,会话管理,Watch机制

快速回答

当 ZooKeeper 客户端会话结束时：

会话创建的所有临时节点会被自动删除
该会话注册的Watcher会被自动移除
删除临时节点会触发其他客户端在该节点上设置的 Watcher
会话超时时间由客户端创建时指定，服务端通过心跳检测维护

## 解析

1. 核心原理说明

临时节点（Ephemeral Nodes）是 ZooKeeper 的重要特性：

生命周期与会话绑定，会话结束（主动断开或超时）时自动删除
不能有子节点，常用于实现分布式锁、服务注册等场景

会话管理机制：

客户端通过心跳（ping）维持会话（默认心跳间隔 2s）
服务端会话超时时间 = min(sessionTimeout, 2 * tickTime)
会话状态变化：CONNECTING → CONNECTED → CLOSED/EXPIRED

Watch 触发逻辑：

临时节点删除触发 NodeDeleted 事件
Watcher 是一次性的（除持久递归 Watcher）

2. 代码示例

Java 客户端观察临时节点：

// 创建会话（会话超时 5s）
ZooKeeper zk = new ZooKeeper("localhost:2181", 5000, watchedEvent -> {
    if (watchedEvent.getType() == Event.EventType.NodeDeleted) {
        System.out.println("临时节点被删除: " + watchedEvent.getPath());
    }
});

// 创建临时节点
String path = zk.create("/ephemeral_node", "data".getBytes(), 
    ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL);

// 在其他客户端设置 Watcher
zk.exists(path, true); // 注册节点删除监听

// 主动关闭会话（触发节点删除）
zk.close(); // 此时其他客户端会收到 NodeDeleted 事件

3. 最佳实践

会话超时设置：推荐 5-20s，过长导致故障检测延迟，过短易误判
Watcher 使用：
- 处理事件后需重新注册 Watcher
- 使用 Curator 等框架简化 Watcher 管理
临时节点应用：
- 分布式锁：利用节点唯一性
- 服务注册：临时节点代表服务实例，会话断开自动注销

4. 常见错误

误用持久节点：服务注册场景使用持久节点导致僵尸节点
忽略 SessionExpired：未处理 KeeperState.Expired 事件导致状态不一致
Watcher 丢失：未在事件回调中重新注册 Watcher
心跳阻塞：主线程长时间阻塞导致心跳失败（解决方案：用独立线程处理耗时操作）

5. 扩展知识

会话转移（Session Moved）：客户端重连到不同服务端时，会话 ID 保持不变
临时节点与 SEQUENTIAL 标志组合：创建有序临时节点（如 /lock/lock-00000001）
Watch 类型对比：
类型特性触发条件
一次性 Watcher 默认类型，触发后失效 exists/getData/getChildren
持久 Watcher 永久有效（API 4.0+） addWatch() 注册
ZooKeeper 集群角色：Leader 处理写请求，Follower 处理读请求和参与选举