前面介绍过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，如需转载请自行联系原作者
