途牛的旅游网站是谁做的,网站备案指的是什么,唐山网站建设拓,软件开发app开发定制外包99本文参考#xff1a;connect 函数在阻塞和非阻塞模式下的行为
一般情况下#xff0c;在使用connect连接服务端时#xff0c;需要等待一会儿才会函数才会返回#xff0c;导致程序阻塞。为了降低阻塞的影响#xff0c;我们可能会单独开个线程处理connect请求#xff0c;例…本文参考connect 函数在阻塞和非阻塞模式下的行为
一般情况下在使用connect连接服务端时需要等待一会儿才会函数才会返回导致程序阻塞。为了降低阻塞的影响我们可能会单独开个线程处理connect请求例如在界面当中就会启用一个线程避免UI卡死。 当然这里还有一些其他的方法也就是我们常见的非阻塞IO。
主要步骤大致如下
创建socket并将 socket 设置成非阻塞模式调用 connect 函数此时无论 connect 函数是否连接成功会立即返回如果返回-1并不表示连接出错如果此时错误码是EINPROGRESS接着调用 select 函数在指定的时间内判断该 socket 是否可写如果可写说明连接成功反之则认为连接失败。
按上述流程编写代码如下 /*** Linux 下正确的异步的connect写法linux_nonblocking_connect.cpp* zhangyl 2018.12.17*/#include sys/types.h #include sys/socket.h#include arpa/inet.h#include unistd.h#include iostream#include string.h#include stdio.h#include fcntl.h#include errno.h#define SERVER_ADDRESS 127.0.0.1#define SERVER_PORT 3000#define SEND_DATA helloworldint main(int argc, char* argv[]){//1.创建一个socketint clientfd socket(AF_INET, SOCK_STREAM, 0);if (clientfd -1){std::cout create client socket error. std::endl;return -1;}//连接成功以后我们再将 clientfd 设置成非阻塞模式//不能在创建时就设置这样会影响到 connect 函数的行为int oldSocketFlag fcntl(clientfd, F_GETFL, 0);int newSocketFlag oldSocketFlag | O_NONBLOCK;if (fcntl(clientfd, F_SETFL, newSocketFlag) -1){close(clientfd);std::cout set socket to nonblock error. std::endl;return -1;}//2.连接服务器struct sockaddr_in serveraddr;serveraddr.sin_family AF_INET;serveraddr.sin_addr.s_addr inet_addr(SERVER_ADDRESS);serveraddr.sin_port htons(SERVER_PORT);for (;;){int ret connect(clientfd, (struct sockaddr *)serveraddr, sizeof(serveraddr));if (ret 0){std::cout connect to server successfully. std::endl;close(clientfd);return 0;} else if (ret -1) {if (errno EINTR){//connect 动作被信号中断重试connectstd::cout connecting interruptted by signal, try again. std::endl;continue;} else if (errno EINPROGRESS){//连接正在尝试中break;} else {//真的出错了close(clientfd);return -1;}}}fd_set writeset;FD_ZERO(writeset);FD_SET(clientfd, writeset);//可以利用tv_sec和tv_usec做更小精度的超时控制struct timeval tv;tv.tv_sec 3; tv.tv_usec 0;if (select(clientfd 1, NULL, writeset, NULL, tv) ! 1){std::cout [select] connect to server error. std::endl;close(clientfd);return -1;}int err;socklen_t len static_castsocklen_t(sizeof err);if (::getsockopt(clientfd, SOL_SOCKET, SO_ERROR, err, len) 0){close(clientfd);return -1;}if (err 0)std::cout connect to server successfully. std::endl;elsestd::cout connect to server error. std::endl;//5. 关闭socketclose(clientfd);return 0;}
