どのクライアントからどのクライアントから受け取ったメッセージをJavaのすべての接続されたクライアントに転送する方法

Question

私はチャットシステムプロジェクト（まだ不完全です）をJavaで作成しようとしていますが、クライアントの受信メッセージを転送するのに少し助けが必要です。

サーバーがマルチスレッドとして機能しているので、多くのクライアントが接続できるようになります。（想定されるシナリオ）6つのクライアントがサーバーに接続されていて、そのうちの1つがメッセージを送信した場合、接続されたすべてのクライアントにサーバー経由で接続します。ここ

は

import java.io.*; 
import java.net.*; 
public class ChatServer implements Runnable 
{ 
    Socket csocket; 
    ChatServer(Socket csocket){ this.csocket = csocket; } 

public static void main(String[]args)throws Exception 
{ 
    ServerSocket sersock=new ServerSocket(3000); 
    System.out.println("Server ready for chatting"); 
    while(true) 
    { 
     Socket sock =sersock.accept(); 
     new Thread(new ChatServer(sock)).start();} 
} 
public void run() 
{ 
    try{ 
      System.out.println(Thread.currentThread().getName() + ": HELLO"); 
      BufferedReader keyRead=new BufferedReader(new InputStreamReader(System.in)); 
      OutputStream ostream=csocket.getOutputStream(); 
      PrintWriter pwrite=new PrintWriter(ostream, true); 
      InputStream istream=csocket.getInputStream(); 
      BufferedReader receiveRead=new BufferedReader(new InputStreamReader(istream)); 
      String receiveMessage, sendMessage; 

      while(true) { 
        if((receiveMessage=receiveRead.readLine())!=null) 
         { 
          System.out.print(Thread.currentThread().getName() + ": "); 
          if(receiveMessage.equals("QUIT")) 
           Thread.currentThread().stop(); 
           else 
            System.out.println(receiveMessage);} 
         sendMessage=keyRead.readLine(); 
         pwrite.println(sendMessage); 
         System.out.flush();} 
     } catch (IOException e){ System.out.println(e); } 

} 

} 

クライアント側事前に

import java.io.*; 
import java.net.*; 
public class ChatClient 
{ 
public static void main(String[]args)throws Exception 
{ 
Socket sock =new Socket("localhost", 3000); 
// reading from keyboard (keyRead object) 
BufferedReader keyRead=new BufferedReader(new InputStreamReader(System.in)); 
// sending to client (pwrite object) 
OutputStream ostream=sock.getOutputStream(); 
PrintWriter pwrite=new PrintWriter(ostream, true); 

// receiving from server (receiveRead object) 
InputStream istream=sock.getInputStream(); 
BufferedReader receiveRead=new BufferedReader(new InputStreamReader(istream)); 

System.out.println("Start the chitchat, type and press Enter key"); 

String receiveMessage, sendMessage; 
while(true) 
{ 
sendMessage=keyRead.readLine();// keyboard reading 
pwrite.println(sendMessage);// sending to server 
System.out.flush();// flush the data 
    if((receiveMessage=receiveRead.readLine())!=null)//receive from server 
{ 
System.out.println(receiveMessage);// displaying at DOS prompt 
} 
} 
} 
} 

おかげ

サーバー側。2つのコードです。

Answer 1

私は、これらのタイプのサーバーアプリケーションを、直接の接続が不可能な場合にリレーサーバー経由でクライアントに接続する方法として頻繁に書き込みます。解決方法は簡単ですが、accept()関数から受け取った各socketを選択したリストまたはツリーに入れてください。

List<Socket> connectionList = new ArrayList<Socket>(); 
... 
Socket sock =sersock.accept(); 
connectionList.add(sock); 
... 
for (Socket connection : connectionList) { 
     connection.getOutputStream().write(msgBytes); 
}