与SocketAsyncEventArgs的异步套接字通信超时
本文关键字:通信 超时 套接字 异步 SocketAsyncEventArgs | 更新日期: 2023-09-27 18:24:47
我使用SocketAsyncEventArgs与数百台设备进行通信(其中大多数是通过GPRS)。有时,它们中的一些会停止响应,而且我似乎无法超时操作,因为文档中指出超时选项(即SocketOptionName.SendTimeout)在异步通信中不起作用。
我正在寻找一种在执行发送/接收/连接异步时检查超时的方法。它不应该阻塞线程(所以,调用someMonitor.WaitOne(SomeTimeoutValue)是不行的),我不想为每个操作创建一个定时器实例(因为设备的数量肯定会增加)。
有什么建议吗?
以下是我的操作方法(尽管我不喜欢这个解决方案):
这个想法是有一个定时器,当触发时,它会检查所有挂起的操作是否超时。我创建了一个异步客户端实现的接口:
public interface ITimeoutable {
event Action<ITimeoutable, Operation> Begin;
event Action<ITimeoutable, Operation> End;
void DoTimeout(Operation operation);
}
其中Operation是枚举,定义为:
public enum Operation {
Connect,
Send,
Receive,
Disconnect
}
因此,客户端在启动异步操作时会引发Begin
事件,在完成异步操作时引发End
事件。另一方面,我创建了一个TimeoutManager,它有一个异步客户端的集合和一个包含操作及其启动时刻的字典。创建新客户端时,它会注册到订阅事件的TimeoutManager
中。TimeoutManager
使用System.Threading.Timer
来检查哪些操作超时。如果超时,则调用DoTimeout
方法(从ITimeoutable
接口)。
这是一个相当复杂的代码,我不喜欢它。但它有效。