文章目錄

• 前言
• 一、使用`select+getsockopt`如何知道是否真的成功的連接到遠(yuǎn)程服務(wù)器？
• 1.1 connect 返回的幾種情況：
• 1.2 針對(duì)1.1中的第二種情況的處理
• 三、 `getsockopt`獲取`SO_ERROR`等于0一定是沒(méi)有問(wèn)題嗎？
• 四、 select 服務(wù)器如何編程能快速知道對(duì)端是否已經(jīng)斷開？
• 總結(jié)

---

前言

使用select+getsockopt如何知道是否真的成功的連接到遠(yuǎn)程服務(wù)器？

客戶端一旦鏈接成功服務(wù)器 fd 的狀態(tài)是什么？是確定不變的？還是多種多樣的？

getsockopt獲取SO_ERROR等于0一定是沒(méi)有問(wèn)題嗎？

select 服務(wù)器如何編程能快速知道對(duì)端是否已經(jīng)斷開？

---

一、使用select+getsockopt如何知道是否真的成功的連接到遠(yuǎn)程服務(wù)器？

最近在看前輩的網(wǎng)絡(luò)客戶端編程，遇到以下代碼：

fd = socket(AF_INET, SOCK_STREAM, 0);ret = connect(fd, ( struct sockaddr* )&addr, sizeof(addr));if (ret == -1 && errno != EINPROGRESS) // connect失敗{ret = CONNECT_ERROR;}else{while(1){FD_ZERO(&read_fds);FD_ZERO(&write_fds);FD_SET(fd, &read_fds);FD_SET(fd, &write_fds);switch (flag){case CHECKSOCKET_CONN:ret = select(fd + 1, &read_fds, &write_fds, NULL, &tv);if (ret <= 0){ // errorret = CONNECT_ERROR;}break;case CHECKSOCKET_READ:ret = select(fd + 1, &read_fds, NULL, NULL, &tv);if (ret < 0){ // errorret = RECV_ERROR;}break;case CHECKSOCKET_WRITE:ret = select(fd + 1, NULL, &write_fds, NULL, &tv);if (ret < 0){ // errorret = SEND_ERROR;}break;default: // never go hereret = RET_UNKNOWN;break;}if (ret == 0){ // timeoutret = TIMEOUT_ERROR;}if (ret < 0) // select error or timeout ,exit{break;}ret = RET_OK; // set ret OKswitch (flag){case CHECKSOCKET_CONN:if (!FD_ISSET(fd, &read_fds) && !FD_ISSET(fd, &write_fds)){ret = CONNECT_ERROR;}else if (FD_ISSET(fd, &read_fds) && FD_ISSET(fd, &write_fds)){ret = getsockopt(fd, SOL_SOCKET, SO_ERROR, &sock_error, &tmp);if (ret == 0 && sock_error == 0){ // connect succ}else if (ret == 0 && sock_error != 0){ret = RET_SOCKET_CONNECT_ERROR;}else{ret = RET_SOCKET_CONNECT_ERROR;}}else if (!FD_ISSET(fd, &read_fds) && FD_ISSET(fd, &write_fds)){ // connect succ}else if (FD_ISSET(fd, &read_fds) && !FD_ISSET(fd, &write_fds)){ret = getsockopt(fd, SOL_SOCKET, SO_ERROR, &sock_error, &tmp);if (ret == 0){}ret = RET_SOCKET_CONNECT_ERROR;}else // never go here{ret = RET_UNKNOWN;}break;case CHECKSOCKET_READ:if (!FD_ISSET(fd, &read_fds)){ret = RET_SOCKET_RECV_ERROR;}break;case CHECKSOCKET_WRITE:if (!FD_ISSET(fd, &write_fds)){ret = SEND_ERROR;}break;default: // never go hereret = RET_UNKNOWN;break;} } }

在網(wǎng)絡(luò)編程中，經(jīng)常使用的是異步的socket也就是非阻塞socket，但是在在異步的情況下如何判斷connect是否連接成功成為了重中之重。

1.1 connect 返回的幾種情況：

connect 返回0，則直接連接成功了。

connect 返回錯(cuò)誤,errno 等于EINPROGRESS,表明socket正在連接，這種情況需要后續(xù)使用epoll wait 后者select 函數(shù)確認(rèn)。

connect 返回錯(cuò)誤,errno不等于EINPROGRESS,那就是連接失敗了

1.2 針對(duì)1.1中的第二種情況的處理

select 模型:將連接的文件描述符加入到讀寫錯(cuò)誤的三個(gè)事件中，調(diào)用select函數(shù)，
如果socket連接失敗,則socket同時(shí)變的可讀可寫。
如果socket連接成功，則第一socket變得可寫，第二就是socket同時(shí)變的可讀（連接成功，對(duì)端馬上有數(shù)據(jù)發(fā)過(guò)來(lái)）可寫。
那么如何判斷connect是否真正的成功了呢？
第15行,程序在connect之后，緊接著調(diào)用select，如果返回錯(cuò)誤，或者因?yàn)槌瑫r(shí)返回0，這兩種情況需要后續(xù)通過(guò)查看socket的可寫可讀的情況進(jìn)行分析。
所以在可讀可寫的情況下，調(diào)用getsockopt函數(shù)選定SO_ERROR，通過(guò)該選項(xiàng)我們可以判斷出socket是否連接成功，注意不是獲取該函數(shù)的返回值而是函數(shù)的參數(shù)返回值，函數(shù)調(diào)用中的第四個(gè)參數(shù)會(huì)返回socket連接錯(cuò)誤的錯(cuò)誤碼，如果成功錯(cuò)誤碼為0，否則不為0。

三、 getsockopt獲取SO_ERROR等于0一定是沒(méi)有問(wèn)題嗎？

TCP socket連接失敗后getsockopt獲取SO_ERROR等于0誤以為連接成功；
在Linux下使用非阻塞TCP連接的方式連接一個(gè)錯(cuò)誤的地址，第一次可以connect返回失敗，getsockopt能夠得到正確的錯(cuò)誤碼。但使用此socket進(jìn)行第二次連接的時(shí)候，connect也返回失敗，getsockopt返回獲取錯(cuò)誤(SO_ERROR)為0，從而認(rèn)為連接成功。
解決方法：tcp 在調(diào)用connect失敗后需要重新創(chuàng)建socket。

這是因?yàn)門CP連接的三次握手產(chǎn)生的問(wèn)題，具體參考

網(wǎng)絡(luò)編程Socket之TCP之connect詳解

四、 select 服務(wù)器如何編程能快速知道對(duì)端是否已經(jīng)斷開？

使用select重寫客戶端程序，目的是服務(wù)器進(jìn)程一終止，客戶就能馬上得到通知。新版程序不是阻塞在套接字事件或者IO調(diào)用上，而是阻塞于select調(diào)用上，或是等待套接字或是等待標(biāo)準(zhǔn)IO輸入。
客戶的套接字上的處理?xiàng)l件：

如果對(duì)端TCP發(fā)送數(shù)據(jù)，那么套接字變?yōu)榭勺x，并且read返回一個(gè)大于0的值

如果對(duì)端TCP發(fā)送一個(gè)FIN（對(duì)端進(jìn)程終止），那么套接字變?yōu)榭勺x，并且read返回0(EOF)

如果對(duì)端TCP發(fā)送一個(gè)RST（對(duì)端主機(jī)崩潰并重啟），那么套接字變?yōu)榭勺x，并且返回 -1

#include "unp.h" void str_cli(FILE *fp, int sockfd) {int maxfdp1;fd_set rset;char sendline[MAXLINE],recvline[MAXLINE];FD_ZERO(&rset);for(;;){FD_SET(fileno(fp),&rset);FD_SET(sockfd, &rset);maxfdp1 = max(fileno(fp), sockfd) + 1;select(maxfdp1,&rset,NULL,NULL,NULL);if (FD_ISSET(sockfd, &rset)){ /*socket is readable*/if(readline(sockfd, recvline,MAXLINE) == 0)err_quit("str_cli:server terminated prematurely");Fputs(recvline, stdout);}if (FD_ISSET(fileno(fp), &rset)) { /* input is readable */if (Fgets(sendline, MAXLINE, fp) == NULL)return; /* all done */Writen(sockfd, sendline, strlen(sendline));}} }

---

總結(jié)

總結(jié)

以上是生活随笔為你收集整理的SOCKET【3】-select+getsockopt客户端检测connect是否成功的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。