Apache Mina使用JSON数据进行通信的使用方法

最近使用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 漫过心际的孤独,早已蔚然成冰,而你是这个季节里最美的音符。

Apache Mina使用JSON数据进行通信的使用方法

相关文章:

你感兴趣的文章:

标签云: