Java NIO的Pipe如何实现双向通信

Java NIO 的 Pipe 实现双向通信需要使用两个 Pipe 实例，一个用于读取数据，另一个用于写入数据。每个 Pipe 实例都包含一个 SinkChannel 和一个 SourceChannel，分别用于写入和读取数据。要实现双向通信，你需要在两个线程中分别处理读写操作。

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

import java.io.IOException;
import java.nio.ByteBuffer;
import java.nio.channels.Pipe;
import java.nio.channels.SelectionKey;
import java.nio.channels.Selector;
import java.nio.channels.spi.SelectorProvider;
import java.util.Iterator;
import java.util.Set;

public class NIOPipeBidirectionalCommunication {

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

        // 获取 SinkChannel 和 SourceChannel
        Pipe.SinkChannel sinkChannel1 = pipe1.sink();
        Pipe.SourceChannel sourceChannel1 = pipe1.source();
        Pipe.SinkChannel sinkChannel2 = pipe2.sink();
        Pipe.SourceChannel sourceChannel2 = pipe2.source();

        // 创建两个线程，分别处理读写操作
        Thread thread1 = new Thread(() -> {
            try {
                readData(sourceChannel1);
            } catch (IOException e) {
                e.printStackTrace();
            }
        });

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

        thread1.start();
        thread2.start();

        // 向 pipe1 写入数据
        ByteBuffer buffer1 = ByteBuffer.wrap("Hello from Pipe 1".getBytes());
        sinkChannel1.write(buffer1);

        // 向 pipe2 写入数据
        ByteBuffer buffer2 = ByteBuffer.wrap("Hello from Pipe 2".getBytes());
        sinkChannel2.write(buffer2);

        // 从 pipe1 读取数据
        readData(sinkChannel2);

        // 从 pipe2 读取数据
        readData(sinkChannel1);

        thread1.join();
        thread2.join();
    }

    private static void readData(Pipe.SinkChannel sinkChannel) throws IOException {
        ByteBuffer buffer = ByteBuffer.allocate(1024);
        int bytesRead = sinkChannel.read(buffer);
        while (bytesRead != -1) {
            buffer.flip();
            System.out.println("Received data: " + new String(buffer.array(), 0, bytesRead));
            buffer.clear();
            bytesRead = sinkChannel.read(buffer);
        }
    }
}

在这个示例中，我们创建了两个 Pipe 实例（pipe1 和 pipe2），并分别获取了它们的 SinkChannel 和 SourceChannel。然后，我们创建了两个线程，分别处理这两个 Pipe 实例的读写操作。

在主线程中，我们向 pipe1 的 SinkChannel 写入数据，然后从 pipe2 的 SourceChannel 读取数据。同样，我们从 pipe2 的 SinkChannel 写入数据，然后从 pipe1 的 SourceChannel 读取数据。

这个示例展示了如何使用 Java NIO 的 Pipe 实现双向通信。你可以根据自己的需求修改这个示例，以满足你的实际应用场景。