在Java中使用阻塞NIO

Question

我只是想知道是否可以使用SocketChannel类（带有ByteBuffer）来模拟Java中常规Socket类的阻塞特性。我做了两个测试项目，一个模拟客户端，另一个模拟服务器：

客户代码：

    public static void main(String[] args) throws IOException {

    SocketChannel socket = SocketChannel.open(new InetSocketAddress("127.0.0.1", 6789));

    //Simulate this:
    //DataOutputStream dos = new DataOutputStream(socket.socket().getOutputStream());
    //dos.writeInt(4);
    //dos.writeInt(6);

    ByteBuffer buffer = ByteBuffer.allocate(4);
    buffer.putInt(4);
    buffer.flip();
    socket.write(buffer);
    buffer.clear();
    buffer.putInt(6);
    buffer.flip();
    socket.write(buffer);
}

服务器代码：

    public static void main(String[] args) throws IOException, InterruptedException {
    ServerSocketChannel ssc = ServerSocketChannel.open();
    ssc.socket().bind(new InetSocketAddress(6789));
    SocketChannel socketCh = ssc.accept();
    socketCh.configureBlocking(true);
    // Simulate this
    // DataInputStream dis = new DataInputStream(socketCh.socket().getInputStream());
    // System.out.println(dis.readInt());
    // System.out.println(dis.readInt());

    // This is something to avoid. This is not the same as what is up above
    // If the 2nd line prints -1, the 3rd prints 4
    // If the 2nd line prints 4, the 3rd prints 6
    ByteBuffer buffer = ByteBuffer.allocate(1024);
    socketCh.read(buffer);
    buffer.rewind();
    System.out.println("First number: " + buffer.getInt());
    buffer.clear();
    System.out.println("Change: " + socketCh.read(buffer));
    buffer.rewind();
    System.out.println("Second Number: " + buffer.getInt());
}

正如我在评论中所说，运行服务器然后客户端（按该顺序）的结果是不可预测的，因为有时第二个数字可能保持为4或变为6，而更改分别为-1或4（整数字节）。

至于服务器端，我知道我可以让它等待第二个socketCh。read（buffer）返回一个非-1的值，这意味着SocketChannel中没有写入任何内容（我猜想）。

然而，在客户端，我没有任何想法。

我知道我可以改为使用DataOutputStream和DataInputStream，并以老式的方式进行操作，但我想知道如何使用SocketChannel进行操作，只是为了方便。同样，你也不能在另一个技巧上出错。

尽管我手动将服务器配置为阻塞，但我假设它是默认配置，因此可以放弃它。

提前谢谢！PS：希望我能避免在这么简单的任务中使用选择器类。。。

编辑：我知道Selector类只能用于非阻塞模式。

Answer 1

您正在丢弃可能已读取的额外数据，并假设每次读取都准确地传递与每次写入对应的内容（例如，第一次读取只传递int）。TCP中没有任何东西可以保证这一点。

将re杀青（）更改为翻转（）；将清除（）更改为紧凑（）；添加对read（）的返回值的一些检查；它应该按预期工作。

您不能在阻塞模式下使用Selector。