猿问

这是发送给多个客户端的正确方法吗?

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


这是客户:


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。


这是一个好方法吗?


沧海一幻觉
浏览 143回答 2
2回答

互换的青春

如果所有客户端都在等待带有getString()的println,这是正确的,否则您可能想要更改为UDP协议。不必创建新的PrintWriter每个循环,因为连接将保持打开状态,所以最好是一个(对于每个客户端),而且在客户端,您将只有一个Reader,并且它将通过其get方法等待消息。对于并发问题,您必须创建当前列表的副本:for (Socket client : new ArrayList<>(clients)) {&nbsp; &nbsp;new PrintWriter(client.getOutputStream(), true).println(line);}

三国纷争

您正在client.getOutputStream()遍历列表的同时尝试访问对象(),因此java.util.ConcurrentModificationException。更改您List<>的ConcurrentLinkedQueue。同样在PrintWriter这里,您只需包装现有流。
随时随地看视频慕课网APP

相关分类

Java
我要回答