zk中的会话管理SessionTrackerImpl的方法

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

创新互联是一家集网站建设,千阳企业网站建设,千阳品牌网站建设,网站定制,千阳网站建设报价,网络营销,网络优化,千阳网站推广为一体的创新建站企业,帮助传统企业提升企业形象加强企业竞争力。可充分满足这一群体相比中小企业更为丰富、高端、多元的互联网需求。同时我们时刻保持专业、时尚、前沿,时刻以成就客户成长自我,坚持不断学习、思考、沉淀、净化自己,让我们为更多的企业打造出实用型网站。

SessionTrackerImpl中包含实现SessionImpl继承Session(在SessionTracker中) SessionTracker接口

SessionImpl是session属性集合类

属性

sessionsById

sessionid和会话的对应map

sessionExpiryQueue

会话到期队列

sessionsWithTimeout

sessionid对应过期时间

nextSessionId

下一个sessionid

expirer

让session过期,获取服务id

running

运行中

  

涉及到的类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!");
}

方法

说明

getSessionTimeout

通过sessionId获取超时时间

setSessionClosing

设置会话关闭

removeSession

通过sessionId移除会话,同时移除会话相关的映射关系图

createSession(int sessionTimeout)

创建session,指定过期时间

trackSession(sessionId, sessionTimeout);

取得sessionId,调用trackSession(sessionId, sessionTimeout);方法进行session创建,更新会话超时时间

 

@Override
public 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;
}

方法

说明

涉及异常

commitSession(long id, int sessionTimeout)

提交session

UnknownSessionException

isTrackingSession(long sessionId)

是否为可以追踪会话,说明会话有效

SessionExpiredException

checkSession(long sessionId, Object owner)

通过会话和拥有者检查会话信息

SessionMovedException

分桶策略

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

private long roundToNextInterval(long time) {

return (time / expirationInterval + 1) * expirationInterval;

}

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

问题 会话如何迁移?

zk中的会话管理SessionTrackerImpl的方法

会话激活的方法有
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)这样有利于提高性能

@Override
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);
                setSessionClosing(s.sessionId);
                expirer.expire(s);
            }
        }
    } catch (InterruptedException e) {
        handleException(this.getName(), e);
    }
    LOG.info("SessionTrackerImpl exited loop!");
}

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


分享文章:zk中的会话管理SessionTrackerImpl的方法
分享网址:http://scyanting.com/article/igjgpi.html