从聊天服务器发送到聊天客户端的数组更新

我发现了一个聊天服务器的代码，我有一个简短的问题。这是关于以下摘录：从聊天服务器发送到聊天客户端的数组更新

clientOutputStreams.add（作家）;

显然，这种字符串数组应该被发送到聊天客户端，但我不明白怎么阵列不断被更新 - 即如何发送到由特殊的聊天客户端的服务器字符串数组中accumualated然后送回给所有聊天客户。你做？将不胜感激你的帮助。

import java.io.*; 
import java.net.*; 
import java.util.*; 


public class VerySimpleChatServer { 
ArrayList clientOutputStreams; 

public class ClientHandler implements Runnable { 
    BufferedReader reader; 
    Socket sock; 

    public ClientHandler(Socket clientSOcket) { 
     try { 
      sock = clientSOcket; 
      InputStreamReader isReader = new InputStreamReader(sock.getInputStream()); 
      reader = new BufferedReader(isReader); 

     } catch (Exception ex) { ex.printStackTrace(); } 
    } 

    public void run() { 
     String message; 
     try { 
      while ((message = reader.readLine()) != null) { 
       System.out.println("read " + message); 
       tellEveryone(message); 
      } 
     } catch (Exception ex) { ex.printStackTrace(); } 
    } 
} 

public static void main(String[] args) { 
    new VerySimpleChatServer().go(); 
} 

public void go() { 
    clientOutputStreams = new ArrayList(); 
    try { 
     ServerSocket serverSock = new ServerSocket(5000); 
     while(true) { 
      Socket clientSocket = serverSock.accept(); 
      PrintWriter writer = new PrintWriter(clientSocket.getOutputStream()); 
      clientOutputStreams.add(writer); 

      Thread t = new Thread(new ClientHandler(clientSocket)); 
      t.start(); 
      System.out.println("got a connection"); 
     } 
    } catch (Exception ex) { ex.printStackTrace(); } 
} 

public void tellEveryone(String message) { 
    Iterator it = clientOutputStreams.iterator(); 
    while (it.hasNext()) { 
     try { 
      PrintWriter writer = (PrintWriter) it.next(); 
      writer.println(message); 
      writer.flush(); 
     } catch (Exception ex) { ex.printStackTrace(); } 
    } 
}

}

来源

2017-10-17 Duke

clientOutputStreams不是一个* strings *数组，而是一个* streams * =>数组，即给客户端的“管道”。 – Joel

是否意味着如果总共有10个客户端，那么clientOutputStream的大小是10？ – Duke

是的，就是这样。每次接受客户端连接时，该列表都会增长。正如下面的答案所述，每次在控制台上写入一个字符串时，它都会一次向客户端广播一个字符串。 – Joel

显然，这种字符串数组应该被发送到聊天客户端，

这不是一个字符串数组。这是PrintWriters的数组，你可以从以下几行看到：

PrintWriter writer = new PrintWriter(clientSocket.getOutputStream()); 
clientOutputStreams.add(writer);

，但我不明白怎么阵列不断被更新 - 即如何发送到从特定聊天客户端的服务器字符串中accumualated该数组然后发送回所有聊天客户端。你做？

看起来像琴弦通过功能

public void tellEveryone(String message)

此功能通过每个PrintWriters的循环发送到聊天客户端和传递的字符串message写入每个PrintWriter。我想这是每个客户端看到这些消息的方式。

来源

2017-10-17 20:48:18 MFisherKDX

因此，数组clientOutputStreams的大小是连接到服务器的客户端数量 - 是对的吗？谢谢 – Duke

clientOutputStreams不是一个字符串数组。它是一个Writer的列表，用于向所有连接的客户端发送消息。当客户端向服务器发送消息时，服务器将消息（方法：tellEveryone）发送给每个客户端（列表中的每个写入者）。 ClientHandler类用于读取来自客户端的所有传入消息。希望能够帮助你更好地理解代码。

来源

2017-10-17 20:48:44 Ingrim4

从聊天服务器发送到聊天客户端的数组更新

回答

相关问题