最近使用Mina开发一个在线聊天的项目,因此也特意学习了Apache的这个Mina框架。
首先,Mina是个什么东西?看下官方网站()对它的解释:
Apache的Mina(Multipurpose Infrastructure Networked Applications)是一个网络应用框架,可以帮助用户开发高性能和高扩展性的网络应用程序;它提供了一个抽象的、事件驱动的异步API,使Java NIO在各种传输协议(如TCP/IP,UDP/IP协议等)下快速高效开发。
Apache Mina也称为:
总之:我们简单理解它是一个封装底层IO操作,提供高级操作API的通讯框架!
在Mina的官网、以及网上都有比较丰富的文档了,这里我就稍微简单说一下Mina的结构和示例代码。
因为Mina2.X改进了Mina的代码结构和包结构,降低了使用的复杂性和增强了健壮性,网站空间,所以使得API发生了比较大的改变,有许多地方已经和Mina1.x不兼容了。
我这里要实现的是在线聊天功能,所以其中使用的数据并不单一,香港虚拟主机,所以这里采用了JOSN的数据格式,虚拟主机,我这里是采用UTF-8的编码。
使用的Mina版本为2.0.4
具体的开发过程,比如导包和建立项目什么的我就不说了,这里直接上代码。
(1)服务端代码TcpServer
我这里使用的是Mina自带TextLineCodecFactory
View Code
1 package com.lrcx.ky.server; java.io.IOException; 4 import java.net.InetSocketAddress; 5 import java.nio.charset.Charset; 6 import java.util.concurrent.Executors; org.apache.mina.core.service.IoServiceStatistics; 9 import org.apache.mina.core.session.IdleStatus;10 import org.apache.mina.filter.codec.ProtocolCodecFilter;11 import org.apache.mina.filter.codec.textline.LineDelimiter;12 import org.apache.mina.filter.codec.textline.TextLineCodecFactory;13 import org.apache.mina.filter.executor.ExecutorFilter;14 import org.apache.mina.transport.socket.SocketAcceptor;15 import org.apache.mina.transport.socket.nio.NioSocketAcceptor; com.lrcx.ky.env.SysEnv; TcpServer {port = 8292;idleTime = 1800;bufferSize = 1024;24private SocketAcceptor acceptor; start() {27acceptor = new NioSocketAcceptor(Runtime.getRuntime().availableProcessors() + 1);28TextLineCodecFactory lineCodec = new TextLineCodecFactory(Charset29.forName(“UTF-8”), LineDelimiter.WINDOWS.getValue(),30 LineDelimiter.WINDOWS.getValue());31lineCodec.setDecoderMaxLineLength(2*1024*1024);32lineCodec.setEncoderMaxLineLength(2*1024*1024);33acceptor.getFilterChain().addLast(“codec”, new ProtocolCodecFilter(lineCodec));34acceptor.getFilterChain().addLast(“exceutor”, new ExecutorFilter(Executors.newCachedThreadPool()));35acceptor.setHandler(new TcpHandler());36acceptor.setReuseAddress(true);37acceptor.setBacklog(10240);38acceptor.getSessionConfig().setReuseAddress(true);39 acceptor.getSessionConfig().setReadBufferSize(bufferSize);40 acceptor.getSessionConfig().setReceiveBufferSize(bufferSize);41acceptor.getSessionConfig().setTcpNoDelay(true);42acceptor.getSessionConfig().setSoLinger(-1);acceptor.getSessionConfig().setIdleTime(IdleStatus.BOTH_IDLE, idleTime); {47acceptor.bind(new InetSocketAddress(port));48} catch (IOException e) {49e.printStackTrace();System.exit(0);50 }51 } stop() {54 acceptor.dispose();55 }5657 }
代码中的这两行:
lineCodec.setDecoderMaxLineLength(2*1024*1024);lineCodec.setEncoderMaxLineLength(2*1024*1024);
是用来设置每次传输文本的长度的。
(2)服务端处理器代码TcpHandler
View Code 漫过心际的孤独,早已蔚然成冰,而你是这个季节里最美的音符。