간단한 질문이있는 채팅 서버 코드를 발견했습니다. 다음 발췌 부분에 대한 내용입니다.채팅 서버에서 채팅 클라이언트로 전송되는 배열 업데이트
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는 * strings * 배열이 아니라 * streams * => 즉 클라이언트의 "파이프"배열입니다. – Joel
총 10 개의 클라이언트가있는 경우 clientOutputStream의 크기는 10입니다. – Duke
예, 그게 전부입니다. 클라이언트 연결이 승인 될 때마다이 목록이 커집니다. 아래 답변에서 언급했듯이 콘솔에 문자열이 기록 될 때마다 한 번에 한 문자열 씩 클라이언트에 브로드 캐스팅됩니다. – Joel