前面介绍过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://phinecos.cnblogs.com/
分享到:
相关推荐
Mina2.0框架源码剖析
Mina2.0框架源码剖析.docMina2.0框架源码剖析.docMina2.0框架源码剖析.docMina2.0框架源码剖析.docMina2.0框架源码剖析.docMina2.0框架源码剖析.doc
Mina2.0框架源码剖析.pdf
Mina2.0框架源码剖析(六).pdf
资源包括: MINA笔记.docx ...Mina2.0快速入门与源码剖析.pdf MINA网络框架和RMI的对比研究.pdf 基于3G网络的移动流媒体服务器的设计与实现.pdf 高性能通信框架及智能主站技术研究.nh MINA类图.doc 等
Java 源码包 Applet钢琴模拟程序java源码 2个目标文件,提供基本的音乐编辑功能。编辑音乐软件的朋友,这款实例会对你有所帮助。 Calendar万年历 1个目标文件 EJB 模拟银行ATM流程及操作源代码 6个目标文件,EJB来...
笔者当初为了学习JAVA,收集了很多经典源码,源码难易程度分为初级、中级、高级等,详情看源码列表,需要的可以直接下载! 这些源码反映了那时那景笔者对未来的盲目,对代码的热情、执着,对IT的憧憬、向往!此时此...
6、支持多种通信框架(Mina/Netty/Grizzly),支持多种序列化/反序列化(Java/Hessian/PB); 7、支持自定义通信协议,可完全替换NFS-RPC自带的协议。 淘宝开放平台JAVA版SDK top4java 设计原则 容易维护扩展(不...
6、支持多种通信框架(Mina/Netty/Grizzly),支持多种序列化/反序列化(Java/Hessian/PB); 7、支持自定义通信协议,可完全替换NFS-RPC自带的协议。 淘宝开放平台JAVA版SDK top4java 设计原则 容易维护扩展(不...
6、支持多种通信框架(Mina/Netty/Grizzly),支持多种序列化/反序列化(Java/Hessian/PB); 7、支持自定义通信协议,可完全替换NFS-RPC自带的协议。 淘宝开放平台JAVA版SDK top4java 设计原则 容易维护扩展(不...
6、支持多种通信框架(Mina/Netty/Grizzly),支持多种序列化/反序列化(Java/Hessian/PB); 7、支持自定义通信协议,可完全替换NFS-RPC自带的协议。 淘宝开放平台JAVA版SDK top4java 设计原则 容易维护扩展(不...
6、支持多种通信框架(Mina/Netty/Grizzly),支持多种序列化/反序列化(Java/Hessian/PB); 7、支持自定义通信协议,可完全替换NFS-RPC自带的协议。 淘宝开放平台JAVA版SDK top4java 设计原则 容易维护扩展(不...
6、支持多种通信框架(Mina/Netty/Grizzly),支持多种序列化/反序列化(Java/Hessian/PB); 7、支持自定义通信协议,可完全替换NFS-RPC自带的协议。 淘宝开放平台JAVA版SDK top4java 设计原则 容易维护扩展(不...
6、支持多种通信框架(Mina/Netty/Grizzly),支持多种序列化/反序列化(Java/Hessian/PB); 7、支持自定义通信协议,可完全替换NFS-RPC自带的协议。 淘宝开放平台JAVA版SDK top4java 设计原则 容易维护扩展(不...
6、支持多种通信框架(Mina/Netty/Grizzly),支持多种序列化/反序列化(Java/Hessian/PB); 7、支持自定义通信协议,可完全替换NFS-RPC自带的协议。 淘宝开放平台JAVA版SDK top4java 设计原则 容易维护扩展(不...