S.l.e!ep.￠%

像打了激速一样，以四倍的速度运转，开心的工作
简单、开放、平等的公司文化；尊重个性、自由与个人价值；
posts - 1098, comments - 335, trackbacks - 0, articles - 1
  C++博客 :: 首页 :: 新随笔 :: 联系 :: 聚合  :: 管理

TCP连接非正常断开的检测

Posted on 2010-12-29 10:38 S.l.e!ep.￠% 阅读(1838) 评论(0)  编辑 收藏 引用 所属分类: NetWork 、epoll

TCP连接非正常断开的检测

如果主机崩溃，write是否阻塞取决于内核的tcp缓冲区，但read将一直阻塞，直到超时ETIMEOUT，或由于某些中间路由器的原因返回EHOSTUNREACH/ENETUNREACH。select不能检测到该情况。
如果主机崩溃并重起，客户的write到达主机时主机响应RST，客户的read将返ECONNRESET。





此处的”非正常断开”指TCP连接不是以优雅的方式断开,如网线故障等物理链路的原因,还有突然主机断电等原因
有两种方法可以检测:1.TCP连接双方定时发握手消息 2.利用TCP协议栈中的KeepAlive探测
第二种方法简单可靠,只需对TCP连接两个Socket设定KeepAlive探测,所以本文只讲第二种方法在Linux,Window2000下的实现(在其它的平台上没有作进一步的测试)
Windows 2000平台下
C++代码 复制代码
  1. //定义结构及宏   
  2. struct TCP_KEEPALIVE {   
  3. u_longonoff;   
  4. u_longkeepalivetime;   
  5. u_longkeepaliveinterval;   
  6. } ;   
  7. #define SIO_KEEPALIVE_VALS _WSAIOW(IOC_VENDOR,4)   
  8. //KeepAlive实现   
  9. TCP_KEEPALIVE inKeepAlive = {0}; //输入参数   
  10. unsigned long ulInLen = sizeof(TCP_KEEPALIVE);   
  11. TCP_KEEPALIVE outKeepAlive = {0}; //输出参数   
  12. unsigned long ulOutLen = sizeof(TCP_KEEPALIVE);   
  13. unsigned long ulBytesReturn = 0;   
  14. //设置socket的keep alive为5秒，并且发送次数为3次   
  15. inKeepAlive.onoff = 1;   
  16. inKeepAlive.keepaliveinterval = 5000; //两次KeepAlive探测间的时间间隔   
  17. inKeepAlive.keepalivetime = 5000; //开始首次KeepAlive探测前的TCP空闭时间   
  18. if (WSAIoctl((unsigned int)s, SIO_KEEPALIVE_VALS,   
  19. (LPVOID)&inKeepAlive, ulInLen,   
  20. (LPVOID)&outKeepAlive, ulOutLen,   
  21. &ulBytesReturn, NULL, NULL) == SOCKET_ERROR)   
  22. {   
  23. ACE_DEBUG ((LM_INFO,   
  24. ACE_TEXT ("(%P|%t) \WSAIoctl failed. error code(%d)!\n"),WSAGetLastError()));   
  25. }  


Linux平台下
C++代码 复制代码
  1. #include   
  2. ……   
  3. ////KeepAlive实现   
  4. //下面代码要求有ACE,如果没有包含ACE,则请把用到的ACE函数改成linux相应的接口   
  5. int keepAlive = 1;//设定KeepAlive   
  6. int keepIdle = 5;//开始首次KeepAlive探测前的TCP空闭时间   
  7. int keepInterval = 5;//两次KeepAlive探测间的时间间隔   
  8. int keepCount = 3;//判定断开前的KeepAlive探测次数   
  9. if(setsockopt(s,SOL_SOCKET,SO_KEEPALIVE,(void*)&keepAlive,sizeof(keepAlive)) == -1)   
  10. {   
  11. ACE_DEBUG ((LM_INFO,   
  12. ACE_TEXT ("(%P|%t) setsockopt SO_KEEPALIVE error!\n")));   
  13. }   
  14. if(setsockopt(s,SOL_TCP,TCP_KEEPIDLE,(void *)&keepIdle,sizeof(keepIdle)) == -1)   
  15. {   
  16. ACE_DEBUG ((LM_INFO,   
  17. ACE_TEXT ("(%P|%t) setsockopt TCP_KEEPIDLE error!\n")));   
  18. }   
  19. if(setsockopt(s,SOL_TCP,TCP_KEEPINTVL,(void *)&keepInterval,sizeof(keepInterval)) == -1)   
  20. {   
  21. ACE_DEBUG ((LM_INFO,   
  22. ACE_TEXT ("(%P|%t) setsockopt TCP_KEEPINTVL error!\n")));   
  23. }   
  24. if(setsockopt(s,SOL_TCP,TCP_KEEPCNT,(void *)&keepCount,sizeof(keepCount)) == -1)   
  25. {   
  26. ACE_DEBUG ((LM_INFO,   
  27. ACE_TEXT ("(%P|%t)setsockopt TCP_KEEPCNT error!\n")));   
  28. }  

只有注册用户登录后才能发表评论。
网站导航: 博客园   IT新闻   BlogJava   知识库   博问   管理