私は簡単な質問があるチャットサーバーのコードを見つけました。以下の抜粋についてです。チャットサーバーからチャットクライアントに送信される配列の更新
clientOutputStreams.add(writer);
明らかに、この文字列はチャットクライアントに送信する必要がありますが、配列がどのように更新されるか、つまり特定のチャットクライアントからサーバーに送信された文字列が配列に蓄積され、すべてのチャットクライアントに送信します。あなたは?助けていただければ幸いです。
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(); }
}
}
}明らかに、文字列のこの配列は、チャットクライアントに送信する必要があり
clientOutputStreamsは*文字列*の配列ではなく、* streams * =>の配列、つまりクライアントへの "パイプ"です。 – Joel
合計で10のクライアントがある場合、clientOutputStreamのサイズは10ですか? – Duke
はい、それです。クライアント接続が承認されるたびに、このリストが作成されます。以下の答えで述べるように、コンソールに文字列が書き込まれるたびに、一度に1文字ずつクライアントにブロードキャストされます。 – Joel