java 客户端线程池循环用SocketChannel发送 服务端用SocketChannel和Selector接收流 客户端发送完就把SocketChanne关了 但是客户端没接收完 客户端报错

在这种情况下，当客户端发送完数据后立即关闭`SocketChannel`，而服务端还没有接收完所有数据时，客户端会抛出`java.io.IOException: 远程主机强迫关闭了一个现有的连接`错误。

这是因为在客户端关闭`SocketChannel`后，服务端仍然尝试读取数据，但此时连接已经被关闭，导致服务端的读取操作抛出了异常。

为了解决这个问题，你可以修改客户端的代码逻辑，等待服务端完成对数据的处理后再关闭`SocketChannel`。可以通过服务端发送一个特殊的结束标记来告知客户端数据已经接收完毕。

以下是修改后的客户端代码示例：

import java.io.IOException;
import java.net.InetSocketAddress;
import java.nio.ByteBuffer;
import java.nio.channels.SocketChannel;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class Client {
    private static final int BUFFER_SIZE = 1024;

    public static void main(String[] args) {
        ExecutorService executorService = Executors.newFixedThreadPool(1);

        executorService.execute(() -> {
            try {
                SocketChannel socketChannel = SocketChannel.open();
                socketChannel.connect(new InetSocketAddress("localhost", 8080));

                // 发送数据
                String message = "Hello, server!";
                ByteBuffer buffer = ByteBuffer.wrap(message.getBytes());
                socketChannel.write(buffer);

                // 关闭输出流
                socketChannel.shutdownOutput();

                // 接收响应
                ByteBuffer responseBuffer = ByteBuffer.allocate(BUFFER_SIZE);
                StringBuilder response = new StringBuilder();
                while (socketChannel.read(responseBuffer) != -1) {
                    responseBuffer.flip();
                    byte[] data = new byte[responseBuffer.remaining()];
                    responseBuffer.get(data);
                    response.append(new String(data));
                    responseBuffer.clear();
                }

                System.out.println("Received response from server: " + response.toString());

                // 关闭SocketChannel
                socketChannel.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        });

        executorService.shutdown();
    }
}

在这个示例中，客户端使用线程池执行发送数据的操作。发送完数据后，客户端会通过`shutdownOutput()`关闭输出流，然后开始接收服务端的响应。只有当服务端完成了响应后，客户端才会关闭`SocketChannel`。

这样修改后，客户端就能正常接收服务端的完整响应，并且在处理完响应后再关闭`SocketChannel`，避免了异常的发生。