session连接
zookeeper客户端和服务端维持一个长连接，每隔10s向服务端发送一个心跳，服务端返回客户端一个响应。这就是一个session连接，拥有全局唯一的session id。session连接通常是一直有效，如果因为网络原因断开了连接，客户端会使用相同的session id进行重连。由于服务端保留了session的各种状态，尤其是各种瞬时节点是否删除依赖于session是否失效。
session失效问题
通常客户端主动关闭连接认为是一次session失效。另外也有可能因为其它未知原因，例如网络超时导致的session失效问题。在服务端看来，无法区分session失效是何种情况，一次一旦发生session失效，一定时间后就会将session持有的所有watcher以及瞬时节点删除。
而对于zookeeper客户端而言，一旦发生失效不知道是否该重连，这涉及到watcher和瞬时节点问题，因此zookeeper客户端认为，一旦发生了seesion失效，那么就认为客户端死掉了。从而所有操作都不能够进行。参考
凯发天生赢家一触即发官网的解决方案
对于只是简单查询服务的客户端而言，session失效后只需要重新建立连接即可。而对于需要处理瞬时节点以及各种watcher的服务来说，应用程序需要处理session失效或者重连带来的副作用。
下面的逻辑提供了一种简单的解决session重连的问题，这是指重新生成新的连接。
public static org.apache.zookeeper.zookeeper getzookeeper() {
if (zookeeper == null) {
synchronized (zookeeperclient.class) {
if (zookeeper == null) {
latch = new countdownlatch(1);
zookeeper = buildclient();//如果失败，下次还有成功的机会
long starttime = system.currenttimemillis();
try {
latch.await(30, timeunit.seconds);
} catch (interruptedexception e) {
e.printstacktrace();
} finally {
final socketaddress remoteaddres = zookeeper.testableremotesocketaddress();
system.out.println("[suc-core] local host: " zookeeper.testablelocalsocketaddress());
system.out.println("[suc-core] remote host: " remoteaddres);
system.out.println("[suc-core] zookeeper session id: " zookeeper.getsessionid());
final string remotehost = remoteaddres != null ? ((inetsocketaddress) remoteaddres).getaddress().gethostaddress() : "";
system.out.println("[suc-core] init cost: " (system.currenttimemillis() - starttime) "(ms) " remotehost);
latch = null;
}
}
}
}
return zookeeper;
}
上面的代码只是简单的使用一个double-check来维持zookeeper客户端的单实例。保证总是有机会重建客户端以及只有一个单例（这是因为zookeeper客户端是线程安全的）。
例外上面的例子中继承了org.apache.zookeeper.zookeeper类，以便能够拿到session对于的服务端ip地址以及客户端地址，方便调试问题。
在构建客户端的时候是需要设置session超时的时间，例如下面的代码就是30秒。
private static zookeeper buildclient() {
final string rootpath = getrootpath();
final string connectstring = systemconfig.getinstance().getstring("zookeeper.ips",//
"192.168.10.1:2181,192.168.10.2:2181,192.168.10.3:2181,192.168.10.4:2181,192.168.10.5:2181");
system.out.printf("[suc-core] rootpath: %1s\n", rootpath);
system.out.printf("[suc-core] connectstring:%1s\n", connectstring);
try {
return new zookeeper(connectstring rootpath, 30000, new sessionwatcher());
} catch (ioexception e) {
throw new runtimeexception("init zookeeper fail.", e);
}
}
为了处理连接建立成功以及断开问题，我们需要一个watcher来处理此问题。
static class sessionwatcherimplements watcher {
public void process(watchedevent event) {
if (event.getstate() == keeperstate.syncconnected) {
if (latch !=
null) {
latch.countdown();
}
}
else if (event.getstate() == keeperstate.expired) {
system.out.println("[suc-core] session expired. now rebuilding
");
//session expired, may be never happending.
//close old client and rebuild new client
close();
getzookeeper();
}
}
}
一旦检测到session失效了（expired)，那么久销毁已经建立的客户端实例，重新生成一个客户端实例。
/**
* 关闭zookeeper连接，释放资源
*/
public static void close() {
system.out.println("[suc-core] close");
if (zookeeper != null) {
try {
zookeeper.close();
zookeeper = null;
} catch (interruptedexception e) {
//ignore exception
}
}
}
这是一种简单的处理session expired问题的方法，显然这不会处理瞬时节点的问题，因此如果有相关的需求，业务系统（应用程序）需要自己修复问题。
测试方案
根据 提供的测试方法，写一个简单的例子试验下。
public static void main(string[] args) throws exception {
zookeeper zk = zookeeperclient.getzookeeper();
long sessionid = zk.getsessionid();
//
final string rootpath = zookeeperclient.getrootpath();
final string connectstring = systemconfig.getinstance().getstring("zookeeper.ips",//
"192.168.10.1:2181,192.168.10.2:2181,192.168.10.3:2181,192.168.10.4:2181,192.168.10.5:2181");
// close the old connection
new zookeeper(connectstring rootpath, 30000, null, sessionid, null).close();
thread.sleep(10000l);
//
// rebuild a new session
long newsessionid = zookeeperclient.getzookeeper().getsessionid();
// check the new session
string status = newsessionid != sessionid ? "ok" : "fail";
system.out.println(format("%s --> %s %s", sessionid, newsessionid, status));
// close the client
zookeeperclient.getzookeeper().close();
}
最后能够自动处理session expired的问题。实验中看到确实执行了session expired的逻辑重新生成了新的session。