C# SendAysnc 超時

業務方法

@@@code

public override async Task<List<(IPEndPoint endPoint, byte[] data)>> SendAsync(IPEndPoint server, byte[] data2, int getResponseCount = 1)

{

//隨機使用埠，支持併發

using (UdpClient udpClient = new UdpClient(LocalIPEndPoint)) //廣播包在有虛擬機的時候必須指定有效網卡

{ //多網卡容易丟包

udpClient.Client.SendTimeout = SendTimeout;

udpClient.Client.ReceiveTimeout = ReceiveTimeout;

byte[] data = IsEncrypt ? Encrypt(data2) : data2;

try

{

int sendLength = await udpClient.SendAsync(data, data.Length, server);

//int sendLength = 0;

//udpClient.SendAsync(data, data.Length, server).Wait(SendTimeout); //同步方法

Log?.Invoke($"send:{server.ToString()},Len:{sendLength}/{data.Length},Data:{new Q.Mina.IoBuffer(data).getHexDump()}");

udpClient.Close();

return result;

}

catch (Exception ex)

{

return null;

}

}

}

@@#

對上述方法調用，可以使用三種方式

非同步，業務方法正常執行，超時處理正常，推薦使用此方法

@@@code

var result = await new Q.Sockets.UDPHelper2() { LocalIPEndPoint = localIP, ReceiveTimeout = 1000 }.SendAsync(ip, data, 1000);

@@#

同步，超時未生效，一直處於等待狀態，除非方法內使用udpClient.SendAsync(data, data.Length, server).Wait(SendTimeout); //同步方法

@@@code

new Q.Sockets.UDPHelper2() { LocalIPEndPoint = localIP, ReceiveTimeout=1000 }.SendAsync(ip, data, 1000).Result

@@#

等待指定時間，強行在外部指定超時，打斷了業務方法的執行時間（如接收大量數據）

@@@code

var x = new Q.Sockets.UDPHelper2() { LocalIPEndPoint = localIP, ReceiveTimeout = 1000 }.SendAsync(ip, data, 1000);

x.Wait(3000);

if (x.IsCompleted)

{

show(x.Result);

}

@@#