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
View Code
1 package com.lrcx.ky.server;
2
3 import java.io.IOException;
4 import java.net.InetSocketAddress;
5 import java.nio.charset.Charset;
6 import java.util.concurrent.Executors;
7
8 import org.apache.mina.core.service.IoServiceStatistics;
9 import org.apache.mina.core.session.IdleStatus;
10 import org.apache.mina.filter.codec.ProtocolCodecFilter;
11 import org.apache.mina.filter.codec.textline.LineDelimiter;
12 import org.apache.mina.filter.codec.textline.TextLineCodecFactory;
13 import org.apache.mina.filter.executor.ExecutorFilter;
14 import org.apache.mina.transport.socket.SocketAcceptor;
15 import org.apache.mina.transport.socket.nio.NioSocketAcceptor;
16
17 import com.lrcx.ky.env.SysEnv;
18
19 public class TcpServer {
20
21 private int port = 8292;
22 private int idleTime = 1800;
23 private int bufferSize = 1024;
24 private SocketAcceptor acceptor;
25
26 public void start() {
27 acceptor = new NioSocketAcceptor(Runtime.getRuntime().availableProcessors() + 1);
28 TextLineCodecFactory lineCodec = new TextLineCodecFactory(Charset
29 .forName("UTF-8"), LineDelimiter.WINDOWS.getValue(),
30 LineDelimiter.WINDOWS.getValue());
31 lineCodec.setDecoderMaxLineLength(2*1024*1024);
32 lineCodec.setEncoderMaxLineLength(2*1024*1024);
33 acceptor.getFilterChain().addLast("codec", new ProtocolCodecFilter(lineCodec));
34 acceptor.getFilterChain().addLast("exceutor", new ExecutorFilter(Executors.newCachedThreadPool()));
35 acceptor.setHandler(new TcpHandler());
36 acceptor.setReuseAddress(true);
37 acceptor.setBacklog(10240);
38 acceptor.getSessionConfig().setReuseAddress(true);
39 acceptor.getSessionConfig().setReadBufferSize(bufferSize);
40 acceptor.getSessionConfig().setReceiveBufferSize(bufferSize);
41 acceptor.getSessionConfig().setTcpNoDelay(true);
42 acceptor.getSessionConfig().setSoLinger(-1);
43 // 单位秒
44 acceptor.getSessionConfig().setIdleTime(IdleStatus.BOTH_IDLE, idleTime);
45
46 try {
47 acceptor.bind(new InetSocketAddress(port));
48 } catch (IOException e) {
49 e.printStackTrace(); System.exit(0);
50 }
51 }
52
53 public void stop() {
54 acceptor.dispose();
55 }
56
57 }
代码中的这两行：
lineCodec.setDecoderMaxLineLength(2*1024*1024);
lineCodec.setEncoderMaxLineLength(2*1024*1024);
是用来设置每次传输文本的长度的。
（2）服务端处理器代码TcpHandler
View Code
1 package com.lrcx.ky.server;
2
3 import net.sf.json.JSONObject;
4
5 import org.apache.mina.core.service.IoHandlerAdapter;
6 import org.apache.mina.core.session.IdleStatus;
7 import org.apache.mina.core.session.IoSession;
8
9 public class TcpHandler extends IoHandlerAdapter {
10
11 @Override
12 public void messageReceived(IoSession session, Object message)
13 throws Exception {
14 JSONObject request = JSONObject.fromObject(message.toString());
15 // 根据传来的数据进行处理
16 System.out.println(request);
17 }
18
19 @Override
20 public void exceptionCaught(IoSession session, Throwable cause)
21 throws Exception {
22
23 }
24
25 @Override
26 public void sessionClosed(IoSession session) throws Exception {
27
28 }
29
30 @Override
31 public void sessionIdle(IoSession session, IdleStatus status)
32 throws Exception {
33
34 }
35
36 }
（3）客户端代码TcpClient
View Code
1 package com.lrcx.ky.site.client;
2
3 import java.net.InetSocketAddress;
4 import java.nio.charset.Charset;
5 import java.util.concurrent.Executors;
6
7 import net.sf.json.JSONObject;
8
9 import org.apache.mina.core.filterchain.DefaultIoFilterChainBuilder;
10 import org.apache.mina.core.future.CloseFuture;
11 import org.apache.mina.core.future.ConnectFuture;
12 import org.apache.mina.core.session.IoSession;
13 import org.apache.mina.filter.codec.ProtocolCodecFilter;
14 import org.apache.mina.filter.codec.textline.LineDelimiter;
15 import org.apache.mina.filter.codec.textline.TextLineCodecFactory;
16 import org.apache.mina.filter.executor.ExecutorFilter;
17 import org.apache.mina.transport.socket.SocketConnector;
18 import org.apache.mina.transport.socket.nio.NioSocketConnector;
19
20 public class TcpClient {
21
22 private SocketConnector connector;
23 private ConnectFuture future;
24 private IoSession session;
25
26 public boolean connect() {
27 try {
28 // 创建一个socket连接
29 connector = new NioSocketConnector();
30 // 设置链接超时时间
31 connector.setConnectTimeoutMillis(3000);
32 // 获取过滤器链
33 DefaultIoFilterChainBuilder filterChain = connector.getFilterChain();
34 // 添加编码过滤器 处理乱码、编码问题
35 TextLineCodecFactory lineCodec = new TextLineCodecFactory(Charset.forName("UTF-8"), LineDelimiter.WINDOWS.getValue(), LineDelimiter.WINDOWS.getValue());
36 lineCodec.setDecoderMaxLineLength(2*1024*1024);
37 lineCodec.setEncoderMaxLineLength(2*1024*1024);
38 filterChain.addLast("codec", new ProtocolCodecFilter(lineCodec));
39 filterChain.addLast("exceutor", new ExecutorFilter(Executors.newCachedThreadPool()));
40
41 // 消息核心处理器
42 connector.setHandler(new TcpHandler());
43
44 // 连接服务器，知道端口、地址
45 future = connector.connect(new InetSocketAddress("127.0.0.1", 8292));
46 // 等待连接创建完成
47 future.awaitUninterruptibly();
48 // 获取当前session
49 session = future.getSession();
50 return true;
51 } catch (Exception e) {
52 e.printStackTrace();
53 return false;
54 }
55 }
56
57 public void write(JSONObject request) throws Exception {
58 session.write(request.toString());
59 }
60
61 public boolean close() {
62 try {
63 CloseFuture future = session.getCloseFuture();
64 future.awaitUninterruptibly(1000);
65 connector.dispose();
66
67 return true;
68 } catch (Exception e) {
69 e.printStackTrace();
70 return false;
71 }
72 }
73
74 }
（4）客户端处理器代码TcpHandler
View Code
1 package com.lrcx.ky.site.client;
2
3 import net.sf.json.JSONObject;
4
5 import org.apache.mina.core.service.IoHandlerAdapter;
6 import org.apache.mina.core.session.IoSession;
7
8 public class TcpHandler extends IoHandlerAdapter {
9
10 public void messageReceived(IoSession session, Object message) throws Exception {
11 JSONObject request = JSONObject.fromObject(message.toString());
12 // 根据传来的数据进行处理
13 System.out.println(request);
14 }
15
16 public void exceptionCaught(IoSession session, Throwable cause)
17 throws Exception {
18
19 }
20
21 public void sessionClosed(IoSession session) throws Exception {
22
23 }
24
25 }
以上是客户端和服务端通信的基础代码，具体的业务逻辑大家可以在这个基础上随意发挥。
页:
[1]