AIO与NIO的实际区别是什么

本篇内容主要讲解“AIO与NIO的实际区别是什么”，感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷，实用性强。下面就让小编来带大家学习“AIO与NIO的实际区别是什么”吧! 1. 从某种程度上来说，NIO依然是同步阻塞的虽然NIO中Channel（网络Channel）和Buffer可以实现非阻塞的read/write操作，而且Selector提供了多路复用的功能，使得可以在一个线程中管理使用多个IO通道，避免了传统IO的存在的问题。但是，NIO中在Selector进行调用select()方法进行通道选择时，其依旧是同步阻塞的，而且由于多个Channel注册于Selector上，这个方法会同时阻塞多个IO请求操作，尽管select()方法可以设置超时返回，但依旧是不利的。换句话说，虽然NIO在网络操作中，提供了非阻塞的read/write方法，但是NIO的IO行为还是同步的。对于NIO来说，我们的业务线程是在IO操作准备好时（调用Selector中的select()方法），得到通知（select()方法返回，表示有准备好的Channel），接着就由这个线程自行进行IO操作（通过Channel进行read/write操作），在第一代NIO中，每个线程可以持有多个IO通道并选择使用，但实际上一个线程还是只能选择操作一个IO，IO操作本身是同步的。 2. NIO改进
为了真正实现异步非阻塞的IO操作，在NIO的基础上进行改进，升级为2代NIO——即AIO机制。AIO相比于NIO，则更加进了一步，它不是在IO准备好时再通知线程，而是在IO操作已经完成后，再给线程发出通知。因此AIO是不会阻塞的，此时我们的业务逻辑将变成一个回调函数，等待IO操作完成后，由系统自动触发。也就是相当于在AIO中，当进行读写操作时，只须直接调用API的read或write方法即可。这两种方法均为异步的，对于读操作而言，当有流可读取时，操作系统会将可读的流传入read方法的缓冲区，并通知应用程序；对于写操作而言，当操作系统将write方法传递的流写入完毕时，操作系统主动通知应用程序。即可以理解为，read/write方法都是异步的，完成后会主动调用回调函数。主要在Java.nio.channels包下增加了下面四个异步通道：AsynchronousSocketChannelAsynchronousServerSocketChannelAsynchronousFileChannelAsynchronousDatagramChannel在AIO socket编程中，服务端通道是AsynchronousServerSocketChannel，这个类提供了一个open()静态工厂，一个bind()方法用于绑定服务端IP地址（还有端口号），另外还提供了accept()用于接收用户连接请求。在客户端使用的通道是AsynchronousSocketChannel,这个通道处理提供open静态工厂方法外，还提供了read和write方法。在AIO编程中，发出一个事件（accept read write等）之后要指定事件处理类（回调函数），AIO中的事件处理类是CompletionHandler，这个接口定义了如下两个方法，分别在异步操作成功和失败时被回调。void completed(V result, A attachment);void failed(Throwable exc, A attachment); 3. AIO与NIO的实际区别在JAVA NIO框架中，我们说到了一个重要概念“selector”（选择器）。它负责代替应用查询中所有已注册的通道到操作系统中进行IO事件轮询、管理当前注册的通道集合，定位发生事件的通道等操操作。但是在JAVA AIO框架中，由于应用程序不是“轮询”方式，而是订阅-通知方式，所以不再需要“selector”（选择器）了，改由channel通道直接到操作系统注册监听。异步IO则采用“订阅-通知”模式：即应用程序向操作系统注册IO监听，然后继续做自己的事情。当操作系统发生IO事件，并且准备好数据后，在主动通知应用程序，触发相应的函数。这就使得AIO真正意义上实现了异步阻塞模式。（AIO是依赖于操作系统的实现的）和同步IO一样，异步IO也是由操作系统进行支持的。微软的windows系统提供了一种异步IO技术：IOCP（I/O CompletionPort，I/O完成端口）；
Linux下由于没有这种异步IO技术，所以使用的是epoll（类似于Selector的一种多路复用IO技术的实现）对异步IO进行模拟。 1.java.nio.channels.AsynchronousChannel：这是一个接口，用来标记一个channel支持异步IO操作。有主要的三个子类AsynchronousFileChannel、AsynchronousSocketChannel和AsynchronousServerSocketChannel，分别对应FileChannel、SocketChannel以及ServerSocketChannel。（很奇怪为什么没有AsynchronousDatagramChannel） 2.AsynchronousChannelGroup：异步channel的分组管理，目的是为了资源共享。一个AsynchronousChannelGroup绑定一个线程池，这个线程池执行三个任务：等待IO事件、处理IO数据和派发CompletionHandler。AsynchronousServerSocketChannel创建的时候可以传入一个AsynchronousChannelGroup，那么通过AsynchronousServerSocketChannel创建的 AsynchronousSocketChannel将同属于一个组，共享资源，（可以理解为相当于Selector）。AsynchronousChannelGroup需要绑定线程池来创建，通过三个静态方法来创建，可以需要根据具体应用相应调整。 3.CompletionHandler：异步IO操作结果的回调接口，用于定义在IO操作完成后所作的回调工作。AIO的API允许两种方式来处理异步操作的结果，返回的Future模式或者注册CompletionHandler，常用CompletionHandler的方式，这些handler的调用是由AsynchronousChannelGroup的线程池派发的。显然，线程池的大小是性能的关键因素。CompletionHandler接口有两个个方法，分别对应于处理成功、失败、被取消（通过返回的Future)情况下的回调处理： 4. ByteBuffer：负责承载通信过程中需要读、写的消息。使用方式主要为三步：打开通道、绑定监听端口、接收客户端连接请求。1. 打开（创建）通道可以通过调用AsynchronousServerSocketChannel的静态方法open()来创建AsynchronousServerSocketChannel实例或者在open()方法传入AsynchronousChannelGroup参数，设置通道分组，以实现组内通道资源共享。如果通道打开失败，就会抛出IOExceptionAsynchronousChannelGroup封装了处理由绑定到组的异步通道所触发的I/O操作完成所需的机制。每个AsynchronousChannelGroup关联了一个被用于提交处理I/O事件和分发消费在组内通道上执行的异步操作结果的completion-handlers的线程池。除了处理I/O事件，该线程池还有可能处理其他一些用于支持完成异步I/O操作的任务。从上面例子可以看到，通过指定AsynchronousChannelGroup的方式打开AsynchronousServerSocketChannel，可以定制server channel执行的线程池。如果不指定AsynchronousChannelGroup，则AsynchronousServerSocketChannel会归类到一个默认的分组中。 2. 绑定监听端口和地址通过调用bind()方法来绑定要监听的端口。 3.监听和接收客户端连接请求监听客户端连接请求，主要通过调用accept()方法完成。accept()有两个重载方法：这两个重载方法的行为方式完全相同，提供CompletionHandler回调参数或者返回一个Future类型变量。Future版本的accept方法通过Future接口可以调用Future.get()方法阻塞等待调用结果，返回一个AsynchronousSocketChannel对象。而CompletionHandler回调参数版本则相反，真正的数据IO处理并不会放在当前线程中，而是通过一个回调方法处理，处理逻辑代码就写在CompletionHandler中的completed方法中，因为该方法会在AsynchronousServerSocketChannel成功接收到一个AsynchronousSocketChannel，回调执香港云主机行，而如果AsynchronousServerSocketChannel接受AsynchronousSocketChannel失败，就会回调failed方法。为什么会在completed方法中调用accept方法：因为当一个新的客户端建立连接之后，就会回调completed方法，一个AsynchronousServerSocketChannel会与多个客户端建立连接，此时就需要继续调用accept方法来接受更多的客户端连接。 4. 设置TCP连接属性：通过一个AsynchronousServerSocketChannel建立的连接肯定是TCP连接了，所以通过该对象我们可以设置TCP连接的一些属性。获取本地IP地址 1. 创建连接首先需要调用open方法创建一个AsynchronousSocketChannel对象，然后通过connect方法与服务端建立连接。connect方法也有两个重载版本一个版本是返回Future对象，另一种是传入CompletionHandler参数对象 2. 写数据构建一个ByteBuffer对象并调用socketChannel.write(ByteBuffer)方法异步发送消息，并通过CompletionHandler回调接收处理发送结果： 3. 读数据构建一个指定接收长度的ByteBuffer用于接收数据，调用socketChannel.read()方法读取消息并通过CompletionHandler处理读取结果： 4. 通过AsynchronousSocketChannel也可以设置设置/获取socket选项（TCP连接属性） 1.AIO中定义的异步通道允许指定一个CompletionHandler处理器消费一个异步操作的结果（也就是当准备好IO数据通道后，就回调CompletionHandler中的方法，使用IO数据通道进行IO处理，这也就导致了异步操作，不在等候IO通道的就绪，也不用将IO操作在当前线程中执行，而是采用回调的方式）。从上文中也可以看到，AIO中大部分的异步I/O操作接口都封装了一个带CompletionHandler类型参数的重载方法，使用CompletionHandler可以很方便地处理AIO中的异步I/O操作结果。CompletionHandler是一个具有两个泛型类型参数的接口,声明了两个接口方法： NIO以及AIOU虽然实现了异步非阻塞网络IO操作，但是，其依旧具有一些缺点：虽然JAVA NIO 和 JAVA AIO框架提供了多路复用IO/异步IO的支持，但是并没有提供上层“信息格式”的良好封装。例如前两者并没有提供针对 ProtocolBuffer、JSON这些信息格式的封装，但是Netty框架提供了这些数据格式封装（基于责任链模式的编码和解码功能）要编写一个可靠的、易维护的、高性能的（注意它们的排序）NIO/AIO服务器应用。除了框架本身要兼容实现各类操作系统的实现外。更重要的是它应该还要处理很多上层特有服务，例如：客户端的权限、还有上面提到的信息格式封装、简单的数据读取。这些Netty框架都提供了响应的支持。JAVA NIO框架存在一个poll/epoll bug：Selector doesn’t block onSelector.select(timeout)，不能block意味着CPU的使用率会变成100%（这是底层JNI的问题，上层要处理这个异常实际上也好办）。当然这个bug只有在Linux内核上才能重现。这个问题在JDK 1.7版本中还没有被完全解决：http://bugs.java.com/bugdatabase/view_bug.do?bug_id=2147719。虽然Netty 4.0中也是基于JAVA NIO框架进行封装的（上文中已经给出了Netty中NioServerSocketChannel类的介绍），但是Netty已经将这个bug进行了处理。到此，相信大家对“AIO与NIO的实际区别是什么”有了更深的了解，不妨来实际操作一番吧！这里是开发云网站，更多相关内容可以进入相关频道进行查询，关注我们，继续学习！

相关推荐: 快速学习hadoop只有这些基础可不行

“学习hadoop需要什么基础”这已经不是一个新鲜的话题了，随便上网搜索一下就能找出成百上千篇的文章在讲学习hadoop需要掌握的基础。再直接的一点的问题就是——学Hadoop难吗？用一句特别让人无语的话回答就是：难不会，会不难！趁着学校放假的时间，写了一些h…