Mina的入门（一）

1．介绍概念

2．环境的搭建

3．一个hello world 的demo。

4．框架的解析

一．什么是MINA

首先，Mina(Multipurpose Infrastructure Networked Applications)是Apache开源组织下的一个高性能的网络应用框架，它可以帮助用户开发高性能和高扩展性的网络应用程序，它提供了一个抽象的、事件驱动的异步API，使得Java NIO(非阻塞式)在各种传输协议下快速高效开发。

总之：我们简单理解它是一个封装底层IO操作，提供高级操作API的通讯框架！

二．环境的搭建

第一步：导入jar包

第二步：日志文件的配置

创建一个java project ,添加配置文件 log4j.properties

log4j.rootLogger=DEBUG,MINA,file

log4j.appender.MINA=org.apache.log4j.ConsoleAppender

log4j.appender.MINA.layout=org.apache.log4j.PatternLayout

log4j.appender.MINA.layout.ConversionPattern=%d{yyyy-MM-ddHH\:mm\:ss,SSS}%-5p%c{1}%x-%m%n

log4j.appender.file=org.apache.log4j.RollingFileAppender

log4j.appender.file.File=./log/minademos.log

log4j.appender.file.MaxFileSize=5120KB

log4j.appender.file.MaxBackupIndex=10

log4j.appender.file.layout=org.apache.log4j.PatternLayout

log4j.appender.file.layout.ConversionPattern=[VAMS][%d]%p|%m|[%t]%C.%M(%L)%n

第三步：开始Hello World 的小Demo

第一个小例子：

服务端：

Demo1Server.java

package com.bjsxt.mina.server;

import java.net.InetSocketAddress;

import java.nio.charset.Charset;

import org.apache.log4j.Logger;

import org.apache.mina.common.IdleStatus;

import org.apache.mina.common.IoAcceptor;

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.transport.socket.nio.NioSocketAcceptor;

import com.bjsxt.mina.handler.Demo1ServerHandler;

/**

*

* 创建服务端最主要的就是绑定服务端的消息编码解码过滤器和业务逻辑处理器；

* @author Administrator

*

*/

public class Demo1Server {

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

private static int PORT = 3005;

public static void main(String[]args) {

IoAcceptor acceptor = null; // 创建连接

try {

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

acceptor = newNioSocketAcceptor();

// 设置过滤器（使用Mina提供的文本换行符编解码器）

acceptor.getFilterChain().addLast(

// 添加消息过滤器

"codec",

newProtocolCodecFilter(new TextLineCodecFactory(Charset

.forName("UTF-8"),

LineDelimiter.WINDOWS.getValue(),

LineDelimiter.WINDOWS.getValue())));

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

acceptor.getSessionConfig().setReadBufferSize(2048);

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

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

// 绑定逻辑处理器

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

// 绑定端口

acceptor.bind(newInetSocketAddress(PORT));

logger.info("服务端启动成功... 端口号为：" + PORT);

} catch (Exception e) {

logger.error("服务端启动异常....", e);

e.printStackTrace();

}

}

}

Demo1ServerHandler.java

package com.bjsxt.mina.handler;

import java.util.Date;

import org.apache.log4j.Logger;

import org.apache.mina.common.IdleStatus;

import org.apache.mina.common.IoHandlerAdapter;

import org.apache.mina.common.IoSession;

public class Demo1ServerHandler extends IoHandlerAdapter {

public static Logger logger =Logger.getLogger(Demo1ServerHandler.class);

@Override

public voidsessionCreated(IoSession session) throws Exception {

logger.info("服务端与客户端创建连接...");

}

@Override

public voidsessionOpened(IoSession session) throws Exception {

logger.info("服务端与客户端连接打开...");

}

@Override

public voidmessageReceived(IoSession session, Object message)

throws Exception {

String msg =message.toString();

logger.info("服务端接收到的数据为：" + msg);

if("bye".equals(msg)) { // 服务端断开连接的条件

session.close();

}

Date date = new Date();

session.write(date);

}

@Override

public void messageSent(IoSessionsession, Object message) throws Exception {

session.close();

logger.info("服务端发送信息成功...");

}

@Override

public voidsessionClosed(IoSession session) throws Exception {

}

@Override

public void sessionIdle(IoSessionsession, IdleStatus status)

throws Exception {

logger.info("服务端进入空闲状态...");

}

@Override

public voidexceptionCaught(IoSession session, Throwable cause)

throws Exception {

logger.error("服务端发送异常...", cause);

}

}

注意：创建服务端最主要的就是绑定服务端的消息编码解码过滤器和业务逻辑处理器；

业务逻辑处理器是Demo1ServerHandler

测试第一个小例子。。。。

Mina的底层通信无疑是用socket实现的，它封装后提供给我们一个简单易用的接口。

例子二：

模拟手机的短信的发送

package com.bjsxt.mina.server;

import java.net.InetSocketAddress;

import java.nio.charset.Charset;

import org.apache.log4j.Logger;

import org.apache.mina.common.IdleStatus;

import org.apache.mina.common.IoAcceptor;

import org.apache.mina.common.IoSessionConfig;

importorg.apache.mina.filter.codec.ProtocolCodecFilter;

importorg.apache.mina.filter.codec.serialization.ObjectSerializationCodecFactory;

importorg.apache.mina.filter.codec.textline.LineDelimiter;

importorg.apache.mina.filter.codec.textline.TextLineCodecFactory;

importorg.apache.mina.transport.socket.nio.NioSocketAcceptor;

importcom.bjsxt.mina.handler.ShortMsgServerHandler;

/**

*@author Administrator--jiangyu--2014-9-11下午8:17:14

* 服务器端

*/

public class ShortMsgServer {

privatestatic Logger logger = Logger.getLogger(ShortMsgServer.class);

privatestatic int PORT = 3006;

publicstatic void main(String[] args) {

IoAcceptoracceptor = null;

try{

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

// acceptor = new NioDatagramAcceptor();

acceptor = new NioSocketAcceptor();

//直接发送对象信息

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

newTextLineCodecFactory(Charset

.forName("UTF-8"),LineDelimiter.WINDOWS.getValue(),

LineDelimiter.WINDOWS.getValue())));

//获得IosessionConfig对象

IoSessionConfigcfg = acceptor.getSessionConfig();

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

cfg.setIdleTime(IdleStatus.BOTH_IDLE,100);

//绑定逻辑处理器

acceptor.setHandler(newShortMsgServerHandler());

//绑定短端口号

acceptor.bind(newInetSocketAddress(PORT));

logger.info("服务端启动成功。。。 端口号为："+PORT);

}catch (Exception e) {

logger.error("服务端启动异常。。。",e);

e.printStackTrace();

}

}

}

package com.bjsxt.mina.handler;

import org.apache.log4j.Logger;

importorg.apache.mina.common.IoHandlerAdapter;

import org.apache.mina.common.IoSession;

/**

*

* 服务端业务逻辑处理

*@author Administrator--jiangyu--2014-9-11下午8:17:05

*

*/

public class ShortMsgServerHandler extendsIoHandlerAdapter{

publicstatic Logger logger = Logger.getLogger(ShortMsgServerHandler.class);

@Override

publicvoid messageReceived(IoSession session, Object message) throws Exception {

StringphoneMes = message.toString();

String[]megs = phoneMes.split(";");

StringsendPhone = megs[0];

StringreceivePhone = megs[1];

Stringmes = megs[2];

logger.info("发送人的手机号码："+sendPhone);

logger.info("接收人的手机号码："+receivePhone);

logger.info("发送消息为："+mes);

//短信信息存入移动服务端数据库或者写入手机短信转发队列

session.write("发送成功");

}

@Override

publicvoid messageSent(IoSession session, Object message) throws Exception {

//发送成功后主动断开与客户端的连接

session.close();

}

@Override

publicvoid exceptionCaught(IoSession session, Throwable cause)

throwsException {

logger.error("服务端发送异常...", cause);

}

}

package com.bjsxt.mina.client;

import java.net.InetSocketAddress;

import java.nio.charset.Charset;

import org.apache.log4j.Logger;

import org.apache.mina.common.ConnectFuture;

import org.apache.mina.common.IoConnector;

import org.apache.mina.common.IoSession;

importorg.apache.mina.filter.codec.ProtocolCodecFilter;

importorg.apache.mina.filter.codec.textline.LineDelimiter;

importorg.apache.mina.filter.codec.textline.TextLineCodecFactory;

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

importcom.bjsxt.mina.handler.ShortMsgClientHandler;

/**

*@author Administrator--jiangyu--2014-9-11下午8:17:01

* 客户端

*/

public class ShortMsgClient {

privatestatic Logger logger = Logger.getLogger(ShortMsgClient.class);

privatestatic String HOST = "127.0.0.1";

privatestatic int PORT = 3006;

publicstatic void main(String[] args) {

//创建一个非阻塞式的客户端程序

IoConnectorconnector = new NioSocketConnector();

//设置连接超时时间

connector.setConnectTimeout(30000);

//设置过滤器

connector.getFilterChain().addLast("codec",newProtocolCodecFilter(

newTextLineCodecFactory(Charset.forName("UTF-8"),

LineDelimiter.WINDOWS.getValue(),

LineDelimiter.WINDOWS.getValue())));

//添加业务逻辑处理类

connector.setHandler(newShortMsgClientHandler());

IoSessionsession = null;

try{

//创建连接

ConnectFuturefuture = connector.connect(

newInetSocketAddress(HOST, PORT));

//等待连接创建完成

future.awaitUninterruptibly();

//获得session

session= future.getSession();

//PhotoMsgDtosendMes =

//set

//发送人的手机号码

StringsendPhone = "13681803609";

//接受人的手机号码

StringreceivePhone = "13721427169";

//发送的消息

Stringmessage = "Hello world!!";

Stringmsg = sendPhone + ";" + receivePhone + ";" + message;

session.write(msg);

}catch (Exception e) {

logger.error("客户端连接异常...", e);

}

}

}

package com.bjsxt.mina.handler;

import org.apache.log4j.Logger;

importorg.apache.mina.common.IoHandlerAdapter;

import org.apache.mina.common.IoSession;

/**

* 客户端业务逻辑处理

* @authorAdministrator--jiangyu--2014-9-11 下午8:16:46

* 业务逻辑处理类，这个是重点！业务很简单，如果服务器接收信息成功，就返回接收信息成功的信息。在今后用mina写应用程序时，它是重点之一。

*

*/

public class ShortMsgClientHandler extendsIoHandlerAdapter {

privatestatic Logger logger = Logger

.getLogger(ShortMsgClientHandler.class);

@Override

publicvoid messageReceived(IoSession session, Object message)

throwsException {

Stringmsg = message.toString();

logger.info("客户端接收到的信息为：" + msg);

}

@Override

publicvoid exceptionCaught(IoSession session, Throwable cause)

throwsException {

logger.error("客户端发生异常...", cause);

}

}

服务端程序或客户端程序创建过程：

创建连接---添加消息过滤器(编码解码等)——>添加业务处理

直接发送一个java对象 new ObjectSerializationCodecFactory() 使用dto

总结：

通过上面的练习，基本可以使用Mina开发小的应用程序啦。

下面就总结一下：

首先，看Mina在项目中所处的位置，如下图：

Mina处于中间层，它不关心底层网络数据如何传输，只负责接收底层数据，过滤并转换为Java对象提供给我们的应用程序，然后把应用程序响应值过滤并转换为底层识别的字节，提供给底层传输；

------总之：Mina是底层数据传输和用户应用程序交互的接口！

Mina工作流程图如下：

这个流程图不仅很直观的看出了Mina的工作流程，也涵盖了Mina的三个核心接口:IoService接口，IoFilter接口和IoHandler接口：

l第一步. 创建服务对象（客户端或服务端） ---IoService接口实现

l第二步. 数据过滤（编码解码等）---IOFilter接口实现

l第三步. 业务处理 ---IoHandler接口实现

Mina的精髓是IOFilter，它可以进行日志记录，信息过滤，编码解码等操作，把数据接收发送从业务层独立出来。创建服务对象，则是把NIO繁琐的部分进行封装，提供简洁的接口。业务处理是我们最关心的部分，跟普通的应用程序没任何分别。

Socket编程俗称Java网络编程，是JavaWeb开发的精髓！做J2EE的人可能很少关心多线程，NIO等等这些东西，但是不可否认它却实时与我们打交道，比如常用的web容器Tomcat。