c# - Read（）ブロッキングの問題

Question

私はC＃でサーバーアプリケーションを開発しています。クライアントはサーバーに接続してさまざまな要求を行うことができます。現在、クライアントが接続すると、リクエストを処理するために新しいスレッドが生成されます。TCPClientクラスを使用してクライアント接続を処理しています。私のサーバーは次のように機能します。

クライアントはリクエストでサーバーに接続します
サーバーはリクエストを処理します
サーバーは、クライアントにこれ以上の要求があるかどうかを確認するために待機します
クライアントがタイムアウト期間内に別の要求を行わない場合、サーバーは接続を強制終了します

私の問題は次のとおりです。

TCPClientクラスから取得したNetworkStreamオブジェクトから読み取る場合、使用可能なデータがない場合、NetworkStream Read（）メソッドはブロックされません。サーバーがステップ＃3に達したときに、NetworkStreamにタイムアウトを設定したいと思います。クライアントがその期間内にそれ以上リクエストを行わない場合、サーバーはそのタイムアウト例外がスローされたときに接続を強制終了する必要があります。サーバーがステップ3に到達すると、ReadTimeoutプロパティを何に設定したかに関係なく、NetworkStream Read（）メソッドはブロックされません。誰かが私を助けてくれますか、または私がやろうとしていることをするためのより良い方法を提案できますか？

ありがとう

score 2 · Accepted Answer

読み取るデータがない場合、NetworkStream.Read と ReadByte はタイムアウトになるまでブロックする必要があります。呼び出しが何か、おそらくゼロの束を読んでいる可能性がはるかに高いと思います。クライアントから送信されるデータを注意深く確認してください。

score 0 · Accepted Answer

これはあなたが探しているものですか？

http://msdn.microsoft.com/en-us/library/system.net.sockets.tcpclient.receivetimeout.aspx

GetStream() を使用して TcpClient から NetworkStream を取得し、その上で Read() メソッドを呼び出しているようです。

score 0 · Accepted Answer

Read() の使用を卒業してBeginRead()メソッドに移行し、並列処理を検討する必要があります。ネットワークプログラミングは気弱な人向けではありません。

基本的に、データのループポーリングを作成する必要はありません。

while(!timedout && !stream.DataAvailable) sleep(0); // This is bad.
if(steam.DataAvailable) steam.Read();

代わりに、このようなことをする方が理にかなっています。リセットイベントを作成し、BeginRead() を呼び出して、コールバックでリセットイベントを解放します。次のようなもの：

void clientThread()
{
   stream.BeginRead(myCallback);
   resetEvent.WaitOne(timeout)
}
void myCallback
{
   resetEvent.Set();
}

score 0 · Accepted Answer

利用可能なデータがない場合に NetworkStream を明示的に強制的にブロックするには:

TcpClient clientConnection = new TcpClient();

if(clientConnection.Available > 0)
{ 
  //You want to continue execution even though there is no available data to be read from the server then:
  clientConnection.Client.Blocking = false;
}

score 0 · Accepted Answer

NetworkStream を BufferedStream にラップします。BufferedStream.Read は、少なくとも 1 バイトが使用可能になるまでブロックされます。

score -1 · Accepted Answer

NetworkStream.Read() はそれを行う方法を提供しないため、「タイムアウト」を自分で処理する必要があります。

クライアントスレッドでおそらく実行したいことは、NetworkStream.DataAvailable および/または NetworkStream.CanRead をブロッキング/タイムアウトメカニズムと組み合わせて使用することです (タイムアウトを指定した WaitHandle.WaitOne 呼び出しを使用するなど)。データを利用可能にする時間のあるクライアント。指定した時間が経過しても何も来ない場合は、接続をシャットダウンして終了します。

c# - Read（）ブロッキングの問題

6 に答える 6

Related

Reference