Java NIO、BIO、 AIO 与 同步、阻塞、非阻塞、异步IO 简析

简介: 我相信大部分人看到这些名词,都是一头雾水的,如果你去搜索引擎搜索,那么恭喜你,你又会被各种文章中的高大上的名词搞得云里雾里。那么,我们应该怎么理清这么名词之间的关系呢?所谓 同步/异步/阻塞/非阻塞 IO ,是指操作系统中的对 IO 处理的不同方法,而 Java 对这些不同操作方法做了一些包装,由此有了 BIO / NIO / AIO 几种操作接口。我不想复制一些高大上的概念,只是想尽量好好说话,说清楚他们之间的关系。需求有 A、B、C、D 四个线程可以生产文件,假设他们的返回的文件是一样的,对应我们的服务端有 E、F、G、H 四个线程在随机时间向服务端上传一个文本,并且要求

我相信大部分人看到这些名词,都是一头雾水的,如果你去搜索引擎搜索,那么恭喜你,你又会被各种文章中的高大上的名词搞得云里雾里。那么,我们应该怎么理清这么名词之间的关系呢?

所谓 同步/异步/阻塞/非阻塞 IO ,是指操作系统中的对 IO 处理的不同方法,而 Java 对这些不同操作方法做了一些包装,由此有了 BIO / NIO / AIO 几种操作接口。

我不想复制一些高大上的概念,只是想尽量好好说话,说清楚他们之间的关系。

需求

  1. 有 A、B、C、D 四个线程可以生产文件,假设他们的返回的文件是一样的,对应我们的服务端
  2. 有 E、F、G、H 四个线程在随机时间向服务端上传一个文本,并且要求返回一个文件,对应我们的客户端

服务端和客户端可以在同一个操作系统中,也可以是在网络中。

在网络中,客户端的请求会接入到服务端的操作系统内核,所以和在同一个操作系统中没有太大区别。

如果在网络中,那么这可能就是一个 TCP/HTTP 的模型。

问题:要怎么设计一个程序来的完成上面的操作?

系统 IO 缓冲区

在讲之前,还要明白系统内核中的 IO 缓冲区的概念。

在现实生活中,一个人想要把想法告诉另外一个人,有两种方法,一种是靠嘴说给他听,对方要不停的确认,这样是很慢的。另外一种是直接写一篇 10 页的文稿一次性发给另外一个人,另外一个人有问题再重写一份文档把所有问题写在上面,那么多了这个文档的缓冲区,就可以提高交流的效率。

在系统里面,对两个用户之间的传输操作,首先会建立一个连接,然后会创建一个专用的缓冲区。

缓冲区有四个状态

我们现在有一个情景,就是用户端 E 向服务端 A 在随机时间上传一份文件。缓冲区会经历这四个状态。

  1. 缓冲区空:E 心情不好,还没传文件,这个时候缓冲区是空的
  2. 缓冲区非空:E 开始往缓冲区里面传数据了,现在缓冲区是非空的,A 知道之后会来查收
  3. 缓冲区满:如果 A 一直没查收这个文件,或者 A 的查收速度没有 E 上传的速度那么块。那么缓冲区会被填满。这个时候 E 知道了,就先等着。
  4. 缓冲区非满:E 等了一段时间,A 终于处理了一些 E 上传的数据了,缓冲区又有空间了,缓冲区把状态设置为缓冲区非满,E 知道之后,又可以往缓冲区传数据了。

最终,经过上面的“博弈”,缓冲区最终为空,文件传输完成。接下来可能又要有下一轮文件传输。

我们的几个 IO 模型就是围绕着上面的博弈展开的。

同步

关于 A 如何查收 缓冲区中的内容,我们有同步和异步两种模式。绝大部分应用都是同步查收的。就是说,A 主动 从缓冲区 剪切、粘贴 到自己的用户空间里面。剪切、粘贴的时间 CPU 要等着啥也不干,这个过程是比较费时的,但是也没有办法。

同步阻塞

我们来讨论另外一个问题,就是 A 怎么知道 E 要来传文件呢?换一种说法就是,A 怎么知道缓冲区由空变成非空了,要工作了。

阻塞就是这样一种方法:A 在缓冲区非空的时候,就把自己阻塞住(休眠),等着,啥也不干,一直到缓冲区非空了,系统就叫醒 A,A 这个时候就会从缓冲区查收数据了。A 处理完之后又把自己阻塞住,等待下一个非空状态。

这样做的坏处是什么呢?就是 E、F、G、H 想在随机时间 往 服务端传文件,建立了连接之后,服务端上面就要有 A、B、C、D 四个线程等着啥也不干。但是我们知道,创建线程是需要消耗内存的,这样子客户端多了之后,系统内存就捉襟见肘了。

同步非阻塞

1.0 版:忙轮询

非阻塞和阻塞相反。A 是不阻塞(休眠)的,他会定时定点就检查一下缓冲区是不是非空(可读)了,如果可读就可以工作了。

这样做有一个好处,就是 A 可以一次性把 E、F、G、H 接进来,创建四个缓冲区。然后把这些连接保存成一个 list ,然后 A 定时就检查这个 list 中的连接的缓冲区的状态。这样一个 A 就可以处理多个客户端,处理效率就提高了。

这种一条线程接进来多个客户端的操作,也叫 IO 多路复用。

但是如果是由应用层来遍历,也未免有点太傻了,如果 E、F、G、H 一直不传文件,A 就要一直耗费 CPU 去定时查询,所以这个傻事要由操作系统统一去干。

2.0 版: select、poll

我们把定时查询这个任务就交给系统去做,我们只需要把我们关心的用户的连接 ID(缓冲区)告诉系统。比如还是上面的例子,A 先自己把自己阻塞住,当 E、F、G、H 没有活干的时候,就一直保持阻塞状态。当 E、F、G、H 其中之一往系统内核的缓冲区上传了数据,那么,系统就会唤醒 A,并且告诉他,起来干活了。不过这个时候 A 对于要查收谁的文件还是一脸懵逼的,只能再自己去遍历一遍所有连接的缓冲区,看看哪个缓冲区的状态是非空的,然后再读。这就是 Select 的大致原理。

这样做避免了 1.0 版的 CPU 空转,但是唤醒 A 之后,A 还必须自己去遍历一下所有客户端连接的列表,是一个 O(n) 的操作,所以这个列表不能太长,select 简单粗暴的就定为了 1024 个。 也就是说默认一个线程只能处理 1024 个客户端。poll 改进了 list 的储存结构,这样就可以存更多的连接,不过也是治标不治本呀。

3.0 版: epoll

epoll 是 select 的改进

  1. 使用了更优的数据结构来管理连接列表,使得定位的时候更快
  2. 唤醒 A 之后,会传给他缓冲区非空的连接,A 直接使用即可。而不只是告诉 A 醒来,让 A 自己去找。所以这里是一个 O (1) 的复杂度。

这是目大多数网络应用的底层实现。

4.0 版: Eventloop

Eventloop 并不是操作系统底层的实现,但是在应用层提供了一种更高效的复用思路。

在 传统 epoll 应用中,普通线程只负责客户端的连接的读写操作,如果客户端没有操作,那么线程会被阻塞。而我们要做一些额外的事情可能就要再开线程。

那么,我们还有另外一种复用线程的思路,就是 Eventloop,我们有一个比较小的线程池,每个线程 都有一个 Eventloop, 上面有个事件队列,一方面,Eventloop 尝试 epoll,并且设置阻塞的超时时间,如果到达时间,仍没有客户端读写事件,就先处理事件队列上面的其他事件。我们可以打包一些要做的函数进事件队列,那么本来是负责 Epoll 的线程在本来应该阻塞的时候,还可以做些别的任务。这样就减少了整个系统的线程数量。

当然,要注意,我们有时候也叫 Eventloop 这种实现是异步的,但是和我们整篇文章讲的同步异步并不是在一个区域,我们讲的是系统级的连接的 IO 操作。而 Eventloop 则是一种在应用级的多任务调度方式。

异步

我们之前说了,在系统 IO 中,对于同步异步的概念,是说 A 如何查收 缓冲区中的内容。

而异步的意思是说,调用之后,马上返回一个内存引用,这个引用什么时候填充数据我们并不知道,但是我们可以告诉这个引用填充完数据之后应该干什么。然后这个事件会打包进任务队列,在不定时间执行。

异步 IO 的方式,我们的 A 就可以先开好一个用户空间的内存区域,然后把查收之后要做的事情打包成一个函数,全部告诉给内核,然后内核会自动帮你把数据从内核缓冲区复制到你指定的用户空间,然后调用你指定的函数。

这样,在 IO 读写的时候,阻塞的是系统内部的线程,而不是我们的 A 线程,这样 A 线程的处理效率会提高,也不用一直在阻塞和继续中徘徊。当然,也就没有阻塞还是非阻塞的区别了。

JDK 在 linux 上面的 AIO 实现方法是去维护一个线程池(Linux 的异步 IO 接口不给力)。而在 Windows 上面则有 IOCP 的异步 IO 黑科技,主要是在 IIS 上面使用。

然而,因为从内核缓冲区复制到用户空间这个地方的时间仍然是没有办法避免的,所以 IOCP 比 epoll 的 Eventloop 在性能上其实并没有太大优势,只是说是内核做异步在线程调度上面更有优势,可以节省一些 CPU 使用。

JDK 实现

IO

最传统的java.io 包下面的 ServerSocket 的写法,只支持阻塞同步。

NIO

普通java.nio 的用法

可以选择同步阻塞模式,和传统 IO 一致

也可以选择同步非阻塞 IO 的实现,底层的话,Windows 下面使用底层的 select ,Linux 下面使用底层的 epoll

AIO

java.nio.channels.Asynchronou* 下面的包的调用

AIO 是异步的实现,底层方面,在 Linux 使用 JDK 自建线程池,在 Windows 下面使用 IOCP,不过据说还是有些 bug

应用实现

Netty

Netty 默认是使用 NIO 底层 (同步非阻塞)。

但是在应用层面上,使用 Eventloop 的异步实现,即用一个比较小的线程池同时处理用户端的连接、数据复制,解析数据和执行业务代码。通常,Netty 已经帮我们将相关客户端的数据读取和解析(比如解析 HTTP 请求),我们只需要写具体的业务代码即可。通常,在业务代码中,我们应该尽可能少的使用同步代码,数据库读取也使用异步 NIO 连接(比如,使用 NIO 客户端 连接 MongoDB 或者 Redis ),从而最大化压缩线程因阻塞而浪费的时间。而确实可能会导致阻塞的耗时操作,也用异步封装成事件,发到另外的大线程池中。这样可以用较少的线程完成较多的任务,同时阻塞的时间尽可能小,以达到性能最大化的目的。

Netty 曾经也尝试过 AIO 作为底层,不过最后因为性能比 NIO 差,和兼容性的问题而放弃。为什么差我们也可以做一个猜测,就是 Netty 有一个 Eventloop 线程池 ,和操作系统的 AIO 线程池没有很好兼容,反而增多更多性能损耗。

Tomcat

Tomcat 默认是使用 NIO 底层(同步非阻塞),并且也是异步实现(Acceptor 和 Poller 和 Netty 的 Eventloop 模型如出一辙),我们跑的 SpringBoot 等等都可以跑在 Tomcat 上面,速度理论上是不错的。

可惜在 Tomcat 对于每一个请求,将我们整个 Servlet 、管道、监听器、拦截器 所有东西都打包在一起(当然里面全部都是同步的代码),形成一个超级大的 Runable ,发到线程池上面,导致整个处理请求的过程中多处都要同步等待(比如读取数据库,一般使用同步的方式,如 JDBC 是典型的同步应用),而等待的时间是要占着当前线程的,导致同时处理的任务量过大时,Tomcat 性能非常差。

这也告诉我们,NIO 并不是解决所有问题的万能药,如果我们在 Netty 中运行大量会阻塞很久的同步的代码,也会导致 Netty 性能大幅下降。

其他

另外,Nginx 、 Nodejs、Redis 网络底层都是 select 或者 epoll,也就是说,在系统层面,IO 是同步非阻塞的,只是在应用的任务调度层面,是异步的。而异步 IO 阵营可以说是门前冷落了,IOCP 只有 IIS 在大规模使用。

相关文章
|
2月前
|
并行计算 数据处理 Python
Python并发编程迷雾:IO密集型为何偏爱异步?CPU密集型又该如何应对?
在Python的并发编程世界中,没有万能的解决方案,只有最适合特定场景的方法。希望本文能够为你拨开迷雾,找到那条通往高效并发编程的光明大道。
47 2
|
1天前
|
监控 Java API
探索Java NIO:究竟在哪些领域能大显身手?揭秘原理、应用场景与官方示例代码
Java NIO(New IO)自Java SE 1.4引入,提供比传统IO更高效、灵活的操作,支持非阻塞IO和选择器特性,适用于高并发、高吞吐量场景。NIO的核心概念包括通道(Channel)、缓冲区(Buffer)和选择器(Selector),能实现多路复用和异步操作。其应用场景涵盖网络通信、文件操作、进程间通信及数据库操作等。NIO的优势在于提高并发性和性能,简化编程;但学习成本较高,且与传统IO存在不兼容性。尽管如此,NIO在构建高性能框架如Netty、Mina和Jetty中仍广泛应用。
13 3
|
8天前
|
存储 监控 Java
Java的NIO体系
通过本文的介绍,希望您能够深入理解Java NIO体系的核心组件、工作原理及其在高性能应用中的实际应用,并能够在实际开发中灵活运用这些知识,构建高效的Java应用程序。
26 5
|
2月前
|
存储 消息中间件 安全
JUC组件实战:实现RRPC(Java与硬件通过MQTT的同步通信)
【10月更文挑战第9天】本文介绍了如何利用JUC组件实现Java服务与硬件通过MQTT的同步通信(RRPC)。通过模拟MQTT通信流程,使用`LinkedBlockingQueue`作为消息队列,详细讲解了消息发送、接收及响应的同步处理机制,包括任务超时处理和内存泄漏的预防措施。文中还提供了具体的类设计和方法实现,帮助理解同步通信的内部工作原理。
JUC组件实战:实现RRPC(Java与硬件通过MQTT的同步通信)
|
1月前
|
消息中间件 缓存 Java
java nio,netty,kafka 中经常提到“零拷贝”到底是什么?
零拷贝技术 Zero-Copy 是指计算机执行操作时,可以直接从源(如文件或网络套接字)将数据传输到目标缓冲区, 而不需要 CPU 先将数据从某处内存复制到另一个特定区域,从而减少上下文切换以及 CPU 的拷贝时间。
java nio,netty,kafka 中经常提到“零拷贝”到底是什么?
|
1月前
|
Java 调度
Java 线程同步的四种方式,最全详解,建议收藏!
本文详细解析了Java线程同步的四种方式:synchronized关键字、ReentrantLock、原子变量和ThreadLocal,通过实例代码和对比分析,帮助你深入理解线程同步机制。关注【mikechen的互联网架构】,10年+BAT架构经验倾囊相授。
Java 线程同步的四种方式,最全详解,建议收藏!
|
2月前
|
安全 Java 开发者
Java多线程中的`wait()`、`notify()`和`notifyAll()`方法,探讨了它们在实现线程间通信和同步中的关键作用
本文深入解析了Java多线程中的`wait()`、`notify()`和`notifyAll()`方法,探讨了它们在实现线程间通信和同步中的关键作用。通过示例代码展示了如何正确使用这些方法,并分享了最佳实践,帮助开发者避免常见陷阱,提高多线程程序的稳定性和效率。
52 1
|
2月前
|
Java
让星星⭐月亮告诉你,Java NIO之Buffer详解 属性capacity/position/limit/mark 方法put(X)/get()/flip()/compact()/clear()
这段代码演示了Java NIO中`ByteBuffer`的基本操作,包括分配、写入、翻转、读取、压缩和清空缓冲区。通过示例展示了`position`、`limit`和`mark`属性的变化过程,帮助理解缓冲区的工作原理。
38 2
|
4月前
|
存储 Java
【IO面试题 四】、介绍一下Java的序列化与反序列化
Java的序列化与反序列化允许对象通过实现Serializable接口转换成字节序列并存储或传输,之后可以通过ObjectInputStream和ObjectOutputStream的方法将这些字节序列恢复成对象。
|
5月前
|
Java 大数据
解析Java中的NIO与传统IO的区别与应用
解析Java中的NIO与传统IO的区别与应用