Java NIO 通道：高性能 I/O 的道高的终终极指南

作者：你的老师父 2023-07-12 08:24:19开发 后端 通道是Java NIO中的一个重要概念，它提供了一种高效的道高的终方式来处理IO操作。通道可以连接多种实体，道高的终可以进行阻塞和非阻塞IO操作，道高的终还可以与缓冲区和选择器一起使用。道高的终了解通道的道高的终特性和用法，可以帮助我们更好地理解Java NIO的道高的终工作原理，并编写高效的道高的终NIO程序。

Java NIO中的道高的终通道（Channel）是一种用于在Java程序中进行高效IO操作的抽象概念。通道可以用于读取和写入数据，道高的终还可以用于在不同实体之间传输数据，道高的终比如从文件读取数据并将其写入到网络连接中。道高的终通道提供了一种灵活的道高的终方式来处理数据，可以在通道中读取和写入任意数量的道高的终数据。

通道的道高的终主要作用是连接源和目标，使得数据可以在它们之间进行传输。通道可以连接到多种实体，包括文件、网络连接、管道等。不同类型的通道提供了不同的功能和特性，可以根据需要进行选择。

以下是Java NIO中通道的主要特点：

• 可以进行读写操作：通道可以用于读取和写入数据。在读模式下，通道可以从输入源（如文件或网络连接）中读取数据。在写模式下，通道可以将数据写入输出源（如文件或网络连接）中。
• 可以进行阻塞和非阻塞IO操作：通道可以支持阻塞和非阻塞IO操作。在阻塞模式下，IO操作会一直阻塞，直到数据可用或操作完成。在非阻塞模式下，IO操作将立即返回，并在完成时通知调用者。
• 可以与缓冲区一起使用：通道可以与缓冲区一起使用，以实现高效的数据传输。读取或写入数据时，数据会被存储在缓冲区中，然后传输到通道中。通道还提供了一些方法，可以直接将数据传输到缓冲区中，或者从缓冲区中直接传输数据。
• 可以与选择器一起使用：Java NIO中的选择器（Selector）提供了一种高效的方式来处理IO操作。通道可以与选择器一起使用，以实现非阻塞IO操作。选择器可以监视多个通道上的IO事件，并在事件发生时通知调用者。
• 支持文件锁定：通道还支持文件锁定操作，可以用于在多个进程或线程之间共享文件。文件锁定可以防止多个进程或线程同时修改同一个文件，从而保证文件的一致性和安全性。

通道的类型

Java NIO中有多种类型的通道，包括文件通道（FileChannel）、套接字通道（SocketChannel和ServerSocketChannel）、管道通道（Pipe.SinkChannel和Pipe.SourceChannel）等。不同类型的通道提供了不同的功能和特性，可以根据需要进行选择。

以下是文件通道的示例代码：

import java.io.IOException;import java.nio.ByteBuffer;import java.nio.channels.FileChannel;import java.nio.file.Path;import java.nio.file.Paths;import java.nio.file.StandardOpenOption;public class FileChannelExample {     public static void main(String[] args) {         try {             Path path = Paths.get("test.txt");            FileChannel channel = FileChannel.open(path, StandardOpenOption.CREATE, StandardOpenOption.WRITE);            String message = "Hello, World!";            ByteBuffer buffer = ByteBuffer.wrap(message.getBytes());            channel.write(buffer);            channel.close();        } catch (IOException e) {             e.printStackTrace();        }    }}

以上代码创建了一个文件通道，并将字符串"Hello, World!"写入文件中。首先，我们创建了一个Path对象，用于指定文件路径。然后，我们使用FileChannel.open()方法创建一个文件通道，指定了文件的打开模式为创建和写入。接着，我们将字符串转换成字节数组，并使用ByteBuffer.wrap()方法将其包装成一个缓冲区。最后，我们使用通道的write()方法将缓冲区中的数据写入文件中，并关闭通道。

通道的创建

通道的创建可以通过工厂方法来完成，例如FileChannel.open()方法可以创建一个文件通道，SocketChannel.open()方法可以创建一个套接字通道。通道的创建也可以通过流和通道之间的适配器来完成。

以下是套接字通道的示例代码：

import java.io.IOException;import java.net.InetSocketAddress;import java.nio.ByteBuffer;import java.nio.channels.SocketChannel;public class SocketChannelExample {     public static void main(String[] args) {         try {             SocketChannel channel = SocketChannel.open();            channel.connect(new InetSocketAddress("www.google.com", 80));            String message = "GET / HTTP/1.0\r\n\r\n";            ByteBuffer buffer = ByteBuffer.wrap(message.getBytes());            channel.write(buffer);            buffer.clear();            channel.read(buffer);            System.out.println(new String(buffer.array()));            channel.close();        } catch (IOException e) {             e.printStackTrace();        }    }}

以上代码创建了一个套接字通道，并连接到Google搜索主页。首先，我们使用SocketChannel.open()方法创建一个套接字通道。然后，我们使用通道的connect()方法连接到指定的主机和端口。接着，我们将字符串转换成字节数组，并使用ByteBuffer.wrap()方法将其包装成一个缓冲区。我们使用通道的write()方法将缓冲区中的数据发送到服务器，并使用clear()方法清空缓冲区。最后，我们使用通道的read()方法读取服务器的响应，并将响应输出到控制台，然后关闭通道。

通道的读写操作

通道可以用于读取和写入数据。在读模式下，通道可以从输入源（如文件或网络连接）中读取数据。在写模式下，通道可以将数据写入输出源（如文件或网络连接）中。读写操作可以通过缓冲区来完成，也可以直接读写字节数据。

以下是读写文件通道的示例代码：

import java.io.IOException;import java.nio.ByteBuffer;import java.nio.channels.FileChannel;import java.nio.file.Path;import java.nio.file.Paths;import java.nio.file.StandardOpenOption;public class ReadWriteFileChannelExample {     public static void main(String[] args) {         try {             Path path = Paths.get("test.txt");            FileChannel channel = FileChannel.open(path, StandardOpenOption.READ, StandardOpenOption.WRITE);            ByteBuffer buffer = ByteBuffer.allocate(1024);            int bytesRead = channel.read(buffer);            while (bytesRead != -1) {                 buffer.flip();                while (buffer.hasRemaining()) {                     System.out.print((char) buffer.get());                }                buffer.clear();                bytesRead = channel.read(buffer);            }            String message = "Hello, World!";            buffer.put(message.getBytes());            buffer.flip();            channel.write(buffer);            channel.close();        } catch (IOException e) {             e.printStackTrace();        }    }}

以上代码打开了一个文件通道，并读取文件中的数据。首先，我们创建了一个Path对象，用于指定文件路径。然后，我们使用FileChannel.open()方法创建一个文件通道，指定了文件的打开模式为读和写。接着，我们创建了一个ByteBuffer对象，用于存储读取的数据。我们使用通道的read()方法读取数据，并将其存储在缓冲区中。如果读取的数据不为空，则使用缓冲区的flip()方法将其从写模式切换到读模式，并使用缓冲区的get()方法逐个读取字节，并输出到控制台。最后，我们将一个字符串转换成字节数组，并使用缓冲区的put()方法将其存储到缓冲区中。我们使用缓冲区的flip()方法将其从写模式切换到读模式，并使用通道的write()方法将缓冲区中的数据写入文件中。最后，我们关闭通道。

通道的阻塞和非阻塞模式

通道可以支持阻塞和非阻塞IO操作。在阻塞模式下，IO操作会一直阻塞，直到数据可用或操作完成。在非阻塞模式下，IO操作将立即返回，并在完成时通知调用者。

以下是非阻塞套接字通道的示例代码：

import java.io.IOException;import java.net.InetSocketAddress;import java.nio.ByteBuffer;import java.nio.channels.SocketChannel;public class NonBlockingSocketChannelExample {     public static void main(String[] args) {         try {             SocketChannel channel = SocketChannel.open();            channel.configureBlocking(false);            channel.connect(new InetSocketAddress("www.google.com", 80));            while (!channel.finishConnect()) {                 // do something else while waiting for the connection to complete            }            String message = "GET / HTTP/1.0\r\n\r\n";            ByteBuffer buffer = ByteBuffer.wrap(message.getBytes());            while (buffer.hasRemaining()) {                 channel.write(buffer);            }            buffer.clear();            while (channel.read(buffer) != -1) {                 buffer.flip();                while (buffer.hasRemaining()) {                     System.out.print((char) buffer.get());                }                buffer.clear();            }            channel.close();        } catch (IOException e) {             e.printStackTrace();        }    }}

以上代码创建了一个非阻塞套接字通道，并连接到Google搜索主页。首先，我们使用SocketChannel.open()方法创建一个套接字通道，并使用通道的configureBlocking()方法将其切换到非阻塞模式。然后，我们使用通道的connect()方法连接到指定的主机和端口，并使用while循环等待连接完成。接着，我们将字符串转换成字节数组，并使用ByteBuffer.wrap()方法将其包装成一个缓冲区。我们使用while循环将缓冲区中的数据逐个写入通道，直到所有数据都写入完成。然后，我们使用while循环读取通道中的数据，并将其存储在缓冲区中。如果读取的数据不为空，则使用缓冲区的flip()方法将其从写模式切换到读模式，并使用缓冲区的get()方法逐个读取字节，并输出到控制台。最后，我们关闭通道。

通道的选择器

Java NIO中的选择器（Selector）提供了一种高效的方式来处理IO操作。通道可以与选择器一起使用，以实现非阻塞IO操作。选择器可以监视多个通道上的IO事件，并在事件发生时通知调用者。

以下是选择器的示例代码：

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;import java.util.Set;public class SelectorExample {     public static void main(String[] args) {         try {             Selector selector = Selector.open();            ServerSocketChannel serverChannel = ServerSocketChannel.open();            serverChannel.socket().bind(new InetSocketAddress(8080));            serverChannel.configureBlocking(false);            serverChannel.register(selector, SelectionKey.OP_ACCEPT);            while (true) {                 selector.select();                Set<SelectionKey> keys = selector.selectedKeys();                Iterator<SelectionKey> iterator = keys.iterator();                while (iterator.hasNext()) {                     SelectionKey key = iterator.next();                    iterator.remove();                    if (key.isAcceptable()) {                         SocketChannel channel = serverChannel.accept();                        channel.configureBlocking(false);                        channel.register(selector, SelectionKey.OP_READ);                    } else if (key.isReadable()) {                         SocketChannel channel = (SocketChannel) key.channel();                        ByteBuffer buffer = ByteBuffer.allocate(1024);                        channel.read(buffer);                        buffer.flip();                        while (buffer.hasRemaining()) {                             System.out.print((char) buffer.get());                        }                        channel.close();                    }                }            }        } catch (IOException e) {             e.printStackTrace();        }    }}

以上代码创建了一个选择器，并将其注册到一个ServerSocketChannel上。选择器使用select()方法等待事件发生，并使用selectedKeys()方法获取事件的集合。我们使用迭代器遍历事件的集合，并处理每个事件。如果事件是ACCEPT事件，则创建一个新的SocketChannel，并将其注册到选择器上。如果事件是READ事件，则读取通道中的数据，并输出到控制台，然后关闭通道。

通道的文件锁定

通道还支持文件锁定操作，可以用于在多个进程或线程之间共享文件。文件锁定可以防止多个进程或线程同时修改同一个文件，从而保证文件的一致性和安全性。

以下是文件锁定的示例代码：

import java.io.IOException;import java.nio.channels.FileChannel;import java.nio.channels.FileLock;import java.nio.file.Path;import java.nio.file.Paths;import java.nio.file.StandardOpenOption;public class FileLockExample {     public static void main(String[] args) {         try {             Path path = Paths.get("test.txt");            FileChannel channel = FileChannel.open(path, StandardOpenOption.CREATE, StandardOpenOption.WRITE);            FileLock lock = channel.tryLock();            if (lock != null) {                 System.out.println("File is locked");                Thread.sleep(5000);                lock.release();                System.out.println("File is released");            }            channel.close();        } catch (IOException | InterruptedException e) {             e.printStackTrace();        }    }}

以上代码打开了一个文件通道，并尝试对文件进行锁定操作。我们使用通道的tryLock()方法尝试获取文件锁定，并在获取成功时输出"File is locked"。接着，我们使用Thread.sleep()方法模拟对文件的操作。最后，我们使用锁定对象的release()方法释放文件锁定，并输出"File is released"。

总之，通道是Java NIO中的一个重要概念，它提供了一种高效的方式来处理IO操作。通道可以连接多种实体，可以进行阻塞和非阻塞IO操作，还可以与缓冲区和选择器一起使用。了解通道的特性和用法，可以帮助我们更好地理解Java NIO的工作原理，并编写高效的NIO程序。

责任编辑：姜华 来源： 今日头条 Java NIO通道

(责任编辑：焦点)