Comment gérer les temps d'attente en Async Socket?

J'ai un code que l'utilisation de socket asynchrone à envoyer un message au client et d'attendre la réponse d'elle. Si le client n'a pas répondu dans un certain interne il considère délai d'attente. Certains de l'article dans Internet suggèrent d'utiliser WaitOne, mais cela bloque le thread et reporte le but de l'utilisation d'e/S achèvement.

Quel est le meilleur moyen de gérer les temps d'attente en async socket?

 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
InformationsquelleAutor kevin | 2011-05-12
  1. 7

    Vous ne pouvez pas de délai d'attente ou d'annuler asynchrone Socket opérations.

    Tout ce que vous pouvez faire est de commencer votre propre Timer qui ferme la Socket—le rappel sera alors immédiatement appelé et le EndX fonction de retour avec un ObjectDisposedException si vous l'appelez. Voici un exemple:

    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.
}
}
    • J'ai trouvé une réponse similaire. stackoverflow.com/questions/1231816/... . L'idée est d'avoir un seul timer pour s'occuper de toutes les connexions existant à vérifier est ce délai d'attente.
    InformationsquelleAutor Cory Nelson