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

Mina2.0快速入门与源码剖析第0页共39页Mina2.0快速入门与源码剖析姓名：邓以克网名：phinecos(洞庭散人)MSN:[e-mail]出处：本文版权归作者所有，欢迎传阅，但请保留此段声明。Mina2.0快速入门与源码剖析第1页共39页目录1.Mina2.0快速入门........................................................................................................................22.Mina2.0框架源码剖析（一）....................................................................................................53.Mina2.0框架源码剖析（二）..................................................................................................104.Mina2.0框架源码剖析（三）..................................................................................................145.Mina2.0框架源码剖析（四）..................................................................................................186.Mina2.0框架源码剖析（五）..................................................................................................227.Mina2.0框架源码剖析（六）..................................................................................................258.Mina2.0框架源码剖析（七）..................................................................................................309.Mina2.0框架源码剖析（八）..................................................................................................34Mina2.0快速入门与源码剖析第2页共39页1.Mina2.0快速入门MinaTimeServer.javapackagecom.vista;importjava.io.IOException;importjava.net.InetSocketAddress;importjava.nio.charset.Charset;importorg.apache.mina.core.service.IoAcceptor;importorg.apache.mina.core.session.IdleStatus;importorg.apache.mina.filter.codec.ProtocolCodecFilter;importorg.apache.mina.filter.codec.textline.TextLineCodecFactory;importorg.apache.mina.filter.logging.LoggingFilter;importorg.apache.mina.transport.socket.nio.NioSocketAcceptor;publicclassMinaTimeServer{privatestaticfinalintPORT=6488;publicstaticvoidmain(String[]args)throwsIOException{//监听即将到来的TCP连接IoAcceptoracceptor=newNioSocketAcceptor();acceptor.getFilterChain().addLast(logger,newLoggingFilter());acceptor.getFilterChain().addLast(codec,newProtocolCodecFilter(newTextLineCodecFactory(Charset.forName(UTF-8))));acceptor.setHandler(newTimeServerHandler());acceptor.getSessionConfig().setReadBufferSize(2048);acceptor.getSessionConfig().setIdleTime(IdleStatus.BOTH_IDLE,10);acceptor.bind(newInetSocketAddress(PORT));System.out.println(服务器启动);}Mina2.0快速入门与源码剖析第3页共39页}TimeServerHandler.javapackagecom.vista;importjava.util.Date;importorg.apache.mina.core.service.IoHandlerAdapter;importorg.apache.mina.core.session.IdleStatus;importorg.apache.mina.core.session.IoSession;publicclassTimeServerHandlerextendsIoHandlerAdapter{publicvoidexceptionCaught(IoSessionsession,Throwablecause)throwsException{cause.printStackTrace();}publicvoidmessageReceived(IoSessionsession,Objectmessage)throwsException{StringstrMsg=message.toString();if(strMsg.trim().equalsIgnoreCase(quit)){session.close();return;}Datedate=newDate();session.write(date.toString());System.out.println(Messagewritten);}publicvoidsessionIdle(IoSessionsession,IdleStatusstatus)throwsException{System.out.println(IDLE+session.getIdleCount(status));}}测试：Mina2.0快速入门与源码剖析第4页共39页ClientOutputServerOutputuser@myhost:~telnet127.0.0.19123Trying127.0.0.1...Connectedto127.0.0.1.Escapecharacteris'^]'.helloWedOct1723:23:36EDT2007quitConnectionclosedbyforeignhost.user@myhost:~MINATimeserverstarted.Messagewritten...参考资料：1，MINAv2.0QuickStartGuideMina2.0快速入门与源码剖析第5页共39页2.Mina2.0框架源码剖析（一）整个框架最核心的几个包是：org.apache.mina.core.service,org.apache.mina.core.session,org.apache.mina.core.polling以及org.apache.mina.transport.socket。这一篇先来看org.apache.mina.core.service。第一个要说的接口是IoService,它是所有IoAcceptor和IoConnector的基接口.对于一个IoService,有哪些信息需要我们关注呢？1）底层的元数据信息TransportMetadata，比如底层的网络服务提供者（NIO,ARP,RXTX等），2）通过这个服务创建一个新会话时，新会话的默认配置IoSessionConfig。3）此服务所管理的所有会话。4）与这个服务相关所产生的事件所对应的监听者（IoServiceListener）。5）处理这个服务所管理的所有连接的处理器(IoHandler)。6）每个会话都有一个过滤器链（IoFilterChain），每个过滤器链通过其对应的IoFilterChainBuilder来负责构建。7）由于此服务管理了一系列会话，因此可以通过广播的方式向所有会话发送消息,返回结果是一个WriteFuture集，后者是一种表示未来预期结果的数据结构。8）服务创建的会话（IoSession）相关的数据通过IoSessionDataStructureFactory来提供。9）发送消息时有一个写缓冲队列。10）服务的闲置状态有三种：读端空闲，写端空闲，双端空闲。11）还提供服务的一些统计信息，比如时间，数据量等。IoService这个服务是对于服务器端的接受连接和客户端发起连接这两种行为的抽象。再来从服务器看起，IoAcceptor是IoService的子接口，它用于绑定到指定的ip和端口，从而接收来自客户端的连接请求，同时会fire相应的客户端连接成功接收/取消/失败等事件给自己的IoHandle去处理。当服务器端的Accpetor从早先绑定的ip和端口上取消绑定时，默认是所有的客户端会话会被关闭，这种情况一般出现在服务器挂掉了，则客户端收到连接关闭的提示。这个接口最重要的两个方法是bind()和unbind()，当这两个方法被调用时，服务端的连接接受线程就启动或关闭了。再来看一看客户端的连接发起者接口IoConnector，它的功能和IoAcceptor基本对应的，它用于尝试连接到服务器指定的ip和端口，同时会fire相应的客户端连接事件给自己的IoHandle去处理。当connet方法被调用后用于连接服务器端的线程就启动了，而当所有的连接尝试都结束时线程就停止。尝试连接的超时时间可以自行设置。Connect方法返回的结果是ConnectFuture，这和前面说的WriteFuture类似，在后面会有一篇专门讲这个模式的应用。前面的IoAcceptor和IoConnector就好比是两个负责握手的仆人，而真正代表会话的实际I/O操作的接口是IoProcessor，它对现有的Reactor模式架构的JavaNIO框架继续做了一层封装。它的泛型参数指明了它能处理的会话类型。接口中最重要的几个方法，add用于将指定会话加入到此Processor中，让它负责处理与此会话相关的所有I/O操作。由于写操作会有一个写请求队列，flush就用于对指定会话的写请求队列进行强制刷数据。remove方法用于从此Processor中移除和关闭指定会话，这样就可以关闭会话相关联的连接并释放所有相关资源。updateTrafficMask方法用于控制会话的I/O行为，比如是否允许读/写。Mina2.0快速入门与源码剖析第6页共39页然后来说说IoHandle接口，Mina中的所有I/O事件都是通过这个接口来处理的