网站建设优化论坛,关键词设定在网站上,邯郸推广公司,网站每天1万ip能收入多少转载自 java中的AIO简介jdk7中新增了一些与文件(网络)I/O相关的一些api。这些API被称为NIO.2#xff0c;或称为AIO(Asynchronous I/O)。AIO最大的一个特性就是异步能力#xff0c;这种能力对socket与文件I/O都起作用。AIO其实是一种在读写操作结束之前允许进行其他操作的I/O…转载自 java中的AIO简介jdk7中新增了一些与文件(网络)I/O相关的一些api。这些API被称为NIO.2或称为AIO(Asynchronous I/O)。AIO最大的一个特性就是异步能力这种能力对socket与文件I/O都起作用。AIO其实是一种在读写操作结束之前允许进行其他操作的I/O处理。AIO是对JDK1.4中提出的同步非阻塞I/O(NIO)的进一步增强。关于NIO,之前的一篇文章可以看看java中的NIOjdk7主要增加了三个新的异步通道:AsynchronousFileChannel: 用于文件异步读写AsynchronousSocketChannel: 客户端异步socketAsynchronousServerSocketChannel: 服务器异步socket。因为AIO的实施需充分调用OS参与IO需要操作系统支持、并发也同样需要操作系统的支持所以性能方面不同操作系统差异会比较明显。前提概念在具体看AIO之前我们需要知道一些必要的前提概念。Unix中的I/O模型Unix定义了五种I/O模型阻塞I/O非阻塞I/OI/O复用select、poll、linux 2.6种改进的epoll信号驱动IOSIGIO异步I/OPOSIX的aio_系列函数一个戏谑的例子如果你想吃一份宫保鸡丁盖饭同步阻塞你到饭馆点餐然后在那等着还要一边喊好了没啊同步非阻塞在饭馆点完餐就去遛狗了。不过溜一会儿就回饭馆喊一声好了没啊异步阻塞遛狗的时候接到饭馆电话说饭做好了让您亲自去拿。异步非阻塞饭馆打电话说我们知道您的位置一会给你送过来安心遛狗就可以了。详情参见文章末尾的他山之石-Unix下五种IO模型。Reactor与Proactor两种IO多路复用方案:Reactor and Proactor。Reactor模式是基于同步I/O的而Proactor模式是和异步I/O相关的。reactor能收了你跟俺说一声。proactor: 你给我收十个字节收好了跟俺说一声。详情参见文章末尾的他山之石-IO设计模式Reactor和Proactor对比。异步的处理异步无非是通知系统做一件事情。然后忘掉它自己做其他事情去了。很多时候系统做完某一件事情后需要一些后续的操作。怎么办这时候就是告诉异步调用如何做后续处理。通常有两种方式将来式: 当你希望主线程发起异步调用并轮询等待结果的时候使用将来式;回调式: 常说的异步回调就是它。以文件读取为例将来式将来式异步读取将来式用现有的Java.util.concurrent技术声明一个Future,用来保存异步操作的处理结果。通常用Future get()方法带或不带超时参数在异步IO操作完成时获取其结果。AsynchronousFileChannel会关联线程池它的任务是接收IO处理事件并分发给负责处理通道中IO操作结果的结果处理器。跟通道中发起的IO操作关联的结果处理器确保是由线程池中的某个线程产生。将来式例子 Path path Paths.get(/data/code/github/java_practice/src/main/resources/1log4j.properties);AsynchronousFileChannel channel AsynchronousFileChannel.open(path);ByteBuffer buffer ByteBuffer.allocate(1024);FutureInteger future channel.read(buffer,0);
// while (!future.isDone()){
// System.out.println(Im idle);
// }Integer readNumber future.get();buffer.flip();CharBuffer charBuffer CharBuffer.allocate(1024);CharsetDecoder decoder Charset.defaultCharset().newDecoder();decoder.decode(buffer,charBuffer,false);charBuffer.flip();String data new String(charBuffer.array(),0, charBuffer.limit());System.out.println(read number: readNumber);System.out.println(data);回调式回调式异步读取回调式所采用的事件处理技术类似于Swing UI编程采用的机制。基本思想是主线程会派一个侦查员CompletionHandler到独立的线程中执行IO操作。这个侦查员将带着IO的操作的结果返回到主线程中这个结果会触发它自己的completed或failed方法要重写这两个方法。在异步IO活动结束后接口java.nio.channels.CompletionHandler会被调用其中V是结果类型A是提供结果的附着对象。此时必须已经有了该接口completedV,A和failed(V,A)方法的实现你的程序才能知道异步IO操作成功或失败时该如何处理。回调式例子 Path path Paths.get(/data/code/github/java_practice/src/main/resources/1log4j.properties);AsynchronousFileChannel channel AsynchronousFileChannel.open(path);ByteBuffer buffer ByteBuffer.allocate(1024);channel.read(buffer, 0, buffer, new CompletionHandlerInteger, ByteBuffer() {Overridepublic void completed(Integer result, ByteBuffer attachment) {System.out.println(Thread.currentThread().getName() read success!);}Overridepublic void failed(Throwable exc, ByteBuffer attachment) {System.out.println(read error);}});while (true){System.out.println(Thread.currentThread().getName() sleep);Thread.sleep(1000);}异步socket client操作 AsynchronousSocketChannel channel AsynchronousSocketChannel.open();channel.connect(new InetSocketAddress(127.0.0.1,8888)).get();ByteBuffer buffer ByteBuffer.wrap(中文,你好.getBytes());FutureInteger future channel.write(buffer);future.get();System.out.println(send ok);异步socket server操作 final AsynchronousServerSocketChannel channel AsynchronousServerSocketChannel.open().bind(new InetSocketAddress(0.0.0.0,8888));channel.accept(null, new CompletionHandlerAsynchronousSocketChannel, Void() {Overridepublic void completed(final AsynchronousSocketChannel client, Void attachment) {channel.accept(null, this);ByteBuffer buffer ByteBuffer.allocate(1024);client.read(buffer, buffer, new CompletionHandlerInteger, ByteBuffer() {Overridepublic void completed(Integer result_num, ByteBuffer attachment) {attachment.flip();CharBuffer charBuffer CharBuffer.allocate(1024);CharsetDecoder decoder Charset.defaultCharset().newDecoder();decoder.decode(attachment,charBuffer,false);charBuffer.flip();String data new String(charBuffer.array(),0, charBuffer.limit());System.out.println(read data: data);try{client.close();}catch (Exception e){}}Overridepublic void failed(Throwable exc, ByteBuffer attachment) {System.out.println(read error);}});}Overridepublic void failed(Throwable exc, Void attachment) {System.out.println(accept error);}});while (true){Thread.sleep(1000);}他山之石java中的NIO: http://www.jianshu.com/p/a33f741fe450Unix下五种IO模型:http://www.cnblogs.com/virusolf/p/4946975.htmlIO设计模式: Reactor和Proactor对比:https://segmentfault.com/a/1190000002715832proactor: http://www.laputan.org/pub/sag/proactor.pdfJava7中增加的新特性:http://wn398.github.io/2014/04/01/Java7%E4%B8%AD%E5%A2%9E%E5%8A%A0%E7%9A%84%E6%96%B0%E7%89%B9%E6%80%A7/基于Java NIO2实现的异步非阻塞消息通信框架:http://codepub.cn/2016/02/26/Asynchronous-non-blocking-message-communication-framework-based-on-Java-NIO2/Java新一代网络编程模型AIO原理及Linux系统AIO介绍:http://www.52im.net/thread-306-1-1.htmljava aio 编程: http://colobu.com/2014/11/13/java-aio-introduction/[高并发Java 八] NIO和AIO: https://my.oschina.net/hosee/blog/615269
