Apache Mina简单实例
一.简介
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();// 获取sessionsession = connect.getSession();session.write("我爱你，mina！！！！");} catch (Exception e) {System.out.println("客户端连接异常");}session.getCloseFuture().awaitUninterruptibly();connector.dispose();}private Logger logger = Logger.getLogger(MyTextLineCodecEncoder.class);//字符编码类型private Charset charset = Charset.forName("UTF-8");@Overridepublic void dispose(IoSession arg0) throws Exception {}@Overridepublic 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);}private Logger logger = Logger.getLogger(MyTextLineCodecDecoder.class);//字符编码类型private Charset charset = Charset.forName("UTF-8");//设置数据存放的IoBuffer大小private IoBuffer ioBuffer = IoBuffer.allocate(1024).setAutoExpand(true);@Overridepublic 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);//重置ioBufferioBuffer = IoBuffer.allocate(100).setAutoExpand(true);out.write(msg);}}}