Java NIO的Pipe如何进行双向通信

Java NIO 的 Pipe 类提供了一种双向通信机制，它允许在一个线程中写入数据，在另一个线程中读取数据。要实现双向通信，你需要创建一个 Pipe 实例，然后分别获取它的 SinkChannel 和 SourceChannel。SinkChannel 用于写入数据，SourceChannel 用于读取数据。这两个 Channel 都是半双工的，因此你需要在两个线程中分别操作它们。

下面是一个简单的示例，展示了如何使用 Java NIO 的 Pipe 实现双向通信：

import java.io.IOException;
import java.nio.ByteBuffer;
import java.nio.channels.Pipe;
import java.nio.channels.ReadableByteChannel;
import java.nio.channels.WritableByteChannel;

public class PipeExample {

    public static void main(String[] args) throws IOException {
        // 创建一个 Pipe 实例
        Pipe pipe = Pipe.open();

        // 获取 SinkChannel 和 SourceChannel
        WritableByteChannel sinkChannel = pipe.sink();
        ReadableByteChannel sourceChannel = pipe.source();

        // 创建两个线程，一个用于写入数据，另一个用于读取数据
        Thread writerThread = new Thread(() -> {
            try {
                writeData(sinkChannel);
            } catch (IOException e) {
                e.printStackTrace();
            }
        });

        Thread readerThread = new Thread(() -> {
            try {
                readData(sourceChannel);
            } catch (IOException e) {
                e.printStackTrace();
            }
        });

        // 启动线程
        writerThread.start();
        readerThread.start();

        // 等待线程结束
        try {
            writerThread.join();
            readerThread.join();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }

    private static void writeData(WritableByteChannel channel) throws IOException {
        String data = "Hello from the writer thread!";
        ByteBuffer buffer = ByteBuffer.wrap(data.getBytes());

        while (buffer.hasRemaining()) {
            channel.write(buffer);
        }

        System.out.println("Data written by the writer thread.");
    }

    private static void readData(ReadableByteChannel channel) throws IOException {
        ByteBuffer buffer = ByteBuffer.allocate(1024);

        int bytesRead = channel.read(buffer);

        while (bytesRead != -1) {
            buffer.flip();
            byte[] data = new byte[buffer.remaining()];
            buffer.get(data);
            System.out.println("Data read by the reader thread: " + new String(data));
            buffer.clear();
            bytesRead = channel.read(buffer);
        }
    }
}

在这个示例中，我们创建了一个 Pipe 实例，并分别获取了它的 SinkChannel 和 SourceChannel。然后，我们创建了两个线程，一个用于写入数据，另一个用于读取数据。写入线程将数据写入 SinkChannel，读取线程从 SourceChannel 读取数据。这样，我们就实现了双向通信。