Java NIO非阻塞服务器示例VIP专享VIP免费

JavaNIO非阻塞服务器示例姓名：邓以克网名：phinecos(洞庭散人)MSN:phinecos@msn.com出处：http://phinecos.cnblogs.com/本文版权归作者所有，欢迎传阅，但请保留此段声明。以前一直用的是“erverythreadperconnection”的服务器端模式，今天试了下NIO非阻塞模式的服务器。不过java不能实现I/O完成端口模型，这点很遗憾packagecom.vista.Server;importjava.io.IOException;importjava.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;importjava.util.Set;publicclassSelectorServer{privatestaticintDEFAULT_SERVERPORT=6018;//默认端口privatestaticintDEFAULT_BUFFERSIZE=1024;//默认缓冲区大小为1024字节privateServerSocketChannelchannel;privateLinkedListclients;privateSelectorreadSelector;privateByteBufferbuffer;//字节缓冲区privateintport;publicSelectorServer(intport)throwsIOException{this.port=port;this.clients=newLinkedList();this.channel=null;this.readSelector=Selector.open();//打开选择器this.buffer=ByteBuffer.allocate(DEFAULT_BUFFERSIZE);}//服务器程序在服务循环中调用sericeClients()方法为已接受的客户服务publicvoidserviceClients()throwsIOException{Setkeys;Iteratorit;SelectionKeykey;SocketChannelclient;//在readSelector上调用select()方法，参数1代表如果调用select的时候那么阻塞最多1秒钟等待可用的客户端连接if(readSelector.select(1)>0){keys=readSelector.selectedKeys();//取得代表端通道的键集合it=keys.iterator();//遍历，为每一个客户服务while(it.hasNext()){key=(SelectionKey)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);//数据写回到通道中}elseif(bytes<0){//如果返回小于零的值代表读到了流的末尾clients.remove(client);//通道关闭时，选择键也被取消client.close();}}}}}publicvoidregisterClient(SocketChannelclient)throwsIOException{//配置和注册代表客户连接的通道对象client.configureBlocking(false);//设置此通道使用非阻塞模式client.register(readSelector,SelectionKey.OP_READ);//将这个通道注册到选择器上clients.add(client);//保存这个通道对象}publicvoidlisten()throwsIOException{//服务器开始监听端口，提供服务ServerSocketsocket;SocketChannelclient;channel=ServerSocketChannel.open();//打开通道socket=channel.socket();//得到与通到相关的socket对象socket.bind(newInetSocketAddress(port),10);//将scoket榜定在制定的端口上//配置通到使用非阻塞模式，在非阻塞模式下，可以编写多道程序同时避免使用复杂的多线程channel.configureBlocking(false);try{while(true){//与通常的程序不同，这里使用channel.accpet()接受客户端连接请求，而不是在socket对象上调用accept(),这里在调用accept()方法时如果通道配置为非阻塞模式,那么accept()方法立即返回null，并不阻塞client=channel.accept();if(client!=null){registerClient(client);//注册客户信息}serviceClients();//为以连接的客户服务}}finally{socket.close();//关闭socket，关闭socket会同时关闭与此socket关联的通道}}publicstaticvoidmain(String[]args)throwsIOException{System.out.println("服务器启动");SelectorServerserver=newSelectorServer(SelectorServer.DEFAULT_SERVERPORT);server.liste...