日期:2014-05-16  浏览次数:20937 次

Apache Mina使用JSON数据进行通信的使用方法
最近使用Mina开发一个在线聊天的项目,因此也特意学习了Apache的这个Mina框架。
  首先,Mina是个什么东西?看下官方网站(http://mina.apache.org/)对它的解释:
  Apache的Mina(Multipurpose Infrastructure Networked Applications)是一个网络应用框架,可以帮助用户开发高性能和高扩展性的网络应用程序;它提供了一个抽象的、事件驱动的异步API,使Java NIO在各种传输协议(如TCP/IP,UDP/IP协议等)下快速高效开发。
  Apache Mina也称为:
NIO框架
客户端/服务端框架(典型的C/S架构)
网络套接字(networking socket)类库
事件驱动的异步API(注意:在JDK7中也新增了异步API)
总之:我们简单理解它是一个封装底层IO操作,提供高级操作API的通讯框架!

在Mina的官网、以及网上都有比较丰富的文档了,这里我就稍微简单说一下Mina的结构和示例代码。
因为Mina2.X改进了Mina的代码结构和包结构,降低了使用的复杂性和增强了健壮性,所以使得API发生了比较大的改变,有许多地方已经和Mina1.x不兼容了。

我这里要实现的是在线聊天功能,所以其中使用的数据并不单一,所以这里采用了JOSN的数据格式,我这里是采用UTF-8的编码。
使用的Mina版本为2.0.4
具体的开发过程,比如导包和建立项目什么的我就不说了,这里直接上代码。

(1)服务端代码TcpServer
       我这里使用的是Mina自带TextLineCodecFactory
 package com.lrcx.ky.server;
 
 import java.io.IOException;
 import java.net.InetSocketAddress;
 import java.nio.charset.Charset;
 import java.util.concurrent.Executors;
 
 import org.apache.mina.core.service.IoServiceStatistics;
 import org.apache.mina.core.session.IdleStatus;
 import org.apache.mina.filter.codec.ProtocolCodecFilter;
 import org.apache.mina.filter.codec.textline.LineDelimiter;
 import org.apache.mina.filter.codec.textline.TextLineCodecFactory;
 import org.apache.mina.filter.executor.ExecutorFilter;
 import org.apache.mina.transport.socket.SocketAcceptor;
 import org.apache.mina.transport.socket.nio.NioSocketAcceptor;
 
 import com.lrcx.ky.env.SysEnv;
 
 public class TcpServer {
 
     private int port = 8292;
     private int idleTime = 1800;
     private int bufferSize = 1024;
     private SocketAcceptor acceptor;
 
     public void start() {        
         acceptor = new NioSocketAcceptor(Runtime.getRuntime().availableProcessors() + 1);
         TextLineCodecFactory lineCodec = new TextLineCodecFactory(Charset
                 .forName("UTF-8"), LineDelimiter.WINDOWS.getValue(),
                 LineDelimiter.WINDOWS.getValue());
         lineCodec.setDecoderMaxLineLength(2*1024*1024);
         lineCodec.setEncoderMaxLineLength(2*1024*1024);
         acceptor.getFilterChain().addLast("codec", new ProtocolCodecFilter(lineCodec));
         acceptor.getFilterChain().addLast("exceutor", new ExecutorFilter(Executors.newCachedThreadPool()));
         acceptor.setHandler(new TcpHandler());
         acceptor.setReuseAddress(true);
         acceptor.setBacklog(10240);
         acceptor.getSessionConfig().setReuseAddress(true);
         acceptor.getSessionConfig().setReadBufferSize(bufferSize);
         acceptor.getSessionConfig().setReceiveBufferSize(bufferSize);
         acceptor.getSessionConfig().setTcpNoDelay(true);
         acceptor.getSessionConfig().setSoLinger(-1);
         // 单位秒
         acceptor.getSessionConfig().setIdleTime(IdleStatus.BOTH_IDLE, idleTime);
 
         try {
             acceptor.bind(new InetSocketAddress(port));
         } catch (IOException e) {
             e.printStackTrace();                            System.exit(0);
         }
     }
 
     public void stop() {
         acceptor.dispose();
     }
     
 }

代码中的这两行:

  lineCodec.setDecoderMaxLineLength(2*1024*1024);
  lineCodec.setEncoderMaxLineLength(2*1024*1024);

是用来设置每次传输文本的长度的。

(2)服务端处理器代码TcpHandler
 package com.lrcx.ky.server;
 
 import net.sf.json.JSONObject;
 
 import org.apache.mina.core.service.IoHandlerAdapter;
 import org.apache.mina.core.session.IdleStatus;
 import org.apache.mina.core.session.IoSession;
 
 public class TcpHandler extends IoHandlerAdapter {
     
     @Override
     public void messageReceived(IoSession session, Object message)
             throws Exception {
         JSONObject request = JSONObject.fromObject(message.toString());
         // 根据传来的数据进行处理
         System.out.println(request);
     }
 
     @Override
     publ