0

假设我有一个 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() 方法时，线程将进入休眠状态，直到客户端实际发送对象。所以想象一下这个场景：ArrayList "sockets_arraylist" 包含 2 个套接字。列表中的第二个套接字，属于等待接收消息的 2 号客户端。客户端 2 发送此消息并等待服务器读取它。但是有一个问题：上面的循环停留在等待来自客户端 1 的消息的 readObject() 方法上。所以直到客户端 1 不会向服务器发送他的消息，客户端 2 的消息才会被读取。

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

4

1 回答 1

4

有两种解决方案：

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

2）使用异步IO java.nio- 在这种情况下你可能想要SocketChannel。

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

于 2013-02-15T08:27:53.833 回答