MINA服務(wù)端的應(yīng)用應(yīng)用體系結(jié)構(gòu)
基本上，服務(wù)器監(jiān)聽(tīng)端口傳入請(qǐng)求宅楞，處理它們并發(fā)送回復(fù)落塑。它還為每個(gè)客戶端創(chuàng)建和處理會(huì)話（無(wú)論我們是基于TCP或者UDP的時(shí)候）朱庆。
- IOAcceptor在網(wǎng)絡(luò)上監(jiān)聽(tīng)傳入的連接/數(shù)據(jù)包
- 對(duì)于新鏈接蛤克，將會(huì)創(chuàng)建一個(gè)新的會(huì)話捺癞，并在該會(huì)話中處理來(lái)自IP地址/端口組合的所有后續(xù)請(qǐng)求
- 為會(huì)話接收的所有數(shù)據(jù)包將按照?qǐng)D中所示的方式遍歷過(guò)濾器。過(guò)濾器可用于修改數(shù)據(jù)包的內(nèi)容（如轉(zhuǎn)換為對(duì)象构挤，添加/刪除信息等）髓介。PacketEncoder/Decoder對(duì)于將原始字節(jié)轉(zhuǎn)換為高級(jí)對(duì)象，非常有用筋现。
- 最后數(shù)據(jù)包或者轉(zhuǎn)換成對(duì)象的數(shù)據(jù)將加載到IOHandler中版保，IOHandler可以非常完美的處理業(yè)務(wù)需求。
示例TCP服務(wù)器
接下來(lái)將引導(dǎo)您完成構(gòu)建基于MINA的程序的過(guò)程夫否，逐步構(gòu)建一個(gè)時(shí)間服務(wù)器。開(kāi)發(fā)服務(wù)器端需要以下幾個(gè)先決條件：
〗行病１．MINA 2.x Core
』舜取２．JDK1.5或者更高
３．SLF4J1.3.0或者更高（注1中的下載文件中已經(jīng)包含了對(duì)應(yīng)的包）
- Log4J 1.2 的用戶需要的包：slf4j-api.jar,slf4j-log4j12.jar,和Log4J 1.2.x
- Log4J 1.3的用戶需要的包：slf4j-api.jar,slf4j-log4j13.jar,和Log4J 1.3.x
- java.util.logging的用戶需要的包：slf4j-api.jar和slf4j-jdk14.jar,
- 注：請(qǐng)確保你使用了正確的slf4j-*.jar匹配你的日志框架驼鹅。
實(shí)際上微谓， slf4j-log4j12.jar 和log4j-1.3.x.jar 不能一起使用，并且會(huì)發(fā)生故障输钩。
開(kāi)始服務(wù)器端代碼
首先創(chuàng)建java project項(xiàng)目豺型，和普通的創(chuàng)建方式一致，創(chuàng)建libs文件夾將需要的包復(fù)制進(jìn)去：
接下來(lái)創(chuàng)建對(duì)應(yīng)的服務(wù)類(lèi)：
package com.fmblzf.minaservice;
/**
*
* @Copy：2017-fmblzf
* @ProjectName：MINA_SERVER
* @ClassDecription：
* @ClassName：com.fmblzf.minaservice.MinaServerMain
* @Creator：zhaofeng
* @CreatTime：2017年5月27日 上午11:50:55
* @FixPerson：fmblzf
* @FixTime：2017年5月27日 上午11:50:55
* @Tag：
* @version V1.0
*
*/
public class MinaServerMain {
//設(shè)置端口號(hào)
private static final int PORT = 9321;
public static void main(String[] args) {
}
}
首先买乃，我們需要一個(gè)將用于偵聽(tīng)傳入連接的對(duì)象姻氨。由于該程序?qū)⒒赥CP/IP，我們將在我們的程序中添加一個(gè)SocketAcceptor剪验，我們創(chuàng)建對(duì)應(yīng)的NioSocketAcceptor對(duì)象肴焊，并且將其綁定到PORT端口上。
IoAcceptor ioAcceptor = new NioSocketAcceptor();
ioAcceptor.bind(new InetSocketAddress(PORT));
接下來(lái)設(shè)置過(guò)濾器功戚，配置Session娶眷，以及設(shè)置處理對(duì)象
public static void main(String[] args) throws IOException {
//首先，添加對(duì)應(yīng)的網(wǎng)絡(luò)監(jiān)聽(tīng)對(duì)象啸臀，等待處理連接和回復(fù)消息
IoAcceptor ioAcceptor = new NioSocketAcceptor();
//添加過(guò)濾器
ioAcceptor.getFilterChain().addLast("logger",new LoggingFilter());//設(shè)置日志管理過(guò)濾器
ioAcceptor.getFilterChain().addLast("codec", new ProtocolCodecFilter(new ObjectSerializationCodecFactory()));//設(shè)置字節(jié)處理過(guò)濾器
//添加IOHandler
ioAcceptor.setHandler(new MainServerHandler());
//添加Session配置
ioAcceptor.getSessionConfig().setReadBufferSize(2048);//設(shè)置讀緩存區(qū)的大小
ioAcceptor.getSessionConfig().setIdleTime(IdleStatus.BOTH_IDLE, 10);//設(shè)置讀寫(xiě)的空閑時(shí)間都是10秒
ioAcceptor.bind(new InetSocketAddress(PORT));
}
創(chuàng)建自定義的IoHandler對(duì)象
/**
* 邏輯處理類(lèi)
* @Copy：2017-fmblzf
* @ProjectName：MINA_SERVER
*
* @ClassDecription：
* @ClassName：com.fmblzf.minaservice.MainServerHandler
* @Creator：fmblzf
* @CreatTime：2017年5月27日 下午12:41:08
* @FixPerson：fmblzf
* @FixTime：2017年5月27日 下午12:41:08
* @Tag：
* @version V1.0
*
*/
private static class MainServerHandler extends IoHandlerAdapter{
/**
* 接收到消息
* @see org.apache.mina.core.service.IoHandlerAdapter#messageReceived(org.apache.mina.core.session.IoSession, java.lang.Object)
*
*/
@Override
public void messageReceived(IoSession session, Object message)
throws Exception {
String str = message.toString();
if( str.trim().equalsIgnoreCase("quit") ) {
session.closeNow();
return;
}
Date date = new Date();
session.write( date.toString() );
System.out.println("Message written...");
}
@Override
public void sessionIdle(IoSession session, IdleStatus status)
throws Exception {
System.out.println( "IDLE " + session.getIdleCount( status ));
}
/**
* 發(fā)送消息給客戶端
* @see org.apache.mina.core.service.IoHandlerAdapter#messageSent(org.apache.mina.core.session.IoSession, java.lang.Object)
*
*/
@Override
public void messageSent(IoSession session, Object message)
throws Exception {
}
@Override
public void sessionCreated(IoSession session) throws Exception {
}
@Override
public void sessionOpened(IoSession session) throws Exception {
}
@Override
public void sessionClosed(IoSession session) throws Exception {
}
}
示例UDP服務(wù)器
因?yàn)镸INA的統(tǒng)一API接口届宠，所以UDP和TCP在結(jié)構(gòu)上是一致的，只有IoAcceptor對(duì)應(yīng)的實(shí)現(xiàn)類(lèi)是不一致，所以接下來(lái)我們看一看UDP創(chuàng)建的核心代碼：
/**
* 創(chuàng)建UDP連接
* @Title: createUdp
* @Description: TODO
* @throws IOException
*
*/
private static void createUdp() throws IOException {
IoAcceptor ioAcceptor = new NioDatagramAcceptor();
// 添加過(guò)濾器
ioAcceptor.getFilterChain().addLast("logger", new LoggingFilter());// 設(shè)置日志管理過(guò)濾器
ioAcceptor.getFilterChain().addLast("codec",
new ProtocolCodecFilter(new ObjectSerializationCodecFactory()));// 設(shè)置字節(jié)處理過(guò)濾器
// 添加IOHandler
ioAcceptor.setHandler(new MainServerHandler());
// 添加Session配置
ioAcceptor.getSessionConfig().setReadBufferSize(2048);// 設(shè)置讀緩存區(qū)的大小
ioAcceptor.getSessionConfig().setIdleTime(IdleStatus.BOTH_IDLE, 10);// 設(shè)置讀寫(xiě)的空閑時(shí)間都是10秒
ioAcceptor.bind(new InetSocketAddress(PORT+1));
}
從代碼我們可以看見(jiàn)豌注，UDP的IoAcceptor的實(shí)現(xiàn)類(lèi)是NioDatagramAcceptor伤塌，其他的結(jié)構(gòu)編寫(xiě)都是一致。
至此我們的TCP/UDP的核心代碼已經(jīng)完成幌羞，至于其他的衍生部分寸谜，感興趣的朋友可以參考官網(wǎng)來(lái)接著學(xué)習(xí)。
