Javaのチャットサーバー

Question

私はチャットサーバと現在、私の設計は、次の基づいているベースのJavaを書いています： - チャットルームにいる人は、メッセージを送信し、サーバ側のチャットルームのクラスは、すべてに同じメッセージを送信するとき参加者は部屋の中をループします。明らかに、これは、ループが個々の参加者にネットワーク通話が行われているため、貧弱な設計です。したがって、たとえば、チャットルームに10人いるとします。 1人のユーザーがメッセージを送信すると、chatroomクラスはループ内で同じメッセージを10人全員に送信します。言い換えれば、ループの第5人が冗談な接続をしている場合、第6 ..第10人がメッセージを見る時間が影響を受けます。

私は部屋ごとにマルチキャスト、ユニキャストから移動した場合、その後、どのように私はチャットルームあたりのプライベートマルチキャストグループのIPを得るのですか？また、チャットルームごとに個別のグループを持つことは過度のようです。 主な問題の1つは、ループを介して部屋のユーザーに返信したときに、ソケット接続でデータを送信したメソッドがブロックされていたことです。したがって、私は非ブロックNIOソケットを使用し、受信者にループでメッセージを送信すると思っているが、それは問題を解決するだろうか？ 部屋の受信者にデータを送信するのを最適化するために他にも巧妙なやり方がありますか？

Answer 1

単純な実装は、クライアントごとに2つのスレッドを使用することです。ソケットから読み取るスレッドとソケットに書き込むスレッド。クライアントが少ない場合、これは問題ありません。あなたは多くのクライアントを扱うためにNIOを知る必要があります。 （スレッドモデルがうまく動作しない「多くの」意味。）

クライアントの読み取りスレッドがソケットからメッセージ全体を読み取り、チャットルームオブジェクト内のキューに入れます。チャットルームには、メッセージをキューから取り出してクライアントのキューに入れるスレッドがあります。スレッドを書くクライアントは、そのキューをポーリングし、そのメッセージをソケットに書き込みます。

チャットルームには、接続を受け入れ、クライアントオブジェクトを作成するためのスレッドを持っており、コレクションでそれらを置きます。メッセージキューをポーリングしてメッセージをクライアントキューに配信する別のスレッドがあります。

Apache MinaはNIO

Answer 2

私はシリアルに受信者をループすることは悪い考えであろうことに同意を使用する例があります。このために、ThreadPoolを使用して手助けをすることを検討することができます。しかし、私はマルチキャストがあなたの最善の策だと思うでしょう。チャットルームモデルに適しています。あなたは一度だけ送る必要があり、あなたの反復的なアプローチは解決されます。アドレスに異なるポートを指定することで、一意のグループIDを取得できます。

Answer 3

単純なアプローチは、クライアント接続ごとに2つのスレッドを使用することです。 1つのスレッドは、メッセージを送信するためにクライアントからのメッセージの読み取りを処理し、それによって同時にクライアントからメッセージを送受信することができます。メッセージをブロードキャストするクライアント接続をループする際に、サーバースレッドがクライアントに送信するキューにメッセージを追加する必要がありますネットワーク呼び出しを避けるために

。 java.util.concurrentのLinkedBlockingQueueはこれに最適です。以下はその例です：

/** 
* Handles outgoing communication with client 
*/ 
public class ClientConnection extends Thread { 
    private Queue<String> outgoingMessages = new LinkedBlockingQueue<String>(MAX_OUTGOING); 
    // ... 
    public void queueOutgoing(String message) { 
     if (!outgoingMessages.offer(message)) { 
      // Kick slow clients 
      kick(); 
     } 
    } 

    public void run() { 
     // ... 
     while (isConnected) { 
      List<String> messages = new LinkedList<String>(); 
      outgoingMessages.drainTo(messages); 
      for (String message : messages) { 
       send(message); 
      } 
      // ... 
     } 
    } 
} 

public class Server { 
    // ... 
    public void broadcast(String message) { 
     for (ClientConnection client : clients) { 
      client.queueOutgoing(message); 
     } 
    } 
}