java中zookeeper会话过期时抛出keeperexception.sessionexpiredexception，需捕获该异常或监听watcher.event.keeperstate.expired事件，且必须关闭旧实例并重建连接，临时节点将被自动删除。
Java 中 ZooKeeper 并不会直接抛出名为 ZooKeeperSessionExpiredException 的异常——这个类并不存在于官方 ZooKeeper 客户端（org.apache.zookeeper）中。
实际会话过期时抛出的异常类型
当 ZooKeeper 会话超时（session expired），客户端在尝试执行操作（如 getData()、create()、exists() 等）时，会抛出 KeeperException.SessionExpiredException，它是 KeeperException 的子类。
注意：SessionExpiredException 是运行时异常（非检查型），但它的父类 KeeperException 是检查型异常，所以调用 ZooKeeper API 仍需处理或声明 KeeperException 及其子类。
如何识别和处理会话过期
- 捕获
KeeperException.SessionExpiredException：这是最直接的判断方式 - 监听
Watcher.Event.KeeperState.Expired：在 Watcher 的process()方法中，若收到状态为Expired的事件，说明会话已不可用，后续所有操作都会失败 - 检查
ZooKeeper.getState()：返回CONNECTED、EXPIRED等枚举值；会话过期后状态变为EXPIRED
典型错误处理示例
以下代码演示了如何安全地处理会话过期：
zooKeeper.exists("/path", false, (rc, path, ctx) -> {
if (rc == KeeperException.Code.SESSIONEXPIRED.intValue()) {
// 异步回调中检测到会话过期
System.err.println("Session expired in async callback");
// 应重建 ZooKeeper 实例
}
}, null);
同步调用示例：
try {
zooKeeper.getData("/path", false, null);
} catch (KeeperException.SessionExpiredException e) {
System.err.println("Session expired: " + e.getMessage());
// 必须关闭旧实例并创建新连接
zooKeeper.close();
zooKeeper = new ZooKeeper(connectString, sessionTimeout, watcher);
} catch (KeeperException | InterruptedException e) {
// 其他异常处理...
}
关键注意事项
- 会话过期后，ZooKeeper 实例不可恢复，必须新建实例，不能重连
- Watchers 不会自动重注册，重建连接后需重新设置监听
- 临时节点（Ephemeral Nodes）会在会话过期时被服务端自动删除
- 不要依赖
InterruptedException或ConnectionLossException判断过期——它们只表示连接中断，不等于会话已过期
Java免费学习笔记：立即使用
解锁 Java 大师之旅：从入门到精通的终极指南
