我有一个服务器(线程),该服务器接收数据并具有一组客户端(套接字)。每当客户端连接时,都会创建一个新线程,并将新客户端添加到客户端阵列。
这是客户:
List<Socket> clients = Collections.synchronizedList(new ArrayList<Socket>());
因此,服务器将接收到的数据发送给客户端,如下所示:
//for each message:
for(Socket client : clients){ //throws java.util.ConcurrentModificationException
new PrintWriter(client.getOutputStream(), true).println(line);
}
现在这里有两个问题:
首先,当线程2添加客户端时,我偶尔会遇到java.util.ConcurrentModificationException。
另外,每次发送消息时,我都会创建一个新的
PrintWriter
。另一个选择是为每个客户端存储一个PrintWriter
,但是它是一个客户端,因此存储PrintWriter
没有意义。这是一个好方法吗?
最佳答案
如果所有客户端都在等待带有getString()的println,这是正确的,否则您可能想要更改为UDP协议。
不必创建新的PrintWriter每个循环,因为连接将保持打开状态,所以最好是一个(对于每个客户端),而且在客户端,您将只有一个Reader,并且它将通过其get方法等待消息。
对于并发问题,您必须创建当前列表的副本:
for (Socket client : new ArrayList<>(clients)) {
new PrintWriter(client.getOutputStream(), true).println(line);
}