博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
[译]C# Socket连接请求超时机制
阅读量:6238 次
发布时间:2019-06-22

本文共 1959 字,大约阅读时间需要 6 分钟。

作者:

译者:

原文:

介绍

您可能注意到了,.Net的System.Net.Sockets.TcpClient和System.Net.Sockets.Socket都没有直接为Connect/BeginConnect提供超时控制机制。因此,当服务器未处于监听状态,或者发生网络故障时,客户端连接请求会被迫等待很长一段时间,直到抛出异常。默认的等待时间长达20~30s。.Net Socket库的SocketOptionName.SendTimeout提供了控制发送数据的超时时间,但并非本文讨论的连接请求的超时时间。

背景

这个问题最初源于我的某个项目,在解决以后,我曾将关键代码发表在自己的博客上。我注意到不少人对此表示感谢,所以我想这是一个常见的问题,或许很多人都需要解决它。

实现

下面是实现的关键代码:

class
TimeOutSocket
{
   
private static bool IsConnectionSuccessful = false
;
   
private static
Exception socketexception;
   
private static ManualResetEvent TimeoutObject = new ManualResetEvent(false
);
   
public static TcpClient Connect(IPEndPoint remoteEndPoint, int
timeoutMSec)
    {
        TimeoutObject.Reset();
        socketexception
= null
       
string serverip =
Convert.ToString(remoteEndPoint.Address);
       
int serverport =
remoteEndPoint.Port;          
        TcpClient tcpclient
= new
TcpClient();
       
        tcpclient.BeginConnect(serverip, serverport,
           
new
AsyncCallback(CallBackMethod), tcpclient);
       
if (TimeoutObject.WaitOne(timeoutMSec, false
))
        {
           
if
(IsConnectionSuccessful)
            {
               
return
tcpclient;
            }
           
else
            {
               
throw
socketexception;
            }
        }
       
else
        {
            tcpclient.Close();
           
throw new TimeoutException("TimeOut Exception"
);
        }
    }
   
private static void
CallBackMethod(IAsyncResult asyncresult)
    {
       
try
        {
            IsConnectionSuccessful
= false
;
            TcpClient tcpclient
= asyncresult.AsyncState as
TcpClient;
            
           
if (tcpclient.Client != null
)
            {
                tcpclient.EndConnect(asyncresult);
                IsConnectionSuccessful
= true
;
            }
        }
       
catch
(Exception ex)
        {
            IsConnectionSuccessful
= false
;
            socketexception
=
ex;
        }
       
finally
        {
            TimeoutObject.Set();
        }
    }
}

这里,ManualResetEvent的WaitOne(TimeSpan, Boolean)起到了主要的作用。它将阻止当前线程,直到ManualResetEvent对象被Set或者超过timeout时间。上面的代码中,调用BeginConnect后通过WaitOne方法阻止当前线程,如果在timeoutMSec时间内连接成功,将在CallBackMethod回调中调用TimeoutObject.Set,解除被阻塞的连接线程并返回;否则,连接线程会在等待超时后,主动关闭连接并抛出TimeoutException。

总结

虽然实现非常简单,但或许很多人都需要连接请求超时机制,如果有任何问题,我会尽力为您解答。

[译注]

作者介绍了一种异步连接+WaitOne的连接请求超时机制。其中的实现细节有值得商榷的地方,比如:a.static成员带来的线程安全性问题;b.可以考虑利用IAsyncResult.AsyncWaitHandle,不必另行创建ManualResetEvent。但瑕不掩瑜,感谢作者的解决思路。

转载地址:http://ofdia.baihongyu.com/

你可能感兴趣的文章
查看mysql数据库存放的路径|Linux下查看MySQL的安装路径
查看>>
selenium+testNG+Ant
查看>>
1024程序员节,你屯书了吗?(内含福利)
查看>>
移动端JS 触摸事件基础
查看>>
Flex拖动原来如此简单
查看>>
温故而知新:什么是wcf
查看>>
centos语言设置
查看>>
php安装
查看>>
Fragment在getUserVisibleHint时进行加载数据的问题记录
查看>>
使用线程池模拟处理耗时任务,通过websocket提高用户体验
查看>>
Java 内部类种类及使用解析
查看>>
Axure产品原型设计工具
查看>>
spice在桌面虚拟化中的应用系列之三(USB映射实现,SSL加密,密码认证,多客户端支持)...
查看>>
Loading project 91606170 of 1: Project FooBar 问题如何解决?
查看>>
C# yeild使用
查看>>
MapReduce-Hadoop分布式计算模型
查看>>
StrokePlus
查看>>
joisino's travel
查看>>
组合游戏-博弈论中经典模型题目
查看>>
浅谈HTTP的GET和POST
查看>>