JAVA NIO的实例.docVIP

JAVA NIO的实例 分类： java应用 2010-07-19 21:29 525人阅读 评论(0) 收藏 举报 JAVA NIO的实例 ? 1：JAVA NIO简介 ??????????? Java NIO非堵塞技术实际是采取Reactor模式，或者说是Observer模式为我们监察I/O端口，假如有内容进来，会自动通知我们，这样，我们就不必开启多个线程死等，从外界看，实现了流畅的I/O读写，不堵塞了。NIO 有一个主要的类Selector,这个类似一个观察者，只要我们把需要探知的socketchannel告诉Selector,我们接着做别的事情，当有事件发生时，他会通知我们，传回一组SelectionKey,我们读取这些Key,就会获得我们刚刚注册过的socketchannel,然后，我们从这个Channel中读取数据，放心，包准能够读到，接着我们可以处理这些数据。Selector内部原理实际是在做一个对所注册的channel的轮询访问，不断的轮询(目前就这一个算法)，一旦轮询到一个channel有所注册的事情发生，比如数据来了，他就会站起来报告，交出一把钥匙，让我们通过这把钥匙来读取这个channel的内容。　　 2： 服务器端：SumServer.java类 ? [java] view plaincopyprint? package?nio;?? import?java.io.IOException;?? import?java.net.InetSocketAddress;?? import?java.net.Socket;?? import?java.nio.ByteBuffer;?? import?java.nio.IntBuffer;?? import?java.nio.channels.SelectionKey;?? import?java.nio.channels.Selector;?? import?java.nio.channels.ServerSocketChannel;?? import?java.nio.channels.SocketChannel;?? import?java.nio.channels.spi.SelectorProvider;?? import?java.util.Iterator;?? import?java.util.Set;?? /**? ?*?SumServer.java? ?*?? ?*?? ?*?Created:?Thu?Nov?06?11:41:52?2003? ?*?? ?*?@author?starchu1981? ?*?@version?1.0? ?*/?? public?class?SumServer?{?? ????private?ByteBuffer?_buffer?=?ByteBuffer.allocate(8);?? ????private?IntBuffer?_intBuffer?=?_buffer.asIntBuffer();?? ????private?SocketChannel?_clientChannel?=?null;?? ????private?ServerSocketChannel?_serverChannel?=?null;?? ????public?void?start()?{?? ????????try?{?? ????????????openChannel();?? ????????????waitForConnection();?? ????????}?catch?(IOException?e)?{?? ????????????System.err.println(e.toString());?? ????????}?? ????}?? ????private?void?openChannel()?throws?IOException?{?? ????????_serverChannel?=?ServerSocketChannel.open();?? ????????_serverChannel.socket().bind(new?InetSocketAddress(10001));?? ????????_serverChannel.configureBlocking(false);//?设置为非阻塞形式 ?? ????????System.out.println(服务器通道已经打开);?? ????}?? ????/*? ?????*?private?void?waitForConnection()?throws?IOException?{?while?(true)?{? ?????*?_clientCh