Mina2.0框架源码剖析(五)

  1. 云栖社区>
  2. 博客>
  3. 正文

Mina2.0框架源码剖析(五)

嗯哼9925 2018-01-08 12:03:41 浏览750
展开阅读全文
前面介绍过IoSessionRecycler是负责回收不再使用的会话的接口,ExpiringSessionRecycler是其一个实现类,用于回收超时失效的会话。

private ExpiringMap<Object, IoSession> sessionMap;//待处理的会话集
private ExpiringMap<Object, IoSession>.Expirer mapExpirer;//负责具体的回收工作
sessionMap的键是由本地地址和远端地址共同组成的,值是这两个地址对应的会话。

Expirer类实现了Runnable接口,这个线程负责监控ExpiringMap,并把ExpiringMap中超过阀值的元素从ExpiringMap中移除。这个线程调用了setDaemon(true),因此是作为守护线程在后台运行。具体的处理过程如下:

复制代码
   private void processExpires() 
        {
            long timeNow = System.currentTimeMillis();//当前时间
            for (ExpiringObject o : delegate.values()) 
            {
                if (timeToLiveMillis <= 0) 
                {
                    continue;
                }
                long timeIdle = timeNow - o.getLastAccessTime();//时间差
                if (timeIdle >= timeToLiveMillis) 
                {//超时
                    delegate.remove(o.getKey());
                    for (ExpirationListener<V> listener : expirationListeners) 
                    {//呼叫监听者
                        listener.expired(o.getValue());
                    }
                }
            }
        }
复制代码
     启动/关闭超时检查线程都需要进行封锁机制,这里使用的是读写锁:

复制代码
      private final ReadWriteLock stateLock = new ReentrantReadWriteLock();

        public void startExpiring() 
        {
            stateLock.writeLock().lock();
            try 
            {
                if (!running) 
                {
                    running = true;
                    expirerThread.start();
                }
            } 
            finally 
            {
                stateLock.writeLock().unlock();
            }
        }
        public void stopExpiring() 
        {
            stateLock.writeLock().lock();
            try 
            {
                if (running) 
                {
                    running = false;
                    expirerThread.interrupt();
                }
            } 
            finally 
            {
                stateLock.writeLock().unlock();
            }
        }
复制代码
     会话超时监听者:

    private class DefaultExpirationListener implements
            ExpirationListener<IoSession> {
        public void expired(IoSession expiredSession) {
            expiredSession.close();//关闭超时的会话
        }
    }

本文转自Phinecos(洞庭散人)博客园博客,原文链接:http://www.cnblogs.com/phinecos/archive/2008/12/04/1347752.html,如需转载请自行联系原作者

网友评论

登录后评论
0/500
评论
嗯哼9925
+ 关注