Linux网络编程二(TCP图解三次握手及四次挥手、TCP滑动窗口、MSS、TCP状态转换、多进程/多线程服务器实现)

2024-04-03 09:12
文章标签 实现 linux 服务器 多线程 编程 转换 进程 图解 网络 窗口 tcp 状态 四次 握手 挥手 三次 滑动 mss

本文主要是介绍Linux网络编程二(TCP图解三次握手及四次挥手、TCP滑动窗口、MSS、TCP状态转换、多进程/多线程服务器实现)，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

文章目录

      • 1、TCP三次握手
        • (1) 第一次握手
        • (2) 第二次握手
        • (3) 第三次握手
      • 2、TCP四次挥手
        • (1) 一次挥手
        • (2) 二次挥手
        • (3) 三次挥手
        • (4) 四次挥手
      • 3、TCP滑动窗口
      • 4、TCP状态时序图
      • 5、多进程并发服务器
      • 6、多线程并发服务器

1、TCP三次握手

TCP三次握手(TCP three-way handshake)是TCP协议建立可靠连接的过程，确保客户端和服务器之间可以进行可靠的通信。下面是TCP三次握手的详细过程：
假设客户端为A，服务器为B。

SYN---> ACK + SYN --->ACK
(1) 第一次握手

第一次握手（SYN=1，seq=500）
A向B发送一个带有SYN标志位的数据包，表示A请求建立连接。SYN标志位为1表示这是一个连接请求数据包，500是A随机选择的初始序列号。

(2) 第二次握手

第二次握手（SYN=1，ACK=1，ack=500+1，seq=800）：
B接收到A发送的连接请求后，会向A回复一个数据包。该数据包中，SYN和ACK标志位都被设置为1。ACK=1表示B确认收到了A的连接请求，ack字段的值为A的初始序列号加1，表明B期望下一个收到的序列号是A初始序列号加1。seq字段800是B随机选择的初始序列号。

(3) 第三次握手

第三次握手（ACK=1，ack=800+1）：
A收到B的回复后，检查ACK标志位是否为1，以及ack字段的值是否为B的初始序列号加1。如果正确，A会向B发送一个确认数据包。在该数据包中，ACK标志位被设置为1，表示A确认收到了B的回复。ack字段的值是B的初始序列号加1，表明A期望下一个收到的序列号是B初始序列号加1。
完成这三次握手后，TCP连接就建立成功，A和B之间可以开始传输数据。连接的状态变为已建立(ESTABLISHED)。
三次握手是操作系统内核（Kernel）的TCP协议栈负责处理。用户层的表现：服务器端是accept()，客户端是connect()，其这两个函数成功执行并返回了。
自创

2、TCP四次挥手

TCP四次挥手（TCP four-way handshake）是TCP连接的关闭过程，用于在客户端和服务器之间终止一个已建立的连接。与TCP三次握手不同，四次挥手需要进行四个步骤来关闭连接，以确保数据传输的完整性和可靠性。

FIN--->ACK   FIN--->ACk
(1) 一次挥手

客户端向服务器发送连接释放请求（FIN）的数据包。
客户端希望关闭连接，因此发送一个带有FIN标志位的数据包，FIN=1表示连接释放请求。设置序列号为seq=501。

(2) 二次挥手

服务器接收到客户端的连接释放请求后，回复确认连接释放（ACK）的数据包。
服务器收到客户端的FIN后，发送一个带有ACK标志位的数据包，ACK=1，ack 502表示确认收到客户端的连接释放请求。

(3) 三次挥手

服务器向客户端发送连接释放请求（FIN）的数据包。
服务器希望关闭连接，因此发送一个带有FIN标志位的数据包，FIN=1表示连接释放请求。设置序列号为seq=701。

(4) 四次挥手

客户端接收到服务器的连接释放请求后，回复确认连接释放（ACK）的数据包。
客户端收到服务器的FIN后，发送一个带有ACK标志位(这个不是数据，是控制报文)，ACK=1，ack 702表示确认收到服务器的连接释放请求。
在发送完ACK后，客户端等待一段时间，确保服务器收到了ACK，然后完全关闭连接。

3、TCP滑动窗口

TCP滑动窗口是TCP协议中的一个重要概念，用于实现流量控制和可靠性传输。滑动窗口机制允许发送方和接收方在数据传输过程中动态调整可发送和可接收的数据量，从而适应不同的网络条件和接收方的处理能力。每次通信时，接收方利用win(4096)告知发送方缓冲区剩余大小。
MSS（Maximum Segment Size）是指TCP数据包中的最大有效载荷大小，它表示在TCP协议中一次性发送的最大数据量（即数据包中的有效数据部分，不包括TCP头部和IP头部）。
在TCP连接建立时，通过TCP三次握手的过程中，双方会交换彼此的MSS值，然后根据两端通信的网络链路的MTU大小进行协商，确定实际使用的MSS。

MSS = 1500 - 20 (TCP头部) - 20 (IP头部) = 1460 字节

这意味着在该TCP连接中，一次可以发送的最大有效数据量为1460字节，超过这个大小的数据将被拆分成多个TCP数据包进行传输。
MSS的设置对于TCP性能和网络吞吐量很重要。合理设置MSS可以避免网络分段和数据重组，提高数据传输效率，特别是在一些高延迟、低带宽的网络环境中。

4、TCP状态时序图

使用命令查看状态

netstat -aptn | grep 端口号  #查看tcp端口

netstat -apn | grep 端口号  #查看tcp、udp端口

1、主动发起连接请求端
CLOSE----发送 SYN—SYN_SEND—接收 ACK、SYN—发送 ACK-ESTABLISHED(数据通信态)

2、主动关闭连接请求端
ESTABLISHED(数据通信态)—发送 FIN—FIN_WAIT_1 --接收 ACK --FIN_WAIT_2(半关闭)—接收对端发送 FIN—FIN_WAIT_2(半关闭)—回发ACK–TIME_WAIT(只有主动关闭连接方，会经历该状态)—等2MSL时长—CLOSE

3、被动接收连接请求端
CLOSE—LISTEN—接收 SYN—LISTEN—发送 ACK、SYN—SYN_RCVD—接收ACK—ESTABLISHED(数据通信态)

4、被动关闭连接请求端
ESTABLISHED(数据通信态)—接收 FIN —ESTABLISHED(数据通信态)— 发送ACK — CLOSE_WAIT(说明对端【主动关闭连接端】处于FIN_WAIT_2(半关闭)状态—发送FIN —LAST_ACK—接收ACK—CLOSE
重点：ESTABLISHED(数据通信态)、FIN_WAIT_2、CLOSE_WAIT、TIME_WAIT(2MSL).
在这里插入图片描述
先启动服务器，只有LISTEN状态。
在这里插入图片描述
启动客户端，此时三次握手建立完成，进入ESTABLISHED(数据通信态)。
在这里插入图片描述
尝试关闭一个客户端，此时该客户端进入TIME_WAIT状态。
在这里插入图片描述
服务器先主动关闭，服务器进入FIN_WAIT_2(半关闭)状态。客户端进入CLOSE_WAIT状态。
在这里插入图片描述
此时迅速关闭客户端，客户端处于TIME_WAIT状态。
在这里插入图片描述
提示：#include "wrap.h"错误处理函数，已经封装
错误处理函数

5、多进程并发服务器

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <errno.h>
#include <unistd.h>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <ctype.h>
#include <pthread.h>
#include <signal.h>
#include <sys/wait.h>
#include "wrap.h"				//错误处理函数，已经封装//https://blog.csdn.net/qq_45009309/article/details/131813756?ops_request_misc=%257B%2522request%255Fid%2522%253A%2522171204506416800184170823%2522%252C%2522scm%2522%253A%252220140713.130102334.pc%255Fblog.%2522%257D&request_id=171204506416800184170823&biz_id=0&utm_medium=distribute.pc_search_result.none-task-blog-2~blog~first_rank_ecpm_v1~rank_v31_ecpm-1-131813756-null-null.nonecase&utm_term=%E9%94%99%E8%AF%AF&spm=1018.2226.3001.4450
#define SRV_PORT 9999void catch_child(int signum)		//回调函数 内核操作 产生信号后进来
{while(waitpid(0, NULL, WNOHANG) > 0);	 //非阻塞回收子进程//循环回收是因为可能产生多个子进程死亡return ;				
}int main(int argc, char* argv[])
{int lfd, cfd;								pid_t pid;int ret;char buf[BUFSIZ];struct sockaddr_in srv_addr, clt_addr;socklen_t clt_addr_len;//memset(&srv_addr, 0, sizeof(srv_addr));				//地址结构清零bzero(&srv_addr, sizeof(srv_addr));srv_addr.sin_family = AF_INET;							srv_addr.sin_port = htons(SRV_PORT);srv_addr.sin_addr.s_addr = htonl(INADDR_ANY);lfd = Socket(AF_INET, SOCK_STREAM, 0);		//创建套接字 返回用于监听的文件描述符Bind(lfd, (struct sockaddr*)&srv_addr, sizeof(srv_addr));	//绑定服务器IP+地址Listen(lfd, 128);							//设置监听上线clt_addr_len = sizeof(clt_addr);while (1) {cfd = Accept(lfd, (struct sockaddr*)&clt_addr, &clt_addr_len);	//返回用于双方通信的文件描述符pid = fork();							//创建子进程if (pid < 0) {perr_exit("fork error");}else if (pid == 0) {close(lfd);break;}else {									//父进程使用信号捕捉回收子进程struct sigaction act;act.sa_handler = catch_child;sigemptyset(&act.sa_mask);act.sa_flags = 0;ret = sigaction(SIGCHLD, &act, NULL);if (ret != 0) {perr_exit("sigaction error");}close(cfd);continue;}}if (pid == 0) {								//子进程实现读写功能for (;;) {ret = Read(cfd, buf, sizeof(buf));for (int i = 0; i < ret; i++) {buf[i] = toupper(buf[i]);}write(cfd, buf, ret);write(STDOUT_FILENO, buf, ret);		//实现大小写转换功能if (ret == 0) {close(cfd);exit(1);}}}return 0;
}

在这里插入图片描述

6、多线程并发服务器

//头文件同上#define MAXLINE 8192
#define SERV_PORT 8000struct s_info {							//定义一个结构体，将地址结构跟cfd捆绑struct sockaddr_in cliaddr;		int connfd;
};void* do_work(void* arg)				//子线程主调函数
{int n, i;struct s_info* ts = (struct s_info*)arg;char buf[MAXLINE];char str[INET_ADDRSTRLEN];			//16while (1) {n = Read(ts->connfd, buf, MAXLINE);if (n == 0) {printf("the client %d closed...\n", ts->connfd);break;}printf("received from %s at PORT %d\n",			//打印客户端IP+端口inet_ntop(AF_INET, &(*ts).cliaddr.sin_addr, str, sizeof(str)),ntohs((*ts).cliaddr.sin_port));for (i = 0; i < n; i++)buf[i] = toupper(buf[i]);Write(STDOUT_FILENO, buf, n);Write(ts->connfd, buf, n);					//回写到客户端}Close(ts->connfd);return (void*)0;
}int main(int argc, char* argv[])
{struct sockaddr_in servaddr, cliaddr;socklen_t cliaddr_len;int listenfd, connfd;pthread_t tid;struct s_info ts[256];		//创建结构体数组int i = 0;listenfd = Socket(AF_INET, SOCK_STREAM, 0);			//创建一个socket,得到lfdbzero(&servaddr, sizeof(servaddr));servaddr.sin_family = AF_INET;servaddr.sin_port = htons(SERV_PORT);				//指定端口号servaddr.sin_addr.s_addr = htonl(INADDR_ANY);		//指定本地任意IPBind(listenfd, (struct sockaddr*)&servaddr, sizeof(servaddr));	//绑定Listen(listenfd, 128);printf("Accepting client connect...\n");while (1) {cliaddr_len = sizeof(cliaddr);connfd = Accept(listenfd, (struct sockaddr*)&cliaddr, &cliaddr_len);		//阻塞监听客户端链接请求ts[i].cliaddr = cliaddr;ts[i].connfd = connfd;pthread_create(&tid, NULL, do_work, (void*)&ts[i]);pthread_detach(tid);							//子线程分离，防止僵尸线程产生i++;}return 0;
}

这篇关于Linux网络编程二(TCP图解三次握手及四次挥手、TCP滑动窗口、MSS、TCP状态转换、多进程/多线程服务器实现)的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/872497。

相关文章

Linux内核的调试（TODO）

Linux内核的调试（TODO）

（TODO）
阅读更多...
服务器集群同步时间手记

服务器集群同步时间手记

1.时间服务器配置（必须root用户） （1）检查ntp是否安装 [root@node1 桌面]# rpm -qa|grep ntpntp-4.2.6p5-10.el6.centos.x86_64fontpackages-filesystem-1.41-1.1.el6.noarchntpdate-4.2.6p5-10.el6.centos.x86_64 （2）修改ntp配置文件 [r
阅读更多...
linux-基础知识3

linux-基础知识3

打包和压缩 zip 安装zip软件包 yum -y install zip unzip 压缩打包命令: zip -q -r -d -u 压缩包文件名 目录和文件名列表 -q:不显示命令执行过程-r:递归处理，打包各级子目录和文件-u:把文件增加/替换到压缩包中-d:从压缩包中删除指定的文件 解压:unzip 压缩包名 打包文件 把压缩包从服务器下载到本地 把压缩包上传到服务器(zip
阅读更多...
hdu1043（八数码问题，广搜 + hash（实现状态压缩） ）

hdu1043（八数码问题，广搜 + hash（实现状态压缩） ）

利用康拓展开将一个排列映射成一个自然数，然后就变成了普通的广搜题。 #include<iostream>#include<algorithm>#include<string>#include<stack>#include<queue>#include<map>#include<stdio.h>#include<stdlib.h>#include<ctype.h>#inclu
阅读更多...
hdu1565（状态压缩）

hdu1565（状态压缩）

本人第一道ac的状态压缩dp，这题的数据非常水，很容易过 题意：在n*n的矩阵中选数字使得不存在任意两个数字相邻，求最大值 解题思路： 一、因为在1<<20中有很多状态是无效的，所以第一步是选择有效状态，存到cnt[]数组中 二、dp[i][j]表示到第i行的状态cnt[j]所能得到的最大值，状态转移方程dp[i][j] = max(dp[i][j],dp[i-1][k]) ,其中k满足c
阅读更多...
【C++】_list常用方法解析及模拟实现

【C++】_list常用方法解析及模拟实现

相信自己的力量，只要对自己始终保持信心，尽自己最大努力去完成任何事，就算事情最终结果是失败了，努力了也不留遗憾。💓💓💓 目录   ✨说在前面 🍋知识点一：什么是list？ •🌰1.list的定义 •🌰2.list的基本特性 •🌰3.常用接口介绍 🍋知识点二：list常用接口 •🌰1.默认成员函数 🔥构造函数（⭐） 🔥析构函数 •🌰2.list对象
阅读更多...
【Prometheus】PromQL向量匹配实现不同标签的向量数据进行运算

【Prometheus】PromQL向量匹配实现不同标签的向量数据进行运算

✨✨ 欢迎大家来到景天科技苑✨✨ 🎈🎈 养成好习惯，先赞后看哦~🎈🎈 🏆 作者简介：景天科技苑 🏆《头衔》：大厂架构师，华为云开发者社区专家博主，阿里云开发者社区专家博主，CSDN全栈领域优质创作者，掘金优秀博主，51CTO博客专家等。 🏆《博客》：Python全栈，前后端开发，小程序开发，人工智能，js逆向，App逆向，网络系统安全，数据分析，Django，fastapi
阅读更多...
让树莓派智能语音助手实现定时提醒功能

让树莓派智能语音助手实现定时提醒功能

最初的时候是想直接在rasa 的chatbot上实现，因为rasa本身是带有remindschedule模块的。不过经过一番折腾后，忽然发现，chatbot上实现的定时，语音助手不一定会有响应。因为，我目前语音助手的代码设置了长时间无应答会结束对话，这样一来，chatbot定时提醒的触发就不会被语音助手获悉。那怎么让语音助手也具有定时提醒功能呢？ 我最后选择的方法是用threading.Time
阅读更多...
Linux 网络编程 --- 应用层

Linux 网络编程 --- 应用层

一、自定义协议和序列化反序列化 代码： 序列化反序列化实现网络版本计算器 二、HTTP协议 1、谈两个简单的预备知识 https://www.baidu.com/ --- 域名 --- 域名解析 --- IP地址 http的端口号为80端口，https的端口号为443 url为统一资源定位符。CSDNhttps://mp.csdn.net/mp_blog/creation/editor
阅读更多...
【Python编程】Linux创建虚拟环境并配置与notebook相连接

【Python编程】Linux创建虚拟环境并配置与notebook相连接

1.创建 使用 venv 创建虚拟环境。例如，在当前目录下创建一个名为 myenv 的虚拟环境： python3 -m venv myenv 2.激活 激活虚拟环境使其成为当前终端会话的活动环境。运行： source myenv/bin/activate 3.与notebook连接 在虚拟环境中，使用 pip 安装 Jupyter 和 ipykernel： pip instal
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2