Apache Mina使用JSON数据进行通信的使用方法-白红宇

Apache Mina使用JSON数据进行通信的使用方法

阅读量：5842 次

发布时间：2019-06-18

本文共 6333 字，大约阅读时间需要 21 分钟。

最近使用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的编码，代码中用到的JSON的2个处理包：json-lib-2.3-jdk15.jar、ezmorph-1.0.6.jar。

使用的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;

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

public void exceptionCaught(IoSession session, Throwable cause)

throws Exception {

}

@Override

public void sessionClosed(IoSession session) throws Exception {

}

@Override

public void sessionIdle(IoSession session, IdleStatus status)

throws Exception {

}

}

（3）客户端代码TcpClient

package com.lrcx.ky.site.client;

import java.net.InetSocketAddress;

import java.nio.charset.Charset;

import java.util.concurrent.Executors;

import net.sf.json.JSONObject;

import org.apache.mina.core.filterchain.DefaultIoFilterChainBuilder;

import org.apache.mina.core.future.CloseFuture;

import org.apache.mina.core.future.ConnectFuture;

import org.apache.mina.core.session.IoSession;

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.SocketConnector;

import org.apache.mina.transport.socket.nio.NioSocketConnector;

public class TcpClient {

private SocketConnector connector;

private ConnectFuture future;

private IoSession session;

public boolean connect() {

try {

// 创建一个socket连接

connector = new NioSocketConnector();

// 设置链接超时时间

connector.setConnectTimeoutMillis(3000);

// 获取过滤器链

DefaultIoFilterChainBuilder filterChain = connector.getFilterChain();

// 添加编码过滤器处理乱码、编码问题

TextLineCodecFactory lineCodec = new TextLineCodecFactory(Charset.forName("UTF-8"), LineDelimiter.WINDOWS.getValue(), LineDelimiter.WINDOWS.getValue());