C++ TCP socket 非阻塞连接超时设定方式

由于网上大部分教程为阻塞方式连接，当项目需要大量连接从机的情况下，阻塞式连接socket会导致长时间卡顿。因此需要用非阻塞式的方式连接，并设置超时是时间，再设置会阻塞。下属C++编辑代码实测可用，代码如下：

SOCKET s；

ctx->s为 socket的套接字，自己定义即可

int rc;
struct sockaddr_in addr;
modbus_tcp_t *ctx_tcp = ctx->backend_data;

#ifdef OS_WIN32
if (_modbus_tcp_init_win32() == -1) {
return -1;
}
#endif

ctx->s = socket(PF_INET, SOCK_STREAM, 0);
if (ctx->s == -1) {
return -1;
}

rc = setsockopt(ctx->s, IPPROTO_TCP, TCP_NODELAY,
(const void *)&option, sizeof(int));
if (rc == -1) {
return -1;
}

if (ctx->debug) {
printf("Connecting to %s\n", ctx_tcp->ip);
}

//想办法将链接设置为非阻塞，链接完成后再设置为阻塞 william 0924

unsigned long ul = 1;
   rc = ioctlsocket(ctx->s, FIONBIO, (unsigned long*)&ul);
   if (rc == SOCKET_ERROR)
       return -1;

//bzero(&addr, sizeof(addr));
   addr.sin_family = AF_INET;
   addr.sin_port = htons(ctx_tcp->port);
   addr.sin_addr.s_addr = inet_addr(ctx_tcp->ip);

rc = connect(ctx->s, (struct sockaddr *)&addr,
sizeof(struct sockaddr_in));

TIMEVAL tm = { 1,0 };//设置超时时间1s
   fd_set rset;
   fd_set wset;
   unsigned long mode = 1;

//一般非锁定模式套接比较难控制，可以根据实际情况考虑再设回阻塞模式 william 0924
   if (rc)
   {
       rc = WSAGetLastError();
       if (WSAEWOULDBLOCK == rc)/*!<如果Resource temporarily unavailable.10035*/
       {
           FD_ZERO(&rset);
           FD_ZERO(&wset);
           FD_SET(ctx->s, &rset);
           FD_SET(ctx->s, &wset);

           rc = select(ctx->s + 1, &rset, &wset, NULL, &tm);
           if (rc<0)
           {
               close(ctx->s);
               return -1;
           }
           else if (rc == 0)/*!<Time Out*/
           {
               close(ctx->s);
               return -1;
           }
           else
           {
               if (FD_ISSET(ctx->s, &wset))/*!<如果可写，说明连接好*/
               {
                   mode = 0;
                   rc = ioctlsocket(ctx->s, FIONBIO, &mode); /*!<再次设置为阻塞模式 */
                   if (rc)
                   {
                       close(ctx->s);
                       return -1;
                   }
                   ///*!<正确退出*/
                   return 0;
               }
               else
               {
                   // /*!<不可写*/
                   close(ctx->s);
                   return -1;
               }
           }
       }// end if(WSAEWOULDBLOCK==ret)
       else
       {
   //   /*!<网络出现其他错误*/
           close(ctx->s);
           return -1;
       }
   }
   else
   {
       return 0;
   }

//一般非锁定模式套接比较难控制，可以根据实际情况考虑再设回阻塞模式

return 0;

C++ TCP socket 非阻塞连接超时设定方式相关推荐

boost库之socket 非阻塞/缓冲区大小等属性设置
boost库之socket 非阻塞/缓冲区大小等属性设置原文:http://blog.csdn.net/byxdaz/article/details/77318219 asio socket 非阻塞 ...
php socket非阻塞,php stream_set_blocking设置非阻塞模式,php stream_set_blocking影响函数fgets()和fread()...
stream_set_blocking函数可以将资源流设置为阻塞模式或者非阻塞模式,主要影响的函数分别是fgets,fread,其他的手册没有说. 在socket编程中,如果一个socket连接上了, ...
阻塞、非阻塞、超时（同步与异步）
今天看RXW文档,看到这个概念,不知啥意思... 1.阻塞: 阻塞==同步->例如:发送消息直到发送成功才能发送下一条消息接收消息这条消息接收完毕才能接收下条消息 2.非阻塞非阻塞 ...
非阻塞的connect使用方式
connect 函数的调用涉及到3次握手,默认connect函数为阻塞连接状态. 通常connect 会阻塞到三次握手的完成和失败,而这个connect阻塞超时时间会依赖于系统,一般为75s到几分钟时 ...
怎样实现一个非阻塞的超时重试任务队列
起因最近接手一个项目,要把其中的阻塞任务队列,重构成非阻塞.在客户端很少有机会直接处理任务队列.项目完成需要总结经验阻塞的发生我这里先说明我遇到的阻塞问题,我这里的阻塞不是多线程访问的阻塞,概念 ...
epoll关于ET、LT模式和socket非阻塞模式的几个总结
epoll的ET和LT模式 LT水平触发是默认的模式,只要缓冲区有消息就会触发,如果这次事件没有被处理,那么下一次调用epoll_wait的时候,事件仍然会被触发:ET边沿触发只会在第一次有消息的时候 ...
Java nio Socket非阻塞模式
NIO 有一个主要的类Selector,这个类似一个观察者,只要我们把需要探知的socketchannel告诉Selector,我们接着做别的事情,当有事件发生时,他会通知我们,传回一组Select ...
java 阻塞 socket_java socket非阻塞I/O
1 非阻塞(Nonblocking)体系结构在这一部分,我将从理论的角度来解释非阻塞体系的结构及其工作原理.这部"喜剧"(当然,如果你喜欢的话也可以称做戏剧)的&quo ...
Socket 非阻塞模式下connect 返回EINPROGRESS（115）错误
今天再测试socket的时候,发现一个很奇怪的问题,就是客户端再connect的时候第一次connect总是会返回-1,errno是115,往往第二次连接就可以成功了.但是对于服务端来说,第一次连接已 ...

C++ TCP socket 非阻塞连接超时设定方式

C++ TCP socket 非阻塞连接超时设定方式相关推荐

最新文章

热门文章