日韩性视频-久久久蜜桃-www中文字幕-在线中文字幕av-亚洲欧美一区二区三区四区-撸久久-香蕉视频一区-久久无码精品丰满人妻-国产高潮av-激情福利社-日韩av网址大全-国产精品久久999-日本五十路在线-性欧美在线-久久99精品波多结衣一区-男女午夜免费视频-黑人极品ⅴideos精品欧美棵-人人妻人人澡人人爽精品欧美一区-日韩一区在线看-欧美a级在线免费观看

歡迎訪問 生活随笔!

生活随笔

當前位置: 首頁 > 运维知识 > linux >内容正文

linux

【Linux网络编程】TCP网络编程中connect()、listen()和accept()三者之间的关系

發布時間:2024/4/21 linux 41 豆豆
生活随笔 收集整理的這篇文章主要介紹了 【Linux网络编程】TCP网络编程中connect()、listen()和accept()三者之间的关系 小編覺得挺不錯的,現在分享給大家,幫大家做個參考.

基于 TCP 的網絡編程開發分為服務器端和客戶端兩部分,常見的核心步驟和流程如下:


connect()函數

對于客戶端的 connect() 函數,該函數的功能為客戶端主動連接服務器,建立連接是通過三次握手,而這個連接的過程是由內核完成,不是這個函數完成的,這個函數的作用僅僅是通知 Linux 內核,讓 Linux 內核自動完成?TCP 三次握手連接(三次握手詳情,請看《淺談 TCP 三次握手》),最后把連接的結果返回給這個函數的返回值(成功連接為0, 失敗為-1)。


通常的情況,客戶端的?connect() 函數默認會一直阻塞,直到三次握手成功或超時失敗才返回(正常的情況,這個過程很快完成)。


listen()函數

對于服務器,它是被動連接的。舉一個生活中的例子,通常的情況下,移動的客服(相當于服務器)是等待著客戶(相當于客戶端)電話的到來。而這個過程,需要調用listen()函數。

#include<sys/socket.h> int listen(int sockfd, int backlog)


listen() 函數的主要作用就是將套接字(?sockfd?)變成被動的連接監聽套接字(被動等待客戶端的連接),至于參數 backlog 的作用是設置內核中連接隊列的長度(這個長度有什么用,后面做詳細的解釋),TCP 三次握手也不是由這個函數完成,listen()的作用僅僅告訴內核一些信息。


這里需要注意的是,listen()函數不會阻塞,它主要做的事情為,將該套接字和套接字對應的連接隊列長度告訴 Linux 內核,然后,listen()函數就結束。


這樣的話,當有一個客戶端主動連接(connect()),Linux 內核就自動完成TCP 三次握手,將建立好的鏈接自動存儲到隊列中,如此重復。


所以,只要 TCP 服務器調用了 listen(),客戶端就可以通過 connect() 和服務器建立連接,而這個連接的過程是由內核完成



下面為測試的服務器和客戶端代碼,運行程序時,要先運行服務器,再運行客戶端:

服務器:

#include <stdio.h> #include <stdlib.h> #include <string.h> #include <unistd.h> #include <sys/socket.h> #include <netinet/in.h> #include <arpa/inet.h> int main(int argc, char *argv[]) {unsigned short port = 8000; int sockfd;sockfd = socket(AF_INET, SOCK_STREAM, 0);// 創建通信端點:套接字if(sockfd < 0){perror("socket");exit(-1);}struct sockaddr_in my_addr;bzero(&my_addr, sizeof(my_addr)); my_addr.sin_family = AF_INET;my_addr.sin_port = htons(port);my_addr.sin_addr.s_addr = htonl(INADDR_ANY);int err_log = bind(sockfd, (struct sockaddr*)&my_addr, sizeof(my_addr));if( err_log != 0){perror("binding");close(sockfd); exit(-1);}err_log = listen(sockfd, 10);if(err_log != 0){perror("listen");close(sockfd); exit(-1);} printf("listen client @port=%d...\n",port);sleep(10); // 延時10ssystem("netstat -an | grep 8000"); // 查看連接狀態return 0; }

客戶端:

#include <stdio.h> #include <unistd.h> #include <string.h> #include <stdlib.h> #include <arpa/inet.h> #include <sys/socket.h> #include <netinet/in.h> int main(int argc, char *argv[]) {unsigned short port = 8000; // 服務器的端口號char *server_ip = "10.221.20.12"; // 服務器ip地址int sockfd;sockfd = socket(AF_INET, SOCK_STREAM, 0);// 創建通信端點:套接字if(sockfd < 0){perror("socket");exit(-1);}struct sockaddr_in server_addr;bzero(&server_addr,sizeof(server_addr)); // 初始化服務器地址server_addr.sin_family = AF_INET;server_addr.sin_port = htons(port);inet_pton(AF_INET, server_ip, &server_addr.sin_addr);int err_log = connect(sockfd, (struct sockaddr*)&server_addr, sizeof(server_addr)); // 主動連接服務器if(err_log != 0){perror("connect");close(sockfd);exit(-1);}system("netstat -an | grep 8000"); // 查看連接狀態while(1);return 0; }


運行程序時,要先運行服務器,再運行客戶端,運行結果如下:


三次握手的連接隊列

這里詳細的介紹一下 listen() 函數的第二個參數(?backlog)的作用:告訴內核連接隊列的長度。


為了更好的理解 backlog 參數,我們必須認識到內核為任何一個給定的監聽套接口維護兩個隊列:

1、未完成連接隊列(incomplete connection queue),每個這樣的 SYN 分節對應其中一項:已由某個客戶發出并到達服務器,而服務器正在等待完成相應的 TCP?三次握手過程。這些套接口處于 SYN_RCVD 狀態。


2、已完成連接隊列(completed connection queue),每個已完成 TCP?三次握手過程的客戶對應其中一項。這些套接口處于 ESTABLISHED 狀態。


?

當來自客戶的 SYN 到達時,TCP 在未完成連接隊列中創建一個新項,然后響應以三次握手的第二個分節:服務器的 SYN 響應,其中稍帶對客戶 SYN 的 ACK(即SYN+ACK),這一項一直保留在未完成連接隊列中,直到三次握手的第三個分節(客戶對服務器 SYN 的 ACK )到達或者該項超時為止(曾經源自Berkeley的實現為這些未完成連接的項設置的超時值為75秒)。


如果三次握手正常完成,該項就從未完成連接隊列移到已完成連接隊列的隊尾。


backlog 參數歷史上被定義為上面兩個隊列的大小之和,大多數實現默認值為 5,當服務器把這個完成連接隊列的某個連接取走后,這個隊列的位置又空出一個,這樣來回實現動態平衡,但在高并發 web 服務器中此值顯然不夠


accept()函數

accept()函數功能是,從處于 established 狀態的連接隊列頭部取出一個已經完成的連接,如果這個隊列沒有已經完成的連接,accept()函數就會阻塞,直到取出隊列中已完成的用戶連接為止。


如果,服務器不能及時調用 accept() 取走隊列中已完成的連接,隊列滿掉后會怎樣呢?UNP(《unix網絡編程》)告訴我們,服務器的連接隊列滿掉后,服務器不會對再對建立新連接的syn進行應答,所以客戶端的 connect 就會返回 ETIMEDOUT。但實際上Linux的并不是這樣的!


下面為測試代碼,服務器 listen() 函數只指定隊列長度為 2,客戶端有 6 個不同的套接字主動連接服務器,同時,保證客戶端的 6 個 connect()函數都先調用完畢,服務器的 accpet() 才開始調用。


服務器:

#include <stdio.h> #include <stdlib.h> #include <string.h> #include <unistd.h> #include <sys/socket.h> #include <netinet/in.h> #include <arpa/inet.h> int main(int argc, char *argv[]) {unsigned short port = 8000; int sockfd = socket(AF_INET, SOCK_STREAM, 0); if(sockfd < 0){perror("socket");exit(-1);}struct sockaddr_in my_addr;bzero(&my_addr, sizeof(my_addr)); my_addr.sin_family = AF_INET;my_addr.sin_port = htons(port);my_addr.sin_addr.s_addr = htonl(INADDR_ANY);int err_log = bind(sockfd, (struct sockaddr*)&my_addr, sizeof(my_addr));if( err_log != 0){perror("binding");close(sockfd); exit(-1);}err_log = listen(sockfd, 2); // 等待隊列為2if(err_log != 0){perror("listen");close(sockfd); exit(-1);} printf("after listen\n");sleep(20); //延時 20秒printf("listen client @port=%d...\n",port);int i = 0;while(1){ struct sockaddr_in client_addr; char cli_ip[INET_ADDRSTRLEN] = ""; socklen_t cliaddr_len = sizeof(client_addr); int connfd;connfd = accept(sockfd, (struct sockaddr*)&client_addr, &cliaddr_len); if(connfd < 0){perror("accept");continue;}inet_ntop(AF_INET, &client_addr.sin_addr, cli_ip, INET_ADDRSTRLEN);printf("-----------%d------\n", ++i);printf("client ip=%s,port=%d\n", cli_ip,ntohs(client_addr.sin_port));char recv_buf[512] = {0};while( recv(connfd, recv_buf, sizeof(recv_buf), 0) > 0 ){printf("recv data ==%s\n",recv_buf);break;}close(connfd); //關閉已連接套接字//printf("client closed!\n");}close(sockfd); //關閉監聽套接字return 0; }

客戶端:

#include <stdio.h> #include <unistd.h> #include <string.h> #include <stdlib.h> #include <arpa/inet.h> #include <sys/socket.h> #include <netinet/in.h>void test_connect() {unsigned short port = 8000; // 服務器的端口號char *server_ip = "10.221.20.12"; // 服務器ip地址int sockfd;sockfd = socket(AF_INET, SOCK_STREAM, 0);// 創建通信端點:套接字if(sockfd < 0){perror("socket");exit(-1);}struct sockaddr_in server_addr;bzero(&server_addr,sizeof(server_addr)); // 初始化服務器地址server_addr.sin_family = AF_INET;server_addr.sin_port = htons(port);inet_pton(AF_INET, server_ip, &server_addr.sin_addr);int err_log = connect(sockfd, (struct sockaddr*)&server_addr, sizeof(server_addr)); // 主動連接服務器if(err_log != 0){perror("connect");close(sockfd);exit(-1);}printf("err_log ========= %d\n", err_log);char send_buf[100]="this is for test";send(sockfd, send_buf, strlen(send_buf), 0); // 向服務器發送信息system("netstat -an | grep 8000"); // 查看連接狀態//close(sockfd); }int main(int argc, char *argv[]) {pid_t pid;pid = fork();if(0 == pid){test_connect(); // 1pid_t pid = fork();if(0 == pid){test_connect(); // 2}else if(pid > 0){test_connect(); // 3}}else if(pid > 0){test_connect(); // 4pid_t pid = fork();if(0 == pid){test_connect(); // 5}else if(pid > 0){test_connect(); // 6}}while(1);return 0; }

同樣是先運行服務器,在運行客戶端,服務器 accept()函數前延時了 20 秒, 保證了客戶端的 connect() 全部調用完畢后再調用 accept(),運行結果如下:

服務器運行效果圖:




客戶端運行效果圖:



按照 UNP 的說法,連接隊列滿后(這里設置長度為 2,發了 6 個連接),以后再調用 connect() 應該統統超時失敗,但實際上測試結果是:有的 connect()立刻成功返回了,有的經過明顯延遲后成功返回了。對于服務器 accpet() 函數也是這樣的結果:有的立馬成功返回,有的延遲后成功返回。


對于上面服務器的代碼,我們把lisen()的第二個參數改為 0 的數,重新運行程序,發現:

客戶端 connect() 全部返回連接成功(有些會延時):



服務器 accpet() 函數卻不能把連接隊列的所有連接都取出來:



對于上面服務器的代碼,我們把lisen()的第二個參數改為大于 6 的數(如 10),重新運行程序,發現,客戶端 connect() 立馬返回連接成功, 服務器 accpet() 函數也立馬返回成功。


TCP 的連接隊列滿后,Linux 不會如書中所說的拒絕連接,只是有些會延時連接,而且accept()未必能把已經建立好的連接全部取出來(如:當隊列的長度指定為 0 ),寫程序時服務器的 listen() 的第二個參數最好還是根據需要填寫,寫太大不好(具體可以看cat /proc/sys/net/core/somaxconn,默認最大值限制是 128),浪費資源,寫太小也不好,延時建立連接。


總結

以上是生活随笔為你收集整理的【Linux网络编程】TCP网络编程中connect()、listen()和accept()三者之间的关系的全部內容,希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯,歡迎將生活随笔推薦給好友。

主站蜘蛛池模板: av网站免费观看 | 非洲黑妞xxxxhd精品 | 麻豆一区二区在线观看 | 精品久久在线 | 色婷婷av一区二区三区在线观看 | 7777在线视频 | 青青草社区视频 | 亚洲精品大片www | 波多野结衣在线看 | 国产亲伦免费视频播放 | www男人的天堂 | 欧美人在线 | 亚洲天天视频 | 亚洲天堂第一区 | 天天操天天玩 | 五月天开心网 | www.激情.com| 免费av成人 | 极品粉嫩国产18尤物 | 国模在线 | 9191国产精品 | 制服丝袜先锋影音 | 美女一区二区三区视频 | 日本aaa视频 | 九九亚洲精品 | 黄色a毛片 | 福利视频导航网 | 高清av一区 | 非洲黄色片 | 99色精品| 一边吃奶一边摸做爽视频 | 成人午夜视频网站 | 国产在线喷水 | 1级av| 光棍影院手机版在线观看免费 | 久久久综合av| 少妇被又大又粗又爽毛片久久黑人 | 91性色| 九七在线视频 | 国产精品白浆一区二小说 | 久久久噜噜噜久久 | 91黄瓜视频 | 国产精品乱码久久久 | 成人在线国产 | 两性囗交做爰视频 | 6090伦理| 在线高清观看免费观看 | 午夜视频在线观看国产 | 视频丨9l丨白浆 | 日本东京热一区二区三区 | 国产精品久久999 | 天堂精品视频 | 污网在线观看 | av在线播放地址 | 国产97色在线 | 成人在线观看亚洲 | 中国浓毛少妇毛茸茸 | 精品九九视频 | 又爽又黄又无遮挡 | 欧美性大战久久久久久 | 蜜桃久久久久久 | 久久精精品久久久久噜噜 | 精品无码人妻一区二区免费蜜桃 | 蜜桃臀一区二区三区 | 狠狠综合一区 | 久久久久久久久久久久久久久久久 | 高清视频一区二区三区 | 99精品在线视频观看 | 久久久国产精品视频 | 欧美私人网站 | 看全黄大色黄大片 | 久久久久人妻一区精品 | 欧美特黄一级视频 | 96av在线视频 | 久久在线视频精品 | 专干老肥女人88av | 69久久精品无码一区二区 | 亚洲狼人在线 | 国产二区自拍 | 婷婷天天| 少女情窦初开的第4集在线观看 | 人妻夜夜爽天天爽 | 国产女人叫床高潮大片免费 | 欧美福利一区二区 | 亚洲欧美网 | 久久人人爽 | 国产精品手机在线 | 亚洲欧美日韩不卡 | 日韩激情精品 | 国产欧美日韩在线视频 | 午夜免费网 | 国产二区电影 | 欧美色一区二区三区在线观看 | 国产素人av | 星铁乱淫h侵犯h文 | 手机看片1024欧美 | 国产美女裸体无遮挡免费视频 | 国产91一区二区三区在线精品 | 天天透天天干 |