前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >ZooKeeper会话到期后自动重连

ZooKeeper会话到期后自动重连

作者头像
十毛
发布2019-03-27 15:11:12
5.5K0
发布2019-03-27 15:11:12
举报
文章被收录于专栏:用户1337634的专栏

因为网络问题ZK客户端会与服务器断开连接,如果断开时间超过sessionTimeout后,会话会被服务器清空,即使之后连接恢复,也没办法恢复会话了。这样就会导致客户端一直不能与ZK服务器通信。 本文通过监听事件,并重新建立ZK客户端的方式恢复与ZK服务器的连接。

遇到的问题

项目中有的服务器会断开与ZooKeeper服务器的连接(临时节点消失),客户端一般会出现如下日志:

代码语言:javascript
复制
21:16:31  [ main-SendThread(192.168.58.100:2181):4000645 ] - [ WARN ]  Client session timed out, have not heard from server in 15526ms for sessionid 0x16797e426b8000e
21:16:31  [ main-SendThread(192.168.58.100:2181):4000645 ] - [ INFO ]  Client session timed out, have not heard from server in 15526ms for sessionid 0x16797e426b8000e, closing socket connection and attempting reconnect
21:16:31  [ main-SendThread(192.168.58.100:2181):4000905 ] - [ INFO ]  Socket connection established to 192.168.58.100/192.168.58.100:2181, initiating session
21:16:31  [ main-SendThread(192.168.58.100:2181):4000906 ] - [ WARN ]  Unable to reconnect to ZooKeeper service, session 0x16797e426b8000e has expired
21:16:31  [ main-SendThread(192.168.58.100:2181):4000906 ] - [ INFO ]  Unable to reconnect to ZooKeeper service, session 0x16797e426b8000e has expired, closing socket connection
21:16:31  [ main-EventThread:4000906 ] - [ INFO ]  EventThread shut down for session: 0x16797e426b8000e
  • 原因分析

ZK客户端因为网络抖动等原因与服务器断开连接,如果在sessionTimeout时间内重新连接上,则会话继续,状态为CONNECTED。但是如果时间超过sessinTimeout,服务器则会进行会话的清理工作,如果此时ZK客户端才恢复连接,则会收到State为Expired的 WatchedEvent,并断开与服务器的连接。

解决办法

当监听器Watcher收到Expired事件后,重新建立ZooKeeper客户端。如下:

代码语言:javascript
复制
@Override
public void process(WatchedEvent watchedEvent) {
    if (watchedEvent.getState() == Event.KeeperState.Expired) {
        try {
            zooKeeper = new ZooKeeper("192.168.58.100:2181", 3000, this);
        } catch (IOException e) {
            log.warn("fail to connect to zoo keeper", e);
        }
    }
}

完整代码如下:

代码语言:javascript
复制
import org.apache.zookeeper.ZooKeeper;

import java.io.IOException;

@Slf4j
public class App implements Watcher
{
    private static ZooKeeper zooKeeper = null;

    public static void main( String[] args ) throws IOException, InterruptedException {
        final App app = new App();
        zooKeeper = new ZooKeeper("192.168.58.100:2181", 3000, app);
        for (int i = 0; i < 15000; i++) {
            Thread.sleep(1000);
        }
    }

    @Override
    public void process(WatchedEvent watchedEvent) {
        if (watchedEvent.getState() == Event.KeeperState.Expired) {
            try {
                zooKeeper = new ZooKeeper("192.168.58.100:2181", 3000, this);
            } catch (IOException e) {
                log.warn("fail to connect to zoo keeper", e);
            }
        }
    }
}

参考

本文参与 腾讯云自媒体同步曝光计划,分享自作者个人站点/博客。
原始发表:2018.12.27 ,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体同步曝光计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
目录
  • 遇到的问题
  • 解决办法
  • 参考
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档