`
amozon
  • 浏览: 134210 次
  • 性别: Icon_minigender_1
  • 来自: 上海
社区版块
存档分类
最新评论

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

阅读更多
前面介绍过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框架源码剖析》 Apache Mina是一个高性能、轻量级的网络通信框架,常用于构建基于TCP/IP和UDP/IP协议的应用,如服务器端的开发。Mina2.0作为其一个重要版本,引入了许多优化和改进,为开发者提供了更强大...

    Mina2.0框架源码剖析.pdf

    Mina2.0框架源码剖析 Mina2.0是一个基于Java的网络应用框架,提供了一个简洁、灵活的API,帮助开发者快速构建高性能的网络应用程序。下面是Mina2.0框架源码剖析的相关知识点: 一、Mina2.0框架概述 Mina2.0是一个...

    Mina2.0快速入门与源码剖析.docx

    Mina2.0 框架源码剖析(五)主要包括了解 Mina2.0 的套接字实现、套接字的使用和配置、连接器的实现等。 知识点: * 套接字实现:InetSocketAddress、Socket * 套接字的使用和配置:套接字的创建和销毁 * 连接器的...

    Mina2.0快速入门与源码剖析

    Mina2.0框架源码剖析(五) 在Mina2.0框架中,ProtocolCodecFilter是一个实现了ProtocolCodecFactory接口的Filter,负责对数据进行编码和解码。ProtocolCodecFilter可以根据需要对数据进行各种编码和解码操作,例如...

    Mina2.0框架源码剖析(六).pdf

    《Mina2.0框架源码剖析(六)》这篇文档主要关注的是Mina框架中的ExpiringMap、IoSession及其相关概念,这些内容对于理解Mina框架如何处理数据过期、会话管理和读写操作至关重要。 ExpiringMap是一个实现自动过期功能...

    Mina 2.0快速入门与源码解析

    #### Mina 2.0 框架源码剖析 接下来,我们将逐步深入分析 Mina 2.0 的核心组件及其实现原理。 **2.1 IoAcceptor** `IoAcceptor` 接口是 Mina 2.0 中的核心接口之一,它代表了一个网络服务端点。通过该接口可以...

    Mina2.0阅读源码笔记(很值得一看)

    ### Mina2.0阅读源码笔记知识点梳理 #### 一、Mina 概述与官方资源 **Mina** 是 Apache 基金会下的一个开源项目,它为开发者提供了一个高性能且易于使用的网络应用框架。Mina 的设计目标是帮助用户轻松地开发出高...

    Mina2.0 example HttpServer

    通过阅读和分析Mina2.0的源码,我们可以更深入地理解其内部工作机制,从而更好地利用这一工具。对于开发人员来说,理解并掌握HttpServer的实现原理,不仅有助于提高代码质量,还能提升解决网络通信问题的能力。因此...

    Apache Mina Server 2.0 抢鲜体验

    7. **源码分析**:由于标签中提到了“源码”,因此,对于有志于深入理解Mina工作原理的开发者来说,阅读和分析Apache Mina的源码可以帮助他们更好地优化自己的网络应用程序,提高性能和稳定性。 8. **性能优化**:...

    Apache MINA框架相关资料

    3. **Mina2源码分析**(Mina2源码分析.doc):源码分析文档通常由经验丰富的开发者编写,通过深入剖析MINA的源代码,揭示其内部工作原理,帮助开发者理解MINA如何实现非阻塞I/O,以及如何高效地处理网络连接和数据...

    APCHE-MINA 就是全

    描述中提到的“史上最全的mina2.0材料,真的很不错,用了才知道”,暗示这是一份详尽且高质量的学习资源,包含了MINA 2.0版本的所有重要方面,并且通过实际使用可以体验到其价值。 标签中的“mian2.0 中文api”表明...

    资料_MINA(2、3、4).rar

    资源包括: MINA笔记.docx ...Mina2.0快速入门与源码剖析.pdf MINA网络框架和RMI的对比研究.pdf 基于3G网络的移动流媒体服务器的设计与实现.pdf 高性能通信框架及智能主站技术研究.nh MINA类图.doc 等

    mina学习笔记

    《Mina2.0快速入门与源码剖析》这本书可能是MINA 2.0版本的指南,它可能包含以下内容: 1. 快速入门教程:针对MINA 2.0的新特性,提供快速搭建和运行MINA服务端和客户端的步骤。 2. 源码分析:对MINA的关键模块进行...

    MINA框架使用jar包(Android)

    Mina源码解析.zip和mina-example.zip可能包含了MINA的源代码分析和示例项目,对于深入学习MINA的内部工作机制和实际应用开发非常有价值。最后,apache-mina-2.0.7应该是MINA框架的主要库文件,包含了所有必需的类和...

Global site tag (gtag.js) - Google Analytics