Apache Mina入門

Apache MINA(Multipurpose Infrastructure for Network Applications)

官網http://mina.apache.org/

是 Apache 組織一個較新的項目，它為開發高性能和高可用性的網絡應用程序提供了非常便利的框架。當前發行的 MINA 版本支持基于 Java NIO 技術的 TCP/UDP 應用程序開發、串口通訊程序（只在最新的預覽版中提供），MINA 所支持的功能也在進一步的擴展中。 　　目前正在使用 MINA 的軟件包括有：Apache Directory Project、AsyncWeb、AMQP（Advanced Message Queuing Protocol）、RED5 Server（Macromedia Flash Media RTMP）、ObjectRADIUS、Openfire 等等。

本文就介紹入門mina的入門,

參考文檔http://mina.apache.org/mina-project/quick-start-guide.html

第一步、定義MinaTimeServer.java mina服務端

/**

*
*/
package com.figo.onlineshop.test;
import java.io.IOException;
import java.net.InetSocketAddress;
import java.nio.charset.Charset;
import org.apache.mina.core.service.IoAcceptor;
import org.apache.mina.core.session.IdleStatus;
import org.apache.mina.filter.codec.ProtocolCodecFilter;
import org.apache.mina.filter.codec.textline.TextLineCodecFactory;
import org.apache.mina.filter.logging.LoggingFilter;
import org.apache.mina.transport.socket.nio.NioSocketAcceptor;
/**

@author zhuzhifei
*
*/


public class MinaTimeServer {

private static final int PORT = 9123;



      /**

       * @param args

       */

      public static void main(String[] args) {

               // TODO Auto-generated method stub

               //定義socket接收器

               IoAcceptor acceptor = new NioSocketAcceptor();

    //添加日志記錄

    acceptor.getFilterChain().addLast( "logger", new LoggingFilter() );

    //添加編碼解碼器

    acceptor.getFilterChain().addLast( "codec", new ProtocolCodecFilter( new TextLineCodecFactory( Charset.forName( "UTF-8" ))));

    //添加處理器(用于接收數據后處理處理數據邏輯)

    acceptor.setHandler(  new TimeServerHandler() );

    //設置讀取數據緩存單位byte

    acceptor.getSessionConfig().setReadBufferSize( 2048 );

    //設置多長時間后接收器開始空閑

    acceptor.getSessionConfig().setIdleTime( IdleStatus.BOTH_IDLE, 10 );



    try {

              //綁定某個端口，作為數據入口

                        acceptor.bind( new InetSocketAddress(PORT) );

               } catch (IOException e) {

                        // TODO Auto-generated catch block

                        e.printStackTrace();

               }





      }




}
</pre>

第二步、定義消息處理器TimeServerHandler.java

/**

*
*/
package com.figo.onlineshop.test;
import java.util.Date;
import org.apache.mina.core.service.IoHandlerAdapter;
import org.apache.mina.core.session.IdleStatus;
import org.apache.mina.core.session.IoSession;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**

@author zhuzhifei
*
*/


//必須繼承IoHandlerAdapter
public class TimeServerHandler extends IoHandlerAdapter {

private final Logger logger = LoggerFactory.getLogger(MinaTimeServer.class);

//補抓異常

      @Override

      public void exceptionCaught(IoSession session, Throwable cause)

                        throws Exception {

               // TODO Auto-generated method stub

               super.exceptionCaught(session, cause);

      }

//獲取客戶端消息后處理邏輯

      @Override

      public void messageReceived(IoSession session, Object message)

                         throws Exception {

               // TODO Auto-generated method stub

               super.messageReceived(session, message);

               String str = message.toString();

    if( str.trim().equalsIgnoreCase("quit") ) {

        session.close(true);

        return;

    }



    Date date = new Date();

    session.write( "current time:"+date.toString() );//該消息將返回給客戶端

    System.out.println("Message Received:"+str);

    logger.info(date.toString()+"Message Received:"+str);//日志沒有輸出why?



      }

//發送消息

      @Override

      public void messageSent(IoSession session, Object message) throws Exception {

               // TODO Auto-generated method stub

               super.messageSent(session, message);

      }

//當前會話關閉

      @Override

      public void sessionClosed(IoSession session) throws Exception {

               // TODO Auto-generated method stub

               super.sessionClosed(session);

      }

//創建會話

      @Override

      public void sessionCreated(IoSession session) throws Exception {

               // TODO Auto-generated method stub

               super.sessionCreated(session);

      }

//會話空閑

      @Override

      public void sessionIdle(IoSession session, IdleStatus status)

                        throws Exception {

               // TODO Auto-generated method stub

               super.sessionIdle(session, status);

               System.out.println( "IDLE " + session.getIdleCount( status ));

      }

//打開會話

      @Override

      public void sessionOpened(IoSession session) throws Exception {

               // TODO Auto-generated method stub

               super.sessionOpened(session);

      }




}</pre>

第三步、模擬客戶端tcp調用

MinaTimeServer.java run as java Application后

C:\Documents and Settings\zhuzhifei>telnet 127.0.0.1 9123 連上服務器

客戶端輸入：abc后

服務端接收到：

2012-12-25 18:26:52 INFO  com.figo.onlineshop.test.MinaTimeServer - Tue Dec 25 18:26:52 CST 2012Message Received:abc
客戶端顯示：current time:Tue Dec 25 18:26:52 CST 2012