Java NIO：非阻塞IO的革命性进步
咦咦咦，各位小可爱，我是你们的好伙伴——bug菌，今天又来给大家普及Java SE相关知识点了，别躲起来啊，听我讲干货还不快点赞，赞多了我就有动力讲得更嗨啦！所以呀，养成先点赞后阅读的好习惯，别被干货淹没了哦~
🏆本文收录于「滚雪球学Java」专栏中，这个专栏专为有志于提升Java技能的你打造，覆盖Java编程的方方面面，助你从零基础到掌握Java开发的精髓。赶紧关注，收藏，学习吧！
环境说明：Windows 10 + IntelliJ IDEA 2021.3.2 + Jdk 1.8
前言
Java NIO（New Input/Output）于Java 1.4引入，旨在解决传统IO（Blocking IO）的性能瓶颈问题。NIO提供了非阻塞IO操作、缓冲区处理和多路复用能力，使其成为构建高性能网络和文件操作应用程序的强大工具。
在现代分布式系统、服务器端编程和高并发场景下，Java NIO的优势尤为突出。本文将深入探讨Java NIO的核心原理、使用场景、性能分析以及其代码实现。
摘要
Java NIO是一种非阻塞的IO模型，允许开发者在高并发场景下高效地处理数据流。与传统的阻塞IO相比，NIO引入了Channel、Buffer和Selector等概念，实现了IO操作的非阻塞处理和多路复用机制。本文将从NIO的架构、核心API入手，结合实际代码案例，详细介绍NIO的应用场景和优缺点分析，帮助读者掌握Java NIO的基本原理和实际开发方法。
简介
传统的Java IO是基于阻塞模型的，即在执行读写操作时，线程会被阻塞，直到操作完成。这种方式在高并发环境下效率较低，因为每个线程在IO操作完成之前会一直占用系统资源。为了解决这个问题，Java 1.4引入了NIO，它支持非阻塞操作，允许一个线程同时处理多个连接。
Java NIO的核心概念包括：
- 通道（Channel）：数据的双向通道，可以通过它读写数据。
- 缓冲区（Buffer）：数据的存储容器，所有的数据操作都在缓冲区中进行。
- 选择器（Selector）：管理多个通道，允许一个线程处理多个连接。
概述
Java NIO的架构
Java NIO的架构与传统IO有显著差异，NIO基于以下三个关键组件：
- 通道（Channel）：
Channel类似于传统IO中的Stream，但与Stream不同的是，Channel是双向的，既可以读数据也可以写数据。例如，FileChannel、SocketChannel。 - 缓冲区（Buffer）：数据必须先写入
Buffer，然后通过Channel进行传输。缓冲区是NIO的核心之一，因为所有的IO操作都是通过缓冲区进行的。常见的缓冲区有ByteBuffer、CharBuffer。 - 选择器（Selector）：
Selector是Java NIO中的一个关键组件，允许一个线程监控多个通道，处理多路复用的IO操作，极大地提高了系统的并发能力。
核心组件示意图
+------------+ +------------+ +-----------+
| Selector |----->| Channel |----->| Buffer |
+------------+ +------------+ +-----------+
Java NIO的特点
- 非阻塞：传统IO的读写操作会阻塞线程，直到操作完成，而NIO则允许线程继续执行其他任务，等待IO事件触发后再处理数据。
- 多路复用：通过
Selector机制，NIO允许单个线程同时管理多个通道，从而提高了并发处理能力。 - 面向缓冲区：所有的NIO操作都是基于缓冲区的，数据在通道与缓冲区之间传输。
核心源码解读
Channel与Buffer
在Java NIO中，Channel负责数据的传输，Buffer负责数据的存储。
FileChannel源码示例
FileInputStream fis = new FileInputStream("data.txt");
FileChannel fileChannel = fis.getChannel();
ByteBuffer buffer = ByteBuffer.allocate(1024);
int bytesRead = fileChannel.read(buffer);
buffer.flip();
FileChannel 是 Channel 的具体实现类，用于文件IO。通过 read() 方法，数据从 Channel 读取到 Buffer 中，而 flip() 方法则准备 Buffer 以便读取。
ByteBuffer的核心方法
allocate()：分配一个缓冲区。put()：将数据写入缓冲区。get()：从缓冲区读取数据。flip()：将缓冲区从写模式切换到读模式。
Selector与多路复用
Selector允许一个线程同时管理多个通道，是NIO非阻塞IO的核心。
Selector使用示例
Selector selector = Selector.open();
SocketChannel socketChannel = SocketChannel.open();
socketChannel.configureBlocking(false);
socketChannel.register(selector, SelectionKey.OP_READ);
while (true) {
int readyChannels = selector.select();
if (readyChannels == 0) continue;
Set<SelectionKey> selectedKeys = selector.selectedKeys();
Iterator<SelectionKey> keyIterator = selectedKeys.iterator();
while (keyIterator.hasNext()) {
SelectionKey key = keyIterator.next();
if (key.isReadable()) {
SocketChannel channel = (SocketChannel) key.channel();
ByteBuffer buffer = ByteBuffer.allocate(1024);
channel.read(buffer);
// 处理读取的数据
}
keyIterator.remove();
}
}
Selector的工作流程
- 创建
Selector和SocketChannel。 - 将
SocketChannel配置为非阻塞模式，并注册到Selector。 - 使用
select()方法检查哪些通道准备好进行IO操作。 - 遍历
SelectionKey集合，处理可读或可写的通道。
案例分析
案例：使用NIO实现非阻塞服务器
在高并发场景下，传统的阻塞式服务器需要为每个客户端连接分配一个线程，系统资源消耗大。而NIO通过非阻塞模式，可以让单个线程管理多个客户端连接，提高服务器的并发性能。
非阻塞服务器代码
import java.io.IOException;
import java.net.InetSocketAddress;
import java.nio.ByteBuffer;
import java.nio.channels.SelectionKey;
import java.nio.channels.Selector;
import java.nio.channels.ServerSocketChannel;
import java.nio.channels.SocketChannel;
import java.util.Iterator;
public class NIOServer {
public static void main(String[] args) throws IOException {
Selector selector = Selector.open();
ServerSocketChannel serverSocketChannel = ServerSocketChannel.open();
serverSocketChannel.bind(new InetSocketAddress(8080));
serverSocketChannel.configureBlocking(false);
serverSocketChannel.register(selector, SelectionKey.OP_ACCEPT);
while (true) {
selector.select();
Iterator<SelectionKey> iterator = selector.selectedKeys().iterator();
while (iterator.hasNext()) {
SelectionKey key = iterator.next();
iterator.remove();
if (key.isAcceptable()) {
SocketChannel socketChannel = serverSocketChannel.accept();
socketChannel.configureBlocking(false);
socketChannel.register(selector, SelectionKey.OP_READ);
} else if (key.isReadable()) {
SocketChannel socketChannel = (SocketChannel) key.channel();
ByteBuffer buffer = ByteBuffer.allocate(1024);
int bytesRead = socketChannel.read(buffer);
if (bytesRead > 0) {
buffer.flip();
socketChannel.write(buffer);
} else if (bytesRead == -1) {
socketChannel.close();
}
}
}
}
}
}
案例分析
- 非阻塞模式：服务器通道和客户端通道均设置为非阻塞模式，确保线程不会被IO操作阻塞。
- 多路复用：使用
Selector监听多个通道的事件，实现了多路复用。 - 事件处理：通过
SelectionKey判断通道是否可接受新连接或可读数据，并进行相应的处理。
应用场景演示
- 高并发网络服务器：NIO的非阻塞特性使其特别适用于构建高并发的网络服务器。通过一个线程处理多个连接，能够显著提升系统的并发处理能力。
- 文件读写：NIO的
FileChannel允许我们通过内存映射（MappedByteBuffer）直接操作大文件，提升文件读写性能。 - 多任务处理：结合
Selector和多路复用技术，NIO适合处理多个任务和通道的并发操作。
优缺点分析
优点
- 高并发性能：NIO的非阻塞特性允许单个线程管理多个连接，显著提升了高并发场景下的性能表现。
- 更少的线程开销：相比传统的IO每个连接一个线程，NIO通过
Selector管理多个连接，减少了线程的数量和上下文切换的开销。 - 灵活的缓冲区管理：通过
Buffer对数据进行
分片、读取、写入操作，提供了更高效的数据传输方式。
缺点
- 实现复杂度高：NIO的非阻塞模型需要开发者手动管理事件和通道，代码相对复杂。
- 小数据处理时性能下降：对于大量小数据操作，NIO的性能优势不明显，甚至可能引发额外的系统资源消耗。
类代码方法介绍及演示
核心类及方法
FileChannel：用于文件读写操作，核心方法包括read()、write()、map()。SocketChannel：用于网络通信，提供非阻塞的connect()、read()、write()操作。Selector：用于多路复用IO操作，方法包括select()、selectNow()。
测试用例
测试代码
import java.io.IOException;
import java.nio.ByteBuffer;
import java.nio.channels.SocketChannel;
import java.net.InetSocketAddress;
public class NIOClient {
public static void main(String[] args) throws IOException {
SocketChannel socketChannel = SocketChannel.open();
socketChannel.connect(new InetSocketAddress("localhost", 8080));
ByteBuffer buffer = ByteBuffer.allocate(1024);
buffer.put("Hello NIO".getBytes());
buffer.flip();
socketChannel.write(buffer);
socketChannel.close();
}
}
测试结果预期
- 预期输出：客户端向服务器发送消息，服务器成功接收到消息并回写。控制台输出显示：
Hello NIO
测试代码分析
这段代码是一个简单的Java NIO客户端示例。它使用了SocketChannel和ByteBuffer来向一个运行在本地（localhost）8080端口的服务器发送字符串数据“Hello NIO”。接下来，我们将对这段代码进行详细的分析。
代码分析
1. 创建并连接Socket通道
SocketChannel socketChannel = SocketChannel.open();
socketChannel.connect(new InetSocketAddress("localhost", 8080));
SocketChannel.open()：SocketChannel是Java NIO中用于非阻塞网络通信的核心类之一。这行代码打开了一个Socket通道。connect()：connect()方法将客户端连接到指定的主机和端口号。这里指定的是localhost（本地）和端口8080，假定在该端口上有一个服务器正在运行并监听客户端连接。
2. 准备数据缓冲区
ByteBuffer buffer = ByteBuffer.allocate(1024);
buffer.put("Hello NIO".getBytes());
buffer.flip();
ByteBuffer.allocate(1024)：ByteBuffer是Java NIO中存储数据的缓冲区，这里分配了一个1024字节大小的缓冲区，用于存储将要发送的数据。buffer.put()：put()方法将字节数组（在这里通过getBytes()方法将字符串“Hello NIO”转换为字节数组）写入到缓冲区中。flip()：flip()方法将缓冲区从“写模式”切换到“读模式”，使得可以从缓冲区中读取数据进行传输。它是非常重要的一步，否则缓冲区的内容将无法正确发送。
3. 发送数据到服务器
socketChannel.write(buffer);
write()：SocketChannel的write()方法用于将ByteBuffer中的数据发送到与之连接的服务器。write()方法是非阻塞的，如果没有完全写入，它会返回已写入的字节数。
4. 关闭通道
socketChannel.close();
close()：一旦数据发送完成，客户端关闭通道。关闭通道是必要的步骤，否则系统资源不会被释放。
运行说明
- 在运行此客户端程序之前，需要在本地机器上启动一个监听8080端口的服务器（比如用Java NIO实现的服务器）。
- 客户端向服务器发送“Hello NIO”消息，如果服务器正确接收到消息并处理，该程序将正常执行并终止。
预期行为
- 当运行该客户端时，它将尝试连接到
localhost:8080的服务器。 - 连接成功后，它将发送一条消息
"Hello NIO"到服务器端。 - 发送完成后，客户端关闭连接。
可能的扩展
- 异常处理：此示例只简单处理了
IOException，可以扩展以捕获连接失败、超时等特定异常。 - 接收响应：目前该客户端只是发送数据，没有接收服务器响应，可以通过
read()方法来读取服务器的回应。 - 异步模式：可以将该代码修改为异步模式，充分发挥NIO非阻塞的优势，实现更复杂的客户端-服务器通信。
小结
这段代码展示了如何使用Java NIO实现一个简单的非阻塞客户端，发送数据到服务器端。通过SocketChannel和ByteBuffer的配合，开发者可以实现更高效的网络通信模型，尤其是在高并发或实时通信的场景下
小结
Java NIO通过非阻塞IO模型、多路复用和缓冲区管理，极大地提高了高并发系统的性能。NIO适用于网络服务器、文件读写等需要高效处理数据的场景。通过本文，读者应对NIO的基本原理、核心类及其应用场景有了更深的理解。
总结
Java NIO是Java IO系统的重要进化，解决了传统IO阻塞模式带来的性能瓶颈。通过灵活的Channel、Buffer和Selector机制，NIO为开发高性能并发应用提供了有效的工具。尽管NIO的实现复杂度较高，但其在高并发场景中的优势无可替代。
寄语
掌握Java NIO不仅仅是为了提升性能，更是为了打开高效编程的大门。愿读者通过本文的学习，在今后的开发过程中，充分利用NIO的强大功能，构建更加高效和健壮的系统。
☀️建议/推荐你
无论你是计算机专业的学生，还是对编程有兴趣的小伙伴，都建议直接毫无顾忌的学习此专栏「滚雪球学Java」，bug菌郑重承诺，凡是学习此专栏的同学，均能获取到所需的知识和技能，全网最快速入门Java编程，就像滚雪球一样，越滚越大，指数级提升。
码字不易，如果这篇文章对你有所帮助，帮忙给bug菌来个一键三连(关注、点赞、收藏) ，您的支持就是我坚持写作分享知识点传播技术的最大动力。
同时也推荐大家关注我的硬核公众号:「猿圈奇妙屋」 ；以第一手学习bug菌的首发干货，不仅能学习更多技术硬货，还可白嫖最新BAT大厂面试真题、4000G Pdf技术书籍、万份简历/PPT模板、技术文章Markdown文档等海量资料，你想要的我都有！
📣关于我
我是bug菌，CSDN | 掘金 | infoQ | 51CTO 等社区博客专家，历届博客之星Top30，掘金年度人气作者Top40，51CTO年度博主Top12，掘金等平台签约作者，华为云 | 阿里云| 腾讯云等社区优质创作者，全网粉丝合计30w+ ；硬核微信公众号「猿圈奇妙屋」，欢迎你的加入！免费白嫖最新BAT互联网公司面试题、4000G pdf电子书籍、简历模板等海量资料。
–End
- 点赞
- 收藏
- 关注作者
评论（0）