zk中的会话管理SessionTrackerImpl的方法

本篇内容主要讲解"zk中的会话管理SessionTrackerImpl的方法"，感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷，实用性强。下面就让小编来带大家学习"zk中的会话管理SessionTrackerImpl的方法"吧!

SessionTrackerImpl中包含实现SessionImpl继承Session（在SessionTracker中） SessionTracker接口

SessionImpl是session属性集合类

属性

涉及到的类ExpiryQueue

类SessionImpl

类SessionExpirer

会话管理功能主要有：

1 会话过期

2 设置会话超时时间

3 生成下一个会话id

方法

将time->sessions map转成time->sessionIds 映射

getSessionExpiryMap

public synchronized Map> getSessionExpiryMap() {    // Convert time -> sessions map to time -> session IDs map    Map> expiryMap = sessionExpiryQueue.getExpiryMap();    Map> sessionExpiryMap = new TreeMap>();    for (Entry> e : expiryMap.entrySet()) {        Set ids = new HashSet();        sessionExpiryMap.put(e.getKey(), ids);        for (SessionImpl s : e.getValue()) {            ids.add(s.sessionId);        }    }    return sessionExpiryMap;}

run 超时会话检查线程，更新超时时间

public void run() {    try {        while (running) {            //没有超时，需要等待超时时间            long waitTime = sessionExpiryQueue.getWaitTime();            //线程等待一段时间            if (waitTime > 0) {                Thread.sleep(waitTime);                continue;            }            //已经超时了，拿出会话队列中的会话进行清理            for (SessionImpl s : sessionExpiryQueue.poll()) {                ServerMetrics.getMetrics().STALE_SESSIONS_EXPIRED.add(1);                //将标记设置为SessionImpl isClosing true                setSessionClosing(s.sessionId);                //zookeeperServer让session过期                expirer.expire(s);            }        }    } catch (InterruptedException e) {        handleException(this.getName(), e);    }    LOG.info("SessionTrackerImpl exited loop!");}

@Overridepublic synchronized boolean trackSession(long id, int sessionTimeout) {    boolean added = false;    SessionImpl session = sessionsById.get(id);    //没有就新增一个session对象    if (session == null) {        session = new SessionImpl(id, sessionTimeout);    }    // findbugs2.0.3 complains about get after put.    //？为什么    // long term strategy would be use computeIfAbsent after JDK 1.8    SessionImpl existedSession = sessionsById.putIfAbsent(id, session);    if (existedSession != null) {        session = existedSession;    } else {        added = true;        if (LOG.isDebugEnabled()) {            LOG.debug("Adding session 0x{}", Long.toHexString(id));        }    }    if (LOG.isTraceEnabled()) {        String actionStr = added ? "Adding" : "Existing";        ZooTrace.logTraceMessage(            LOG,            ZooTrace.SESSION_TRACE_MASK,            "SessionTrackerImpl --- " + actionStr            + " session 0x" + Long.toHexString(id) + " " + sessionTimeout);    }    //存在更新超时时间    updateSessionExpiry(session, sessionTimeout);    return added;}

分桶策略

将不同超时时间的会话分配到不同的桶中，做到有效管理，按照时间间隔来分桶

private long roundToNextInterval(long time) {

return (time / expirationInterval + 1) * expirationInterval;

}

会话建立之后，会话如何保持激活状态

问题 会话如何迁移？

会话激活的方法有public synchronized boolean touchSession(long sessionId, int timeout) {    //获取会话    SessionImpl s = sessionsById.get(sessionId);    if (s == null) {        logTraceTouchInvalidSession(sessionId, timeout);        return false;    }    //关闭    if (s.isClosing()) {        logTraceTouchClosingSession(sessionId, timeout);        return false;    }    //更新会话 将旧过期时间桶中session移动到新桶    updateSessionExpiry(s, timeout);    return true;}

client 什么时候会发出激活会话请求

1客户端向服务端发送请求，包含读写请求，就会激活会话

2 客户端发现在sessionTimeout/3时间内未收到任何通信，就会向服务器发起ping请求，

服务端收到请求后，就会进行会话激活操作

超时检测策略

对于会话超时检测而言，zookeeper使用SessionTracker负责，sessionTracker使用单独线程（超时检查线程）

专门进行会话超时检测，即逐个一次地对会话桶中剩余会话进行清理。

如果一个会话被激活，那么zookeeper会将其从上一个会话桶迁移到下一个会话桶中，

如ExpirationTIme 1的session n迁移到ExpirationTime n桶中，此时ExpirationTime 1中留下的会话就是没有被激活的

超时检测程序就定时检查这个会话桶中剩余未被迁移的会话，并且只在指定时间点上检查(ExpirationTime 1,ExpirationTime2,

ExpirationTime3,...n)这样有利于提高性能

@Overridepublic void run() {    try {        while (running) {            long waitTime = sessionExpiryQueue.getWaitTime();            if (waitTime > 0) {                Thread.sleep(waitTime);                continue;            }            for (SessionImpl s : sessionExpiryQueue.poll()) {                ServerMetrics.getMetrics().STALE_SESSIONS_EXPIRED.add(1);                setSessionClosing(s.sessionId);                expirer.expire(s);            }        }    } catch (InterruptedException e) {        handleException(this.getName(), e);    }    LOG.info("SessionTrackerImpl exited loop!");}

到此，相信大家对"zk中的会话管理SessionTrackerImpl的方法"有了更深的了解，不妨来实际操作一番吧！这里是网站，更多相关内容可以进入相关频道进行查询，关注我们，继续学习！