Javaマルチスレッドステートフルサーバーネットワーキング設計

Question

ステートフルなマルチクライアントサーバーアプリケーションを実装しようとしており、ネットワーク/スレッド設計に関するいくつかの質問があります。私が現在直面している問題は、通信レイヤーとロジックレイヤーの間でメッセージを交換する方法です。

サーバーは複数のクライアントを処理します。複数のクライアントはそれぞれ複数の「チャネル」でアクティブになり、各チャネルには複数のステージがあり、複数のクライアントが動作します。それを複数の部屋を持つチャットプログラムと似たようなものと考えてください。

私はすでにサーバー側でメッセージの受信を実装しています。各クライアントには、データをブロッキングで読み取ってメッセージにデコードする独自のスレッドがあります。今どのように進める？私の意見では、各チャンネルには、その状態を簡単に維持するためのスレッドが必要です。私はBlockingQueueを使用して、受信したメッセージをチャネルスレッドと交換することができます。チャネルスレッドは、そのキュー上の新しいメッセージをブロックして待機しています。

しかし、どのようにクライアントにメッセージを送信するのですか？チャネルのロジックはメッセージを処理し、クライアントの1つ/ some/allに送信されるメッセージを生成します。ソケットに直接書き込むためにチャネルスレッドを使用するのは安全ですか？または、別のBlockingQueueを使用してメッセージをクライアントハンドラスレッドに送信する必要がありますか？しかし、ソケットを読み取るのを待っているので、それを目覚めさせる方法は？または、クライアントごとに個別の送信スレッドを使用するか、別の送信ソケットを使用する必要がありますか？

ところで、私はネットワーキング層に既存のライブラリを使うことができますが、普通のソケットでは最初からやりたいと思っています。

Answer 1

ソケットをラップする通信オブジェクトにメッセージの送信方法を設定します。一度に1つのスレッドしか呼び出せないように、このメソッドを同期させます。次に、このメソッドを呼び出すスレッドの数に違いはありません。各メッセージは一度に1つずつ送信されます。また、読み込みをブロックしているスレッドを妨害する必要もありません。この送信メソッドは、スレッドが送信している間に他のスレッドがブロックされることを心配する必要がない、すばやい操作です。

チャネルが接続された各クライアントの通信オブジェクトへの参照を持っている限り、メッセージは送信され、心配はありません。

問題が発生した場合は、送信メッセージを変更して、送信するオブジェクトをエンキューすることができます。次に、キュー上でブロックして内容をソケットに書き込む特定の送信スレッドを持つことができます。しかし、私の経験からは、これは必要ではありません。

Answer 2

イベントメカニズムについてはどうですか？要求を処理する準備が整っていて、利用可能なクライアント用のデータがある場合は、クライアントソケットハンドラスレッド用のイベントを送信するだけです。クライアントからの送信が終了したため、正常に返信することができます。