Javaでキープアライブを実装する

Question

私は、クライアントがクラッシュしたかどうかを検出するためにキープアライブメカニズムを実装する必要があるクライアント/サーバアプリケーションを構築しています。私は、クライアント側とサーバー側の両方に別々のスレッドを持っています。クライアントスレッドは "ping"を送信して3秒間スリープし、サーバはBufferedInputStreamを読み込み、pingが受信されたかどうかをチェックし、そうであればpingカウンタをゼロにし、そうでない場合は+1し、サーバスレッド3秒間スリープし、pingカウンタが3に達すると、クライアントは死んだと宣言します。

問題は、サーバーが入力ストリームを読み込み、ブロッキングコールを読み込んだときに、次のpingが受信されるまでブロックされ、遅れているかどうかに関係なくブロックされるため、サーバーはpingが見つからないことを検出しません。

ストリームの現在の値を読み取ることができるように、入力ストリームに何もない場合はブロックされません。

おかげで、

Answer 1

のJava 1.4はjava.nioパッケージに代表される非ブロックI/Oの考え方を導入しました。これはおそらくあなたが必要とするものです。

this tutorial for how to use non-blocking I/Oを参照してください。

また、これは宿題や学習の練習ではないと仮定し、Apache MinaやJBoss Nettyなどのより堅牢なプロトコルフレームワークを使用することをお勧めします。それらの間のthis comparisonを参照して、なぜそれらを使用したいでしょうか。

Answer 2

すべてのブロッキング接続を監視する別個の監視スレッドを持つことができます。接続が何かを受け取ると、カウンタをリセットすることができます。 （私はどんなパケットでもハートビートとして扱います）監視スレッドは実行するたびにこのカウンタをインクリメントすることができ、制限に達すると（つまりゼロにリセットされなかったため）、接続を閉じることができます。そのようなスレッドは1つだけ必要です。最後に閉じた接続でブロックしているスレッドはIOExceptionをスローし、スレッドをスリープ状態にします。

一方、ハートビートは、パケットが一定期間送信されなかった場合にトリガーされます。これは、ビジーな接続がハートビートを送信しないことを意味します。