【发布时间】:2013-02-15 08:23:20
【问题描述】:
假设我有一个类 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 发送此消息并等待服务器读取它。但是有一个问题:上面的循环卡在 readObject() 方法上,等待来自客户端 1 的消息。所以直到客户端 1 不会向服务器发送他的消息,客户端 2 的消息才会被读取。
我需要在服务器上为每个客户端创建一个单独的线程吗?还是有另一种解决方案?
【问题讨论】:
-
不要在每次要读取套接字时都创建一个新的
ObjectInputStream。在套接字的整个生命周期中使用相同的。
标签: java multithreading sockets connection