技术笔记：Mina框架(实战详解)

Apache Mina Server 是一个网络通信应用框架，为开发高性能和高可用性的网络应用程序提供了非常便利的框架。

特点：异步的NIO框架,将UDP当成"面向连接"的协议

一、组件管理

Mina的底层依赖的主要是Java NIO库，上层提供的是基于事件的异步接口

(1)IoService(最底层【起点】)

作用：隐藏底层IO的细节，对上提供统一的基于事件的异步IO接口

IOSocketAcceptor和IOSocketChannel，分别对应TCP协议下的服务端和客户端的IOService，low-level IO经过IOService层后变成IO Event

(2)IoProcessor

作用：负责检查是否有数据在通道上读写

IoProcessor 负责调用注册在IoService 上的过滤器，并在过滤器链之后调用IoHandler

(3)IoFilter(拦截器【关键】)

作用：日志输出、黑名单过滤、数据的编码（write 方向）与解码（read 方向）等功能

(4)IoHandler(业务逻辑处理【终点】)

作用：接收、发送数据

每个IoService都需要指定一个IoHandler

(5)IoSession

作用：是对底层连接（服务器与客户端的特定连接，该连接由服务器地址、端口以及客户端地址、端口来决定）的封装

二、服务端流程：

1、通过SocketAcceptor 同客户端建立连接；

2、连接建立之后 I/O的读写交给了I/O Processor线程，I/O Processor是多线程的；

3、通过I/O Processor 读取的数据经过IoFilterChain里所有配置的IoFilter，IoFilter进行消息的过滤，格式的转换，在这个层面可以制定一些自定义的协议；

4、最后IoFilter将数据交给 Handler 进行业务处理，完成了整个读取的过程；

写入过程也是类似，只是刚好倒过来，通过IoSession.write 写出数据，然后Handler进行写入的业务处理，处理完成后交给IoFilterChain，进行消息过滤和协议的转换，最后通过 I/O Processor 将数据写出到 socket 通道

三、服务端代码实现

1、编写IoService（主要功能：设置过滤器，设置handler，绑定端口）

public class MinaServer {

private static Logger logger = Logger.getLogger(MinaServer.class);

public static void main(String【】 args) {

Configuration config = Configuration.getInstance();

try {

config.readConfiguration();

config.initDataSource();

config.initServiceDef();

// 启动FTP读文件，PE积分后台执行

//此处为内部逻辑,通过FTP读取文件,跳过

} catch (Exception e1) {

e1.printStackTrace();

System.exit(1);

}

try {

config.initInterfaceConfig();

// 启动接口调用互斥map维护线程

InterfaceBusThread interfaceBusThread = new InterfaceBusThread();

interfaceBusThread.start();

} catch (Exception e) {

logger.info("InterfaceBus error!", e);

}

NioSocketAcceptor acceptor = null; // 创建连接

try {

// 创建一个非阻塞的server端的Socket

acceptor = new NioSocketAcceptor(Runtime.getRuntime()

.availableProcessors() + 1);// ioprocesser线程数，一般为cpu数量+1

// 建立工作线程池

Executor threadPool = Executors.newFixedThreadPool(Constant.threadCount);// 设置20个handler线程

// 解决在LINUX服务器上kill掉了，但是端口仍然被占用，要过一段时间才能释放

acceptor.setReuseAddress(true);

// 添加消息过滤器

acceptor.getFilterChain().addLast("codec",

new ProtocolCodecFilter(new XMLObjectCodecFactory()));

//

// 设置服务器能够接收的最大连接数

acceptor.setBacklog(Constant.maxSocketConn);

acceptor.getFilterChain().addLast("executor",

new ExecutorFilter(threadPool));

// 设置读取数据的缓冲区大小

acceptor.getSessionConfig().setReadBufferSize(2048);

// 读写通道10秒内无操作进入空闲状态

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

// 绑定逻辑处理器

acceptor.setHandler(new MinaServerHandler()); // 添加业务处理

// 绑定端口

acceptor.bind(new InetSocketAddress(Constant.minaServerPort));

logger.info("server start success... port："

+ Constant.minaServerPort);

} catch (Exception e) {

logger.error("server start error....", e);

e.printStackTrace();

System.exit(1);

}

}

}

2、编写过滤器(即上面代码的添加消息过滤器，这里使用了Mina自带的换行符编解码器工厂，注意：要在acceptor.bind()方法之前执行)

3、编写IoHandler

public class MinaServerHandler extends IoHandlerAdapter {

private final static Logger log = LoggerFactory.getLogger(TCPServerHandler.class);

@Override

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

//业务代码在这里编写处理

String str = message.toString();

System.out.println("The message received is 【" + str + "】");

if (str.endsWith("quit")) {

session.close(true);

return;

}

}

@Override

public void sessionCreated(IoSession session) throws Exception {

//代码效果参考：http://hnjlyzjd.com/xl/wz_24761.html

super.sessionCreated(session);

}

@Override

public void sessionOpened(IoSession session) throws Exception {

System.out.println("server session Opened");

super.sessionOpened(session);

}

@Override

public void sessionClosed(IoSession session) throws Exception {

System.out.println("server session Closed");

super.sessionClosed(session);

}

}

4、将IoHandler 注册到IoService(即上面代码的绑定逻辑处理器，注意：要在acceptor.bind()方法之前执行）

5、运行MinaServer中的main 方法，可以看到控制台一直处于阻塞状态，等待客户端连接

四、Maven的pom.xml配置

org.apache.mina

//代码效果参考：http://hnjlyzjd.com/xl/wz_24759.html

2.0.7

org.apache.mina

mina-integration-spring

1.1.7

五、测试类(模拟客户端请求)

public class AutoTest {

private final static String IP = "localhost";

private final static int PORT = 9002;

public static void main(String【】 args) {

String msg = "testEquityInsertRevequityinsertrev

13632599010120130620";

System.out.println("testEquityInsertRev request msg:"+msg);

System.out.println("testEquityInsertRev response msg:"+testApi(msg));

}

博客园：

Copyright ?2018 不是植物

【转载文章务必保留出处和署名，谢谢！】