当前位置： 首页 > news >正文

linux下的网络编程（2）

news 2025/8/28 9:56:48

一、网络协议--UDP

      UDP位于传输层，全称为 transform  control   Protocol（传输控制协议/流式套接字）

1.1 TCP与UDP的比较

         

UDP的特点：
1. 面向数据包
2. 无连接
3. 尽最大努力交付，不安全不可靠（数据丢包、数据乱序）
4. 机制简单，资源开销小，数据实时性高
5. 可实现一对一、一对多的通信    

TCP的特点：

           1. 面向数据流
2. 有连接（通信之前必须建立连接）
3. 安全可靠的传输机制
4. 机制复杂，网络资源开销大
5. 本质只能实现一对一的通信（使用TCP并发方式可实现一对多通信）

 

1.2 TCP三次握手和四次挥手机制

           TCP三次握手：TCP建立连接时，需要进行三次握手，为了确保收发双方通信之前都已准备就绪。

ACK：响应报文标志；

SYN：请求建立连接标志位；

        三次握手：开始时，发送端向接收端发送SYN请求信号请求接收；接收端发送是哪个ACK应答信号表示接收到请求，同时发送SYN请求信号；发送端发送ACK应答信号，开始传输数据；

 

        TCP四次挥手：TCP断开连接时，需要进行四次挥手，确保断开连接前双方都已通信结束。

     

FIN：断开连接的标志；

        四次挥手：结束阶段，发送端发送FIN结束信号表示结束发送数据，接收端发送ACK应答表示接收到信号，接收端再次发送FIN和ACK信号，表示请求中止接受和应答信号，最后发送端发送ACK应答信号，传输结束。

 

1.3 TCP的编程流程

 

 int connect(int sockfd, const struct sockaddr *addr,
socklen_t addrlen);
功能：请求与服务端建立连接
参数：
sockfd：套接字
addr：要连接的服务端的地址信息
addrlen：服务端地址大小
返回值：
成功：0
失败：-1

 ssize_t send(int sockfd, const void *buf, size_t len, int flags);
功能：发送网络数据
参数：
sockfd：网络套接字
buf：要发送的数据首地址
len：发送的字节数
flags：0 ：按照默认方式发送
返回值：
成功：实际发送的字节数
失败：-1

int listen(int sockfd, int backlog);
功能：监听建立三次握手的客户端
参数：
sockfd：监听套接字
backlog：最大允许监听的客户端个数
返回值：
成功：0
失败：-1

int accept(int socket, struct sockaddr *restrict address,
socklen_t *restrict address_len);
功能：接收建立三次握手的客户端，并产生一个通讯套接字
参数：
socket：监听套接字
address：客户端的地址信息
address_len：客户端地址长的指针
返回值：
成功：通讯套接字
失败：-1


ssize_t recv(int sockfd, void *buf, size_t len, int flags);
功能：从网络套接字上接收数据
参数：
sockfd：通讯套接字
buf：存放接收数据的首地址
len：期望接收到的字节数
flag ： 0：默认方式接收（阻塞）
返回值：
成功：实际接收到的字节数
失败：-1
对方断开连接：0

实例：

#include<stdio.h>
#include<unistd.h>
#include<sys/types.h>          /* See NOTES */
#include<sys/socket.h>
#include<netinet/in.h>
#include<netinet/ip.h> 
#include<arpa/inet.h>
#include<string.h>
#include<sys/wait.h>int main(void)
{int sockfd = socket(AF_INET, SOCK_STREAM, 0);if(sockfd < 0){perror("socket error");return -1;}struct sockaddr_in seraddr;seraddr.sin_family = AF_INET;seraddr.sin_port = htons(50000);seraddr.sin_addr.s_addr = inet_addr("192.168.0.190");int ret = bind(sockfd,(struct sockaddr *)&seraddr,sizeof(seraddr));if(ret < 0){perror("bind error");return -1;}ret = listen(sockfd,10);if(ret < 0){perror("listen error");return -1;}int connfd = accept (sockfd,NULL,NULL);if(connfd < 0){perror("accept error");return -1;}char buff[1024] = {0};ssize_t cnt = recv(connfd,buff,sizeof(buff),0);if(cnt < 0){printf("recv error");return -1;}printf("cnt = %ld,buff = %s\n", cnt, buff);cnt = recv(connfd,buff,sizeof(buff),0);if(cnt < 0){printf("recv error");return -1;}printf("cnt = %ld,buff = %s\n", cnt, buff);close(connfd);close(sockfd);return 0;
}
#include<stdio.h>
#include<unistd.h>
#include<sys/types.h>          /* See NOTES */
#include<sys/socket.h>
#include<netinet/in.h>
#include<netinet/ip.h> 
#include<arpa/inet.h>
#include<string.h>
#include<sys/wait.h>int main(void)
{int sockfd = socket(AF_INET, SOCK_STREAM,0);if(sockfd < 0){perror("sockst error");return -1;}struct sockaddr_in seraddr;seraddr.sin_family = AF_INET;seraddr.sin_port = htons(50000);seraddr.sin_addr.s_addr = inet_addr("192.168.0.190");int ret = connect(sockfd,(struct sockaddr *)&seraddr,sizeof(seraddr));if(ret < 0){perror("connect error");return -1;}ssize_t cnt = send(sockfd,"hello world",11,0);if(cnt < 0){perror("send error");return -1;}printf("cnt = %ld\n",cnt);cnt = send(sockfd,"how are you",11,0);if(cnt < 0){perror("send error");return -1;}printf("cnt = %ld\n",cnt);close(sockfd);return 0;
}

1.4 TCP粘包问题

TCP粘包问题：发送方应用层发送的多包数据，将来在接收方可能一次读到，多包数据产生了粘连。

      原因：
1. 发送方速度较快，TCP底层可能对多包数据进行重新组帧；
2. 接收方数据处理速度较慢，导致多包数据在接收缓冲区缓存，应用层读时，一次将多包数据读出。

     
解决粘包问题的常用方法：

1.  调整发送速率
2.  发送指定大小，将来接收方也接受指定大小。
结构体
注意：
1. 跨平台之间的数据传输时，注意结构体对齐问题。
struct a
{
char a;
int b;
long c;
};
32bits平台《--》64位平台

         3. 应用层位发送的数据增加分隔符,利用分隔符解析
hello world\nhow are you\n

         4. 封装自定义数据帧格式进行发送（协议），严格根据协议进行解析。

AA  C0  00 00 00 F0 00 BB 10 A0  00 00 00 10 校验 BB  AA  C0  00 00 00 F0 00 BB 10 A0  00 00 00 10 校验 BB AA  C0  00 00 00 F0 00 BB 10 A0  00 00 00 10 校验 BB

帧头：AA
帧尾：BB
有效数据长度：C0
有效数据：00 00 00 F0 00 BB 10 A0  00 00 00 10
校验：
8位和校验
16位和校验
CRC校验

1.5  TCP的其他机制

     TCP头部的标志位：

     SYN：请求建立连接标志位
ACK：响应报文标志位
PSH：携带数据标志位，通知接收方该从缓冲区读数据
FIN： 请求断开连接标志位
RST：复位标志位
URG: 紧急数据标志位

  机制：

        1.三次握手，四次挥手；

        2.应答机制：TCP对于每一包数据都会给出相应的应答。发送数据时序列号表示这包数据的起始编号，响应报文中的确认号是接受方收到的最后一个字节编号+1；

        3.超时重传机制：当数据发送出去等待指定时间没有收到响应，此时认为这包数据丢失，则进行重传；

        4.滑动窗口机制：一段缓冲区，缓存TCP已发送未收到响应，准备发送等数据，确保重传时找到数据

提高效率的机制：

延迟应答机制：发送数据时同时等待应答；

流量控制机制：结合TCP头部的窗口大小，动态调整发送速率

捎带应答机制：ACK报文可能和应用层的数据同时发送；

 

二、HTTP协议

 

WWW：万维网

问题：

1.万维网服务器后台如何标记万维网数据：URL；

2.万维网客户端与万维网服务器之间使用什么方式通信（HTTP：超文本传输协议）；

        超文本：文字、链接、音频、视频集合一体的文本；

3.万维网客户端如何展示请求的数据（HTML：超文本标记语言）；

 

 

URL ：统一资源定位符

 

https://www.baidu.com     端口号可省略

 

HTTP：超文本传输协议，位于应用层，基于传输层的TCP协议

        端口：80

        备用端口：8080

 

（1）HTTP通信过程

客户端建立与服务端的TCP链接,再发送HTTP请求报文，服务端发送HTTP回应报文，任意一方均可发送断开TCP连接。

 

长连接：发完回应报文会连续一定时间，不会立刻断开  keep--->alive

短链接：发完立刻断开    close

（2）HTTP的报文格式

GET/ HTTO/1.1\r\n   GET 后面的/是主页

 

 

请求报文：

响应报文：

 

 

三、TCP的并发

        单循环服务器：服务端同一时刻只能处理一个客户端的任务

        并发服务器：服务端同一时刻可以处理多个客户端的任务

        并发模型：

        （1）多进程

                进程资源开销大；安全性高；

实例：

#include<stdio.h>
#include<unistd.h>
#include<sys/types.h>          /* See NOTES */
#include<sys/socket.h>
#include<netinet/in.h>
#include<netinet/ip.h> 
#include<arpa/inet.h>
#include<string.h>
#include<sys/wait.h>
#include <pthread.h>int init_tcp_ser()
{int sockfd = socket(AF_INET, SOCK_STREAM,0);if(sockfd < 0){perror("sockst error");return -1;}struct sockaddr_in seraddr;seraddr.sin_family = AF_INET;seraddr.sin_port = htons(50000);seraddr.sin_addr.s_addr = inet_addr("192.168.0.190");int ret = bind(sockfd,(struct sockaddr *)&seraddr,sizeof(seraddr));if(ret < 0){perror("bind error");return -1;}ret = listen(sockfd,10);if(ret < 0){perror("listen error");return -1;}return sockfd;}int main(void)
{struct sockaddr_in cliaddr;socklen_t clilen = sizeof(cliaddr);int sockfd = init_tcp_ser();if(sockfd < 0){return -1;}  while(1){int connfd = accept(sockfd,(struct sockaddr *)&cliaddr,&clilen);if(connfd < 0){perror("accept error");return -1;}pid_t pid = fork();if(pid > 0){}else if(0 == pid){char buff[1024] = {0};while(1){memset(buff,0,sizeof(buff));size_t cnt = recv(connfd,buff,sizeof(buff),0);if(cnt < 0){perror("recv error");break;}else if(0 == cnt){printf("[%s : %d] : offline\n", inet_ntoa(cliaddr.sin_addr),ntohs(cliaddr.sin_port));break;}printf("[%s : %d] : %s\n",inet_ntoa(cliaddr.sin_addr),ntohs(cliaddr.sin_port),buff);strcat(buff,"----ok");cnt = send(connfd,buff,strlen(buff),0);if(cnt < 0){perror("send error");break;}}close(connfd);}} close(sockfd);return 0;
}

        （2）多线程

                资源开销小；相同资源环境下，并发量比进程大

实例：

#include<stdio.h>
#include<unistd.h>
#include<sys/types.h>          /* See NOTES */
#include<sys/socket.h>
#include<netinet/in.h>
#include<netinet/ip.h> 
#include<arpa/inet.h>
#include<string.h>
#include<sys/wait.h>
#include <pthread.h>
#include<stdlib.h>struct sockaddr_in cliaddr;
socklen_t clilen = sizeof(cliaddr);int init_tcp_ser()
{int sockfd = socket(AF_INET, SOCK_STREAM,0);if(sockfd < 0){perror("sockst error");return -1;}int optval = 1;setsockopt(sockfd, SOL_SOCKET, SO_REUSEADDR, &optval, sizeof(optval));//避免被占用struct sockaddr_in seraddr;seraddr.sin_family = AF_INET;seraddr.sin_port = htons(50000);seraddr.sin_addr.s_addr = inet_addr("192.168.0.190");int ret = bind(sockfd,(struct sockaddr *)&seraddr,sizeof(seraddr));if(ret < 0){perror("bind error");return -1;}ret = listen(sockfd,10);if(ret < 0){perror("listen error");return -1;}return sockfd;}void *send_msg(void *arg)
{int connfd = *((int *)arg);char buff[1024] = {0};while(1){memset(buff,0,sizeof(buff));size_t cnt = recv(connfd,buff,sizeof(buff),0);if(cnt < 0){perror("recv error");break;}else if(0 == cnt){printf("[%s : %d] : offline\n", inet_ntoa(cliaddr.sin_addr),ntohs(cliaddr.sin_port));break;}printf("[%s : %d] : %s\n",inet_ntoa(cliaddr.sin_addr),ntohs(cliaddr.sin_port),buff);strcat(buff,"----ok");cnt = send(connfd,buff,strlen(buff),0);if(cnt < 0){perror("send error");break;}}close(connfd);}int main(void)
{pthread_t tid;int sockfd = init_tcp_ser();if(sockfd < 0){return -1;}  while(1){int connfd = accept(sockfd,(struct sockaddr *)&cliaddr,&clilen);if(connfd < 0){perror("accept error");return -1;}pthread_create(&tid, NULL, send_msg, &connfd);pthread_detach(tid);}close(sockfd);return 0;
}

        （3）线程池

                为了解决多线程或者多进程模型，在服务器运行过程中，频繁创建和销毁线程（进程）bi带来的时间消耗问题；

                基于生产者和消费者编程模型，以及任务队列等，实现的一套多线程模型；

        （4）IO多路复用

                I--->O：fd

                对多个文件描述符的读写可以复用一个进程。

                在不创建新的进程和线程的前提下，使用一个进程实现对多个文件读写的同时检测；

                fgets（stdin）；

                recv（connfd）；

               阻塞IO模式：

                        1.多个任务之间是同步的效果

阻塞IO实例：

#include<stdio.h>
#include<unistd.h>
#include<sys/types.h>          /* See NOTES */
#include<sys/socket.h>
#include<netinet/in.h>
#include<netinet/ip.h> 
#include<arpa/inet.h>
#include<string.h>
#include<sys/wait.h>
#include <pthread.h>
#include<stdlib.h>
#include<sys/time.h>
#include<sys/select.h>
#include <sys/stat.h>
#include <fcntl.h>int main(int argc, const char *argv[])
{char buff[1024] = {0};int sockfd = socket(AF_INET, SOCK_STREAM,0);if(sockfd < 0){perror("socket error");return -1;}struct sockaddr_in seraddr;seraddr.sin_family = AF_INET;seraddr.sin_port = htons(50000);seraddr.sin_addr.s_addr = inet_addr("192.168.0.190");int ret = bind(sockfd,(struct sockaddr *)&seraddr,sizeof(seraddr));if(ret < 0){perror("bind error");return -1;}ret = listen(sockfd,100);if(ret < 0){perror("listen error");return -1;}fd_set rdfds;fd_set rdfdstmp;FD_ZERO(&rdfds);FD_SET(sockfd,&rdfds);int maxfd = sockfd;struct sockaddr_in cliaddr;socklen_t clilen = sizeof(cliaddr);while(1){rdfdstmp = rdfds;int cnt = select(maxfd + 1, &rdfdstmp, NULL, NULL, NULL);if (cnt < 0){perror("select error");return -1;}if(FD_ISSET(sockfd,&rdfdstmp)){int connfd = accept(sockfd, (struct sockaddr *)&cliaddr,&clilen);if(connfd < 0){perror("accept error");return -1;}FD_SET(connfd,&rdfds);maxfd = maxfd > connfd ? maxfd : connfd;}for(int i = sockfd + 1;i <= maxfd; i++){if(FD_ISSET(i,&rdfdstmp)){memset(buff,0,sizeof(buff));ssize_t cnt = recv(i,buff,sizeof(buff),0);if(cnt < 0){perror("recv error");FD_CLR(i,&rdfds);close(i);continue;}else if(0 == cnt){FD_CLR(i,&rdfds);close(i);continue;}printf("%s\n",buff);strcat(buff,"----ok");cnt = send(i,buff,strlen(buff),0);if(cnt < 0){	perror("send error");FD_CLR(i,&rdfds);close(i);continue;}}}}close(sockfd);return 0;
}

 

 

1）select实现IO多路复用：

        1.创建文件描述符集合；    fd_set

        2.添加关注的文件描述符到集合；   FD_SET()

        3.使用select传递集合表给内核，内核开始检测事件；   select()

        4.当内核检测到事件时，应用层select将解除阻塞，并获得相关的事件结果；

        5.根据select返回的结果做不同的处理；

 

       void FD_CLR(int fd, fd_set *set);
int  FD_ISSET(int fd, fd_set *set);
void FD_SET(int fd, fd_set *set);
void FD_ZERO(fd_set *set);

 

 int select(int nfds, fd_set *readfds, fd_set *writefds,
fd_set *exceptfds, struct timeval *timeout);

功能：传递文件描述符给内核并等待获取事件结果；

参数：

        nfds：关注的最大文件描述符+1；

        readfds：读事件关注的文件描述符集合；

        writefds：写事件的文件描述符集合；

        timeout：设置select检测时的超时时间；

                        NULL：不设置超时时间（select一直阻塞等待）

返回值：

        成功：返回内核监测的到达事件的个数；

        失败：-1

        0：超时时间到达但没有事件发生，返回0；

 

 

http://www.dtcms.com/a/353838.html

相关文章：

  • 技术分析 | Parasoft C/C++test如何突破单元测试的隔离难题
  • 亚马逊关键词策略全解析：类型、工具与多账号运营优化指南
  • AT_abc406_f [ABC406F] Compare Tree Weights
  • Windows/Linux 环境下 Jmeter 性能测试的安装与使用
  • 基于SpringBoot的宠物领养服务系统【2026最新】
  • MySQL 面试题系列（五）
  • Unity自定义Inspector面板之使用多选框模拟单选框
  • 前端技术演进录：从 AI 革命到架构新生
  • 【Linux】常用命令 拥有者和权限（四）
  • Python随机选择完全指南：从基础到高级工程实践
  • 安全向量模板类SiVector
  • vue 前端 区域自适应大小
  • AWS申请增加弹性IP配额流程
  • 《Vuejs设计与实现》第 17 章（编译优化）
  • 机器视觉学习-day05-图片颜色识别及颜色替换
  • # 快递单号查询系统：一个现代化的物流跟踪解决方案
  • YOLO12n-Deepsort多目标跟踪之昆虫数据集
  • 【C++标准库】＜ios＞详解基于流的 I/O
  • 科技赋能生态，智慧守护农林，汇岭生态开启农林产业现代化新篇章
  • C# OpenCVSharp 实现物体尺寸测量方案
  • Whisper JAX：突破性实时语音识别加速框架，性能提升70倍的开源解决方案
  • Spring : IOC / DI (控制反转 / 依赖注入)
  • C/C++---前缀和（Prefix Sum）
  • 【重学MySQL】九十一、MySQL远程登录
  • 理智讨论可以将服务器内存占用限制到80%吗？
  • LeaferJS创建支持缩放、平移的画布，并绘制简单图形
  • 关于git的安装（windows）
  • linux部署overleaf服务器
  • 深度学习（鱼书）day12--卷积神经网络（后四节）
  • 动态规划：硬币兑换（有趣）