当前位置：首页 > 编程日记 > 正文

【网络编程】非阻塞connect详解

编程日记 2025-01-14 03:40:00

一、为什么使用非阻塞connect

TCP连接的建立涉及一个在三路握手过程，阻塞的connect一直等到客户收到自己的SYN的ACK才返回，这需要至少一个RTT时间，RTT时间波动很大从几毫秒到几秒。而且在没有响应时，会等待数秒再次发送，（详见TCPv2第828页），总共75秒到几分钟的connect超时时间。为了缩短超时时间，将非阻塞connect与select配合使用

二、connect的处理细节

1、当服务器和客户端在同一个主机上时，connect会立刻建立；

2、建立成功select监测到描述符为可写（详见TCPv2第531页）；

3、建立失败select检测到描述符为可读可写（详见TCPv2第530页）；

4、当可写返回时，通过写成功与否来判断，网络建立成功或失败。

三、代码详解

int MyConnect(int fd, char *addr, int port, int timeout)

{
   struct sockaddr_in server_addr;
   int ioFlags = 0;
   int ret;
   char temp_addr[IP_LEN];

   //设置非阻塞读写，使connect成为非阻塞的
   ioFlags = fcntl(fd, F_GETFL, 0);
   fcntl(fd, F_SETFL, ioFlags|O_NONBLOCK);

   //设置服务器地址
   memset(&server_addr, 0, sizeof(struct sockaddr_in));
   memset(temp_addr, 0, IP_LEN);
   strcpy(temp_addr,addr);

   if (inet_aton(temp_addr, &server_addr.sin_addr) == 0)

{
//再次设置非阻塞读写
fcntl(fd, F_SETFL, ioFlags);

return -1；

}

   server_addr.sin_family = AF_INET;
   server_addr.sin_port = htons(port);

   //连接服务器
   ret = connect(fd, (struct sockaddr *)&server_addr, sizeof(struct sockaddr));
   if( ret == 0 )   //连接成功，服务器与客户端立即建立连接
   {

   }
   else
   {
       if( errno != EINPROGRESS )   //连接失败，EINPROGRESS代表正在进行三次握手

{
//再次设置非阻塞读写
fcntl(fd, F_SETFL, ioFlags);

return -1;
       }
       else //(errno==EINPROGRESS)   //正在进行三次握手
       {
           fd_set rSet, wSet;
           struct timeval to;

           FD_ZERO(&rSet);
           FD_SET(fd, &rSet);
           wSet = rSet;
           to.tv_sec = timeout;
           to.tv_usec= 0;

           ret = select(fd+1, &rSet, &wSet, NULL, &to);//监听网络
           if(ret<0) //select返回错误，连接失败

{
//再次设置非阻塞读写
fcntl(fd, F_SETFL, ioFlags);

return -1;
           }
           else if(ret==0) //连接超时
           {
   //再次设置非阻塞读写
      fcntl(fd, F_SETFL, ioFlags);
                return -1;
           }
           else
           {
               if( FD_ISSET(fd, &wSet) )
               {
                   errno = 0;
                   char t = 0;

                   ret = send(fd, &t, 0, 0);
                   if( (ret==0)&&(errno==0) ) //连接成功
                   {

                   }
                   else
                   {
                         //再次设置非阻塞读写
             fcntl(fd, F_SETFL, ioFlags);
                       return -1;
                   }
               }
               else
               {
   //再次设置非阻塞读写
   fcntl(fd, F_SETFL, ioFlags);
               return -1;
               }
           }
       }
   }

   //再次设置非阻塞读写
   fcntl(fd, F_SETFL, ioFlags);

   return 0;
}

https://www.dkcj.cn/info/36198.html

【网络编程】非阻塞connect详解

相关文章：

AI，被“横扫记录”反噬？

android 入门之一【开发环境搭建】

一块GPU就能训练语义分割网络，百度PaddlePaddle是如何优化的？

【音频】Faad源码交叉编译

springboot 整合redis 实现KeySpaceNotification 键空间通知

黄聪：穿过主机访问虚拟机中的SQL服务 FOR VMware NAT

【数据库】mysql报错编码码1130 和错误码1146

一键fxxk，代码修复神器拯救你

hive2.3.2安装使用

Google经典面试题解析

1分钟构建API网关日志解决方案

ISQL*PLUS

【数据库】mysql 常用命令（一）

15 个 JavaScript Web UI 库

【网络编程】MarioTCP

Spring MVC-ContextLoaderListener和DispatcherServlet

《中国人工智能ABC人才发展报告》发布，算法和应用类人才短缺

博客域名改为http://bobli.cnblogs.com

百度Apollo 3.5是如何设计Cyber RT计算框架的？

Spark Streaming实践和优化

【网络编程】MarioTCP 流程图（一）

Python | 一万多条拼车数据，看春运的迁徙图

[转载] sql server 2000系统表解释

【驱动】uboot环境变量分析

python--属性魔法方法

利用三层交换机实现VLAN的通信实验报告

【Qt】Qt Creator中文输入设置

为何Google将几十亿行源代码放在一个仓库？

Java反射得到属性的值和设置属性的值

ASP.NET 中的正则表达式