Apache Mina简单实例

hgjgh

一.简介
MINA是一个网络应用框架，也可被称之为NIO框架库、客户端/服务器框架库、网络套接字 (socket)库，可以帮助用户开发高性能和高可扩展性的网络应用程序，支持(TCP/IP、UDP/IP协议)等。
二.工作流程
MINA处于中间层，它不关心数据是如何在底层网络进行传输，只负责接受底层数据，将数据通过过滤器过滤并装换成JAVA对象，供应用程序使用，然后在应用程序对数据做过业务处理之后，将响应值过滤且转换成底层能识别的二进制数据，提供给底层传输。总之，MINA是底层数据和应用程序交互的接口。
第一步，创建服务对象(服务端、客户端)  ----IoService接口实现
第二步，数据过滤(编解码器)           ----IoFilter接口实现
第三步，业务处理                       ----IoHandler接口实现
IoFilter是MINA的精髓，可以进行日志记录，信息过滤，编解码等操作，把数据接收发送从业务层独立出来。
IoService对NIO进行了封装，提供简介接口，来创建服务对象。
IoHandler是我们最关心的部分，负责对接收/发送数据做了业务逻辑处理
三.服务端实例
private static Logger logger = Logger.getLogger(Demo1Server.class);
private static final int PORT = 3005;
public static void main(String[] args) {
IoAcceptor acceptor = new NioSocketAcceptor();
acceptor.addListener(new ServerListener());
acceptor.getFilterChain().addLast(
"codec",
new ProtocolCodecFilter(new MyTextLineCodecFactory()));
// 设置读取数据的缓冲区大小
acceptor.getSessionConfig().setReadBufferSize(2048);
// 读写通道10秒内无操作进入空闲状态
acceptor.getSessionConfig().setIdleTime(IdleStatus.BOTH_IDLE, 10);
// 绑定逻辑处理起器
acceptor.setHandler(new Demo1ServerHandler());
// 绑定端口
try {
acceptor.bind(new InetSocketAddress(PORT));
logger.info("服务器启动成功。。。。端口为：" + PORT);
} catch (IOException e) {
logger.error("服务器启动异常。。。。", e);
e.printStackTrace();
}
}

四.客户端实例
private Logger logger = Logger.getLogger(Demo2Client.class);
private static final String HOST = "127.0.0.1";
private static final int PORT = 3005;
public static void main(String[] args) {
// 创建一个非阻塞的客户端程序
IoConnector connector = new NioSocketConnector();
// 设置连接超时时间 单位毫秒
connector.setConnectTimeout(30000);
// 添加过滤器
connector.getFilterChain().addLast(
"codec",
new ProtocolCodecFilter(new MyTextLineCodecFactory()));
// 添加业务逻辑处理类
connector.setHandler(new Demo2ClientHandler());
// 创建连接
IoSession session = null;
try {
ConnectFuture connect = connector.connect(new InetSocketAddress(
HOST, PORT));
// 等待连接创建完成
connect.awaitUninterruptibly();
// 获取session
session = connect.getSession();
session.write("我爱你，mina！！！！");
} catch (Exception e) {
System.out.println("客户端连接异常");
}
session.getCloseFuture().awaitUninterruptibly();
connector.dispose();
}

五.编解码器实例
5.1 编码器
private Logger logger = Logger.getLogger(MyTextLineCodecEncoder.class);
//字符编码类型
private Charset charset = Charset.forName("UTF-8");
@Override
public void dispose(IoSession arg0) throws Exception {
}
@Override
public void encode(IoSession arg0, Object obj, ProtocolEncoderOutput out)
throws Exception {
logger.info("开始编码...........");
IoBuffer io = IoBuffer.allocate(100).setAutoExpand(true);
CharsetEncoder ce = charset.newEncoder();
io.putString(obj.toString(), ce);
io.put((byte)'\r');
io.put((byte)'\n');
io.flip();
out.write(io);
}
5.2 解码器
private Logger logger = Logger.getLogger(MyTextLineCodecDecoder.class);
//字符编码类型
private Charset charset = Charset.forName("UTF-8");
//设置数据存放的IoBuffer大小
private IoBuffer ioBuffer = IoBuffer.allocate(1024).setAutoExpand(true);
@Override
public void decode(IoSession session, IoBuffer in, ProtocolDecoderOutput out)
throws Exception {
logger.info("开始解码...........");
while(in.hasRemaining()){
byte by = in.get();
//将数据存放到IoBuffer中
ioBuffer.put(by);
//数据解码结束标记
if(by == '\n'){
ioBuffer.flip();
byte[] b = new byte[ioBuffer.limit()];
ioBuffer.get(b);
String msg = new String(b,charset);
//重置ioBuffer
ioBuffer = IoBuffer.allocate(100).setAutoExpand(true);
out.write(msg);
}
}
}