我有一个服务器(线程),该服务器接收数据并具有一组客户端(套接字)。每当客户端连接时,都会创建一个新线程,并将新客户端添加到客户端阵列。

这是客户:

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);
}

10-05 20:14
查看更多