常见NIO开源框架（MINA、xSocket）学习 1

【一年前的项目，翻出来总结下】

基于io包的阻塞式socket通信代码简单，在连接数很少的情况下是一个不错的选择。不过实际应用中一个socket服务器采用传统的阻塞式socket方式通信可能会是一场灾难，一路socket同时进行读写操作可能就需要两条线程，如果需要并发一百路socket（这个量其实很小了），可能就是两百条线程，大概几分钟后cpu占用率就是高居不下了。

基于原生nio的socket通信时一种很好的解决方案，基于事件的通知模式使得多并发时不用维持高数量的线程，高并发的socket服务器的java实现成为现实。不过原生nio代码十分复杂，无论编写还是修改都是一件头疼的事。“屏蔽底层的繁琐工作，让程序员将注意力集中于业务逻辑本身”，有需求就有生产力进步，于是各式各样的nio框架涌现而出，而笔者使用到的是其中最常见的两种：xSocket和MINA。

1 xsocket框架

官网：http://xsocket.sourceforge.net/

xSocket是一套非常简洁的nio框架，利用这套框架，你可以在完全不了解nio的情况下设计出高并发的socket服务器。
server端代码：

public class ProjectServer extends Thread {
	
	private static final int PORT=9099;
	
	public void run() {
		IServer srv = null;
		try {
			//建立handler
			srv = new Server(PORT, new ProjectHandle());
		} catch (UnknownHostException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		//服务器运行
		srv.run();
		System.out.println("The ProjectServer start on port: "+PORT);
	}
	
	public static void main(String[] args) {
		ProjectServer projectServer = new ProjectServer();
		projectServer.start();
	}
}

handler代码

public class ProjectHandle implements IDataHandler, IConnectHandler,
		IDisconnectHandler {
	/* 处理连接建立事件 */
	@Override
	public boolean onConnect(INonBlockingConnection nbc) throws IOException,
			BufferUnderflowException, MaxReadSizeExceededException {
		// TODO Auto-generated method stub
		System.out.println(nbc.getId() + "is connect!");
		return true;
	}

	/* 处理连接断开事件 */
	@Override
	public boolean onDisconnect(INonBlockingConnection nbc) throws IOException {
		// TODO Auto-generated method stub
		System.out.println(nbc.getId() + "is disconnect!");
		return true;
	}

	/* 处理接受数据事件 */
	@Override
	public boolean onData(INonBlockingConnection nbc) throws IOException,
			BufferUnderflowException, ClosedChannelException,
			MaxReadSizeExceededException {
		// TODO Auto-generated method stub
		String str = nbc.readStringByDelimiter("\0");
		System.out.println(str);
		return true;
	}
}

这里我们以"\0"为间隔读取数据，xSocket还提供按照长度读取以及全部读取到一个ByteBuffer几种读取数据的方式，如果传递过程中采取byte数组格式，在接受数据时还可以使用xSocket自带的工具类DataConverter进行转化。譬如接收数据时如此操作：

ByteBuffer copyBuffer = ByteBuffer.allocate(20000);
nbc.read(copyBuffer);
copyBuffer.flip();
String str = DataConverter.toString(copyBuffer, "utf-8");

就可以将二进制格式的传输内容还原为原始字符串了。

需要说明的是虽然xSocket代码简单、开发快捷，但是由于太“上层”了，所以很多地方不利于coder自己控制。譬如socket通信中一个很常见的“半包连包”问题用xsocket处理起来就会很麻烦，而且如果传输协议是经过特殊设计的，xsocket也无法像mina那样自己编写解码器。当然如果你不是特别计较这些方面，那么非常适于上手的xSocket就是适合你的nio框架。

另，附件中为xsocket所需要的jar包，下载后直接加载项目中即可使用。

【续：http://unbounder.iteye.com/blog/481668】

评论

2 楼 jd2bs 2010-09-15  

onData() 中实现解码肯定是可以的   无非是按协议格式解析数据而已


半包连包问题 不仅xsocket存在 Mina也同样存在

下面这篇文章 提供了一个解决的思路 ：
http://www.blogjava.net/adapterofcoms/articles/314560.html

没仔细看过Netty  听说Netty处理起来更简单

1 楼 windywany 2009-12-23  

关于解码,能否详细说明一下,既然能传递二进制数据,那么在IDataHandler中实现解码不行吗?