7

非同期ソケットを使用してクライアントにメッセージを送信し、そこからの応答を期待するコードがあります。クライアントが指定された内部で応答しなかった場合、タイムアウトと見なされます。インターネットの記事の中には、WaitOne の使用を提案しているものもありますが、これはスレッドをブロックし、I/O 完了を使用する目的を遅らせます。

非同期ソケットでタイムアウトを処理する最良の方法は何ですか?

 Sub OnSend(ByVal ar As IAsyncResult)
       Dim socket As Socket = CType(ar.AsyncState ,Socket)
       socket.EndSend(ar)

       socket.BeginReceive(Me.ReceiveBuffer, 0, Me.ReceiveBuffer.Length, SocketFlags.None, New AsyncCallback(AddressOf OnReceive), socket)

 End Sub
4

1 に答える 1

8

Socket非同期操作をタイムアウトまたはキャンセルすることはできません。

あなたができることは、コールバックTimerを閉じる独自のものを開始することだけですSocket—コールバックがすぐに呼び出され、関数を呼び出すと、EndX関数が返されObjectDisposedExceptionます。次に例を示します。

using System;
using System.Threading;
using System.Net.Sockets;

class AsyncClass
{
     Socket sock;
     Timer timer;
     byte[] buffer;
     int timeoutflag;

     public AsyncClass()
     {
          sock = new Socket(AddressFamily.InterNetwork,
                SocketType.Stream,
                ProtocolType.Tcp);

          buffer = new byte[256];
     }

     public void StartReceive()
     {
          IAsyncResult res = sock.BeginReceive(buffer, 0, buffer.Length,
                SocketFlags.None, OnReceive, null);

          if(!res.IsCompleted)
          {
                timer = new Timer(OnTimer, null, 1000, Timeout.Infinite);
          }
     }

     void OnReceive(IAsyncResult res)
     {
          if(Interlocked.CompareExchange(ref timeoutflag, 1, 0) != 0)
          {
                // the flag was set elsewhere, so return immediately.
                return;
          }

          // we set the flag to 1, indicating it was completed.

          if(timer != null)
          {
                // stop the timer from firing.
                timer.Dispose();
          }

          // process the read.

          int len = sock.EndReceive(res);
     }

     void OnTimer(object obj)
     {
          if(Interlocked.CompareExchange(ref timeoutflag, 2, 0) != 0)
          {
                // the flag was set elsewhere, so return immediately.
                return;
          }

          // we set the flag to 2, indicating a timeout was hit.

          timer.Dispose();
          sock.Close(); // closing the Socket cancels the async operation.
     }
}
于 2011-05-12T14:37:01.187 に答える