JAVA非阻塞编程.docVIP

例??EchoServer.java(非阻塞模式)?? import?java.io.*;?? import?java.nio.*;?? import?java.nio.channels.*;?? import?java.nio.charset.*;?? import?.*;?? import?java.util.*;?? ?? public?class?EchoServer?? {?? ????private?Selector?selector?=?null;?? ????private?ServerSocketChannel?serverSocketChannel?=?null;?? ????private?int?port?=?8000;?? ????private?Charset?charset?=?Charset.forName(GBK);?? ?? ????public?EchoServer()?throws?IOException?? ????{?? ????????selector?=?Selector.open();?? ????????serverSocketChannel?=?ServerSocketChannel.open();?? ????????serverSocketChannel.socket().setReuseAddress(true);?? ????????serverSocketChannel.configureBlocking(false);?? ????????serverSocketChannel.socket().bind(new?InetSocketAddress(port));?? ????????System.out.println(服务器启动);?? ????}?? ?? ????public?void?service()?throws?IOException?? ????{?? ????????serverSocketChannel.register(selector,?SelectionKey.OP_ACCEPT);?? ????????while(?selector.select()??0?)?? ????????{?? ????????????Set?readyKeys?=?selector.selectedKeys();?? ????????????Iterator?it?=?readyKeys.iterator();?? ????????????while(?it.hasNext()?)?? ????????????{?? ????????????????SelectionKey?key?=?null;?? ????????????????try?? ????????????????{?? ????????????????????key?=?(SelectionKey)it.next();?? ????????????????????it.remove();?? ????????????????????if(?key.isAcceptable()?)?? ????????????????????{?? ????????????????????????ServerSocketChannel?ssc?=?(ServerSocketChannel)key.channel();?? ????????????????????????SocketChannel?socketChannel?=?(SocketChannel)ssc.accept();?? ????????????????????????System.out.println(接收到客户连接，来自:?+?socketChannel.socket().getInetAddress()?? ????????????????????????????????+?:?+?socketChannel.socket().getPort());?? ????????????????????????socketChannel.configureBlocking(false);?? ????????????????????????ByteBuffer?buffer?=?ByteBuffer.allocate(1024);?? ????????????????????????socketChannel.register(selector,?SelectionKey.OP_READ?? ????????????????????????????????|?SelectionKey.OP_WRITE,?buffer);?? ???????