网络发送TCP包有很多重传包，是怎么回事？

eliry

写了两个网络程序，一个客户端，一个服务器端，客户端连过去发送数据包发现对方没接收，通过wireshark抓包发现中间有很多重传包，如图：


大家看下问题出在哪里，谢谢！

dolphin836

我最近也要做TCP的文件发送。
不知LZ可否分享下主要代码研究下。
个人觉得，socket的东西，大家都会写也没什么难度，基本功能也都能实现
主要的点是程序的健壮性和对复杂网络环境的处理。
感觉自己的程序还有很多需要改进的地方。

耗资喜欢猫

上代码吧，另外，既然你用wireshark抓的包，为何要把时间那列给省了，最好是全图

耗资喜欢猫

理论上，TCP连接立后，应该可以直接发送数据了，但是为什么第4条，192.168.20.120会再次给192.168.50.157发送一次syn+ack呢？另外楼主着得看下第五条，看下，是不是checksum错误还是什么原因？

luoyan_xy

感觉三次握手的最后一个包对端没有收到，一直再重发SYN+ACK

eliry

回复 4# 耗资喜欢猫

大家帮分析下，主体代码如下：

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设置为非阻塞方式
    
38.     set_nonblock(listenfd);
    
39. 
    
40.     //声明epoll_event结构体的变量,ev用于注册事件,数组用于回传要处理的事件
    
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) {//如果新监测到一个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.                                 ......  //处理请求
    
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. }
     

复制代码

带有时间的抓包截图：

eliry

dolphin836 发表于 2012-11-22 10:07
我最近也要做TCP的文件发送。
不知LZ可否分享下主要代码研究下。
个人觉得，socket的东西，大家都会写也没 ...

我做的不是文件传输，而是一个自定义协议通讯的东东，主要代码见楼上。
关于网络开发这一块跟你有同感，做稳定和容错性好确实很需要花功夫，也需要一定的技术沉淀，这也是我的一个目标。

eliry

耗资喜欢猫 发表于 2012-11-22 22:43
理论上，TCP连接立后，应该可以直接发送数据了，但是为什么第4条，192.168.20.120会再次给192.168.50.157发 ...

checksum这一块我看了，是“validation disabled”的。

另外说一下，这个程序刚开始跑是没问题的，跑了大概18天才出现的，这中间发生了什么我无从知道。大概还是哪种情况没考虑周全。

zozoiiiiii

tcp协议保证数据收发。。是不是网络不好，导致丢包，然后tcp协议重传。

eliry

回复 9# zozoiiiiii


    内网环境，也排除了IP、MAC地址冲突可能性，我怀疑是程序哪里没写好。