網(wǎng)絡(luò)發(fā)送TCP包有很多重傳包，是怎么回事？

eliry

寫了兩個(gè)網(wǎng)絡(luò)程序，一個(gè)客戶端，一個(gè)服務(wù)器端，客戶端連過(guò)去發(fā)送數(shù)據(jù)包發(fā)現(xiàn)對(duì)方?jīng)]接收，通過(guò)wireshark抓包發(fā)現(xiàn)中間有很多重傳包，如圖：


大家看下問(wèn)題出在哪里，謝謝！

dolphin836

我最近也要做TCP的文件發(fā)送。
不知LZ可否分享下主要代碼研究下。
個(gè)人覺(jué)得，socket的東西，大家都會(huì)寫也沒(méi)什么難度，基本功能也都能實(shí)現(xiàn)
主要的點(diǎn)是程序的健壯性和對(duì)復(fù)雜網(wǎng)絡(luò)環(huán)境的處理。
感覺(jué)自己的程序還有很多需要改進(jìn)的地方。

耗資喜歡貓

上代碼吧，另外，既然你用wireshark抓的包，為何要把時(shí)間那列給省了，最好是全圖

耗資喜歡貓

理論上，TCP連接立后，應(yīng)該可以直接發(fā)送數(shù)據(jù)了，但是為什么第4條，192.168.20.120會(huì)再次給192.168.50.157發(fā)送一次syn+ack呢？另外樓主著得看下第五條，看下，是不是checksum錯(cuò)誤還是什么原因？

luoyan_xy

感覺(jué)三次握手的最后一個(gè)包對(duì)端沒(méi)有收到，一直再重發(fā)SYN+ACK

eliry

回復(fù) 4# 耗資喜歡貓

大家?guī)头治鱿�，主體代碼如下：

1. 
   
2. void *network_proc_thread(void *arg)
   
3. {
   
4.     int listenfd, connfd, sockfd, epfd, nfds, i;
   
5.         struct sockaddr_in addr, clientaddr;
   
6.     socklen_t clilen = sizeof(struct sockaddr);
   
7. 
   
8.         if ((listenfd = socket(AF_INET, SOCK_STREAM, 0)) == -1) {
   
9.                 log_it("sock create failed!: %s\n", strerror(errno));
   
10.                 pthread_exit(-1);
    
11.         }
    
12. 
    
13.     int listen_port = LISTEN_PORT;
    
14. 
    
15.         bzero(&addr, sizeof(addr));
    
16.         addr.sin_family = AF_INET;
    
17.         addr.sin_port = htons(listen_port);
    
18.         addr.sin_addr.s_addr = htonl(INADDR_ANY);
    
19. 
    
20.         //重用端口
    
21.         int opt = 1;
    
22.         if (setsockopt(listenfd, SOL_SOCKET, SO_REUSEADDR, &opt, sizeof(opt))) {
    
23.         log_it("setsockopt REUSEADDR error: %s\n", strerror(errno));
    
24.     }
    
25.         if (bind(listenfd, (struct sockaddr*)&addr, sizeof(addr))) {
    
26.                 log_it("sock bind Failed: %s\n", strerror(errno));
    
27.                 pthread_exit(-1);
    
28.         }
    
29.         if (listen(listenfd, 10)) {
    
30.         close(listenfd);
    
31.                 log_it("sock listen Failed!\n");
    
32.                 pthread_exit(-1);
    
33.         }
    
34. 
    
35.         log_it("network listening on port: %d ......\n", listen_port);
    
36. 
    
37.     //把socket設(shè)置為非阻塞方式
    
38.     set_nonblock(listenfd);
    
39. 
    
40.     //聲明epoll_event結(jié)構(gòu)體的變量,ev用于注冊(cè)事件,數(shù)組用于回傳要處理的事件
    
41.     struct epoll_event ev, events[20];
    
42.     //生成用于處理accept的epoll專用的文件描述符
    
43.     epfd = epoll_create(256);
    
44. 
    
45.     ev.data.fd = listenfd;
    
46.     ev.events = EPOLLIN | EPOLLET;
    
47.     if (epoll_ctl(epfd, EPOLL_CTL_ADD, listenfd, &ev) == -1) {
    
48.         perror("epoll_ctl: listenfd");
    
49.         exit(1);
    
50.     }
    
51. 
    
52.     while (1) {
    
53.         nfds = epoll_wait(epfd, events, 20, 500);
    
54. 
    
55.         for (i = 0; i < nfds; ++i) {
    
56.             if(events[i].data.fd == listenfd) {//如果新監(jiān)測(cè)到一個(gè)SOCKET用戶連接到了綁定的SOCKET端口，建立新的連接。
    
57.                 connfd = accept(listenfd, (struct sockaddr *)&clientaddr, &clilen);
    
58.                 if (connfd < 0){
    
59.                     log_it("accept error!\n");
    
60.                     continue;
    
61.                 }
    
62. 
    
63.                 int port;
    
64.                 char ip_addr[20] = {0};
    
65.                 get_ip_port(connfd, ip_addr, &port);
    
66.                 log_it("receive a connection from: %s : %d, fd: %d ......\n", ip_addr, port, connfd);
    
67. 
    
68.                 ev.events = EPOLLIN | EPOLLET;
    
69.                 ev.data.fd = connfd;
    
70.                 epoll_ctl(epfd, EPOLL_CTL_ADD, connfd, &ev);
    
71.             } else if(events[i].events & EPOLLIN) {
    
72.                 if ((sockfd = events[i].data.fd) < 0)
    
73.                     continue;
    
74. 
    
75.                 request_head_t  pkt_head;
    
76.                 int n;
    
77. 
    
78.                 if ((n = read(sockfd, &pkt_head, sizeof(pkt_head))) < 0) {
    
79.                     if (errno == ECONNRESET) {
    
80.                         log_it("peer may crash!!\n");
    
81.                         close(sockfd);
    
82.                         epoll_ctl(epfd, EPOLL_CTL_DEL, sockfd, NULL);
    
83.                         continue;
    
84.                     } else
    
85.                         log_it("read request_head_t error: %d\n", errno);
    
86.                 } else if (n == 0) {
    
87.                     log_it("peer may close the socket!\n");
    
88.                     close(sockfd);
    
89.                     epoll_ctl(epfd, EPOLL_CTL_DEL, sockfd, NULL);
    
90.                     continue;
    
91.                 }
    
92.                                
    
93.                                 ......  //處理請(qǐng)求
    
94.                                
    
95.                 ev.data.fd = sockfd;
    
96.                 ev.events = EPOLLOUT | EPOLLET;
    
97.                 epoll_ctl(epfd, EPOLL_CTL_MOD, sockfd, &ev);
    
98. 
    
99.             } else if(events[i].events & EPOLLOUT) {
    
100.                 sockfd = events[i].data.fd;
     
101. 
     
102.                 ev.data.fd = sockfd;
     
103.                 ev.events = EPOLLIN | EPOLLET;
     
104.                 epoll_ctl(epfd, EPOLL_CTL_MOD, sockfd, &ev);
     
105.             } else if (events[i].events & EPOLLERR) {
     
106.                 log_it("fd: %d is bad!\n", events[i].data.fd);
     
107.                 close(events[i].data.fd);
     
108.                 epoll_ctl(epfd, EPOLL_CTL_DEL, events[i].data.fd, NULL);
     
109.             } else if (events[i].events & EPOLLHUP) {
     
110.                 log_it("fd : %d EPOLLHUP!\n", events[i].data.fd);
     
111.             }
     
112.         }
     
113.     }
     
114. 
     
115.     log_it("network thread exit normally!\n");
     
116.     return 0;
     
117. }
     

復(fù)制代碼

帶有時(shí)間的抓包截圖：

eliry

dolphin836 發(fā)表于 2012-11-22 10:07
我最近也要做TCP的文件發(fā)送。
不知LZ可否分享下主要代碼研究下。
個(gè)人覺(jué)得，socket的東西，大家都會(huì)寫也沒(méi) ...

我做的不是文件傳輸，而是一個(gè)自定義協(xié)議通訊的東東，主要代碼見(jiàn)樓上。
關(guān)于網(wǎng)絡(luò)開(kāi)發(fā)這一塊跟你有同感，做穩(wěn)定和容錯(cuò)性好確實(shí)很需要花功夫，也需要一定的技術(shù)沉淀，這也是我的一個(gè)目標(biāo)。

eliry

耗資喜歡貓 發(fā)表于 2012-11-22 22:43
理論上，TCP連接立后，應(yīng)該可以直接發(fā)送數(shù)據(jù)了，但是為什么第4條，192.168.20.120會(huì)再次給192.168.50.157發(fā) ...

checksum這一塊我看了，是“validation disabled”的。

另外說(shuō)一下，這個(gè)程序剛開(kāi)始跑是沒(méi)問(wèn)題的，跑了大概18天才出現(xiàn)的，這中間發(fā)生了什么我無(wú)從知道。大概還是哪種情況沒(méi)考慮周全。

zozoiiiiii

tcp協(xié)議保證數(shù)據(jù)收發(fā)。。是不是網(wǎng)絡(luò)不好，導(dǎo)致丟包，然后tcp協(xié)議重傳。

eliry

回復(fù) 9# zozoiiiiii


    內(nèi)網(wǎng)環(huán)境，也排除了IP、MAC地址沖突可能性，我懷疑是程序哪里沒(méi)寫好。