java nio非阻塞服务器示例

《java nio非阻塞服务器示例》由会员上传分享，免费在线阅读，更多相关内容在行业资料-天天文库。

1、Mina2.0快速入门与源码剖析JavaNIO非阻塞服务器示例姓名：邓以克网名：phinecos(洞庭散人)MSN:phinecos@msn.com出处：http://phinecos.cnblogs.com/本文版权归作者所有，欢迎传阅，但请保留此段声明。第7页共8页Mina2.0快速入门与源码剖析以前一直用的是“erverythreadperconnection”的服务器端模式，今天试了下NIO非阻塞模式的服务器。不过java不能实现I/O完成端口模型，这点很遗憾packagecom.vista.Server;importjava.io.IOException;impor

2、tjava.net.InetSocketAddress;importjava.net.ServerSocket;importjava.nio.ByteBuffer;importjava.nio.channels.SelectionKey;importjava.nio.channels.Selector;importjava.nio.channels.ServerSocketChannel;importjava.nio.channels.SocketChannel;importjava.util.Iterator;importjava.util.LinkedList;impor

3、tjava.util.Set;publicclassSelectorServer{privatestaticintDEFAULT_SERVERPORT=6018;//默认端口privatestaticintDEFAULT_BUFFERSIZE=1024;//默认缓冲区大小为1024字节privateServerSocketChannelchannel;privateLinkedListclients;privateSelectorreadSelector;privateByteBufferbuffer;//字节缓冲区privateintport;

4、publicSelectorServer(intport)throwsIOException{this.port=port;this.clients=newLinkedList();this.channel=null;this.readSelector=Selector.open();//打开选择器this.buffer=ByteBuffer.allocate(DEFAULT_BUFFERSIZE);}//服务器程序在服务循环中调用sericeClients()方法为已接受的客户服务publicvoidserviceClients()throws

5、IOException{Setkeys;Iteratorit;SelectionKeykey;SocketChannelclient;//在readSelector上调用select()方法，参数1代表如果调用select的时候第7页共8页Mina2.0快速入门与源码剖析那么阻塞最多1秒钟等待可用的客户端连接if(readSelector.select(1)>0){keys=readSelector.selectedKeys();//取得代表端通道的键集合it=keys.iterator();//遍历，为每一个客户服务while(it.hasNext()){key=(Sele

6、ctionKey)it.next();if(key.isReadable()){//如果通道可读，那么读此通道到buffer中intbytes;client=(SocketChannel)key.channel();//取得键对应的通道buffer.clear();//清空缓冲区中的内容，设置好position,limit，准备接受数据bytes=client.read(buffer);//从通道中读数据到缓冲中，返回读取得字节数if(bytes>=0){buffer.flip();//准备将缓冲中的数据写回到通道中client.write(buffer);//数据写回到通道

7、中}elseif(bytes<0){//如果返回小于零的值代表读到了流的末尾clients.remove(client);//通道关闭时，选择键也被取消client.close();}}}}}publicvoidregisterClient(SocketChannelclient)throwsIOException{//配置和注册代表客户连接的通道对象client.configureBlocking(false);//设置此通道使用非阻塞模式client.register(readSelector,Se