ZooKeeper的会话分桶策略

分桶策略:

ZooKeeper的会话管理主要是由SessionTracker负责的,其采用了一种特殊的会话管理方式,称其为“分桶策略”。所谓分桶策略,是将超时时间相近的会议放到同一个桶中来进行管理,以减少管理的复杂度。在检查超时的会话时,只需要检查桶中剩下的会话即可(没有被转移走的会话全是超时的)。

会话超时时间的计算方法如下:

   long expireTime = roundToInterval(System.currentTimeMillis() + timeout);

 

   private long roundToInterval(long time) {

       // We give a one interval grace period

       return (time / expirationInterval + 1) * expirationInterval;

    }

可见,超时检查的粒度就是expirationInterval,以这个粒度为单位,就可以分成多个桶,同一个桶中存放着超时时间一致的会话。

会话激活:

有了桶之后,接下来就是激活。每次客户端和ZooKeeper服务器之间有通信时,会话就会被激活,会话的超时时间就会被重新计算,然后会话就会被放到其他的桶中。顺便说一句,每个桶就是一个Set,SessionTracker还维护了另外一个Map:

HashMap sessionSets= new HashMap();

sessionSets存放超时时间到桶的映射。这样通过某个超时时间,就可以获取这个时间超时的所有会话了。这样一次可以检查多个会话。

会话检查:

   @Override

    synchronizedpublic void run() {

       try {

           while (running) {

                currentTime =System.currentTimeMillis();

                if (nextExpirationTime >currentTime) {

                   this.wait(nextExpirationTime - currentTime);

                    continue;

                }

                SessionSet set;

                set =sessionSets.remove(nextExpirationTime);

                if (set != null) {

                    for (SessionImpl s :set.sessions) {

                       setSessionClosing(s.sessionId);

                        expirer.expire(s);

                    }

                }

                nextExpirationTime +=expirationInterval;

           }

       } catch (InterruptedException e) {

            handleException(this.getName(), e);

       }

       LOG.info("SessionTrackerImpl exited loop!");

    }

从源代码中可以看出,分桶后,每次把一个桶中剩下的会话全认为是超时的即可(不超时的会话会被移走)。检查一个桶后,经过expirationInterval时间后,再检查下一个桶。
ZooKeeper的会话分桶策略,在一些需要管理大量超时会话的场景下,会非常有用。​

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容

  • 本文将从系统模型、序列化与协议、客户端工作原理、会话、服务端工作原理以及数据存储等方面来揭示ZooKeeper的技...
    端木轩阅读 3,849评论 0 42
  • Spring Cloud为开发人员提供了快速构建分布式系统中一些常见模式的工具(例如配置管理,服务发现,断路器,智...
    卡卡罗2017阅读 135,026评论 19 139
  • ZooKeeper 分布式过程协同技术详解 简介 分布式系统 分布式系统是同时跨越多个物理主机, 独立运行的多个软...
    鲁云飞_阅读 2,670评论 0 1
  • 在ZooKeeper客户端与服务端成功完成建立连接后,就建立了一个会话。ZooKeeper会话在整个运行期间的生命...
    微子Lee阅读 2,135评论 0 0
  • 一、ZooKeeper的背景 1.1 认识ZooKeeper ZooKeeper---译名为“动物园管理员”。动物...
    algernoon阅读 9,141评论 1 106