java - 服务器中的循环读取所有客户端套接字

Question

假设我有一个 ServerReader 类，它是一个始终运行的线程。 ServerReader 有一个循环，以如下方式读取来自所有客户端的所有消息:

while(true) {
    for(Socket socket: sockets_arraylist) {
        ObjectInputStream object_stream = new ObjectInputStream(socket.getInputStream());
        String str = (String) object_stream.readObject();
        System.out.println("message from client: " + str);
        object_stream.close();
    }
}

据我了解，当循环遇到 readObject() 方法时，线程将 hibernate ，直到客户端实际发送对象。想象一下这个场景:ArrayList“sockets_arraylist”包含 2 个套接字。列表中的第二个套接字，属于等待接收消息的 2 号客户端。 2号客户端发送此消息并等待服务器读取它。但是有一个问题:上面的循环停留在 readObject() 方法上，该方法等待来自客户端 1 的消息。因此，直到客户端 1 不再将其消息发送到服务器之前，客户端 2 的消息将不会被读取。

我需要在服务器上为每个客户端创建一个单独的线程吗？或者还有其他解决方案？

Answer 1

有两种解决方案:

1) 为每个客户端使用单独的线程。

2) 使用java.nio使用异步IO - 在这种情况下，您可能需要 SocketChannel .

为每个客户端使用单独的线程可能在概念上更简单，尽管这确实意味着您需要更仔细地考虑竞争条件。使用 NIO可能更具可扩展性(不同的基准测试显示不同的结果，并且它很可能也取决于您的操作系统，就线程和调度的成本而言)。