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

linux编程----网络通信（TCP）

ai 2025/8/24 5:10:00

1.TCP特点

1.面向数据流；

2.有连接通信；

3.安全可靠的通信方式；

4.机制复杂，网络资源开销大；

5.本质只能实现一对一的通信（可使用TCP的并发方式实现一对多通信）；

2.TCP的三次握手与四次挥手

1.TCP的三次握手

TCP建立连接时，需要进行三次握手，以确保收发双方通信之前都已就绪；

2.TCP的四次挥手

TCP断开连接时，需要四次挥手，以确保断开连接前双方都以通信结束；

SYN：请求建立连接标志；

FIN：请求断开连接标志；

ACK：响应报文标志位；

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

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校验

5.代码练习

1. tcp实现图片的传输

//客户端
#include <stdio.h>
#include <sys/types.h>          /* See NOTES */
#include <sys/socket.h>
#include <netinet/in.h>
#include <netinet/ip.h> /* superset of previous */
#include <netinet/in.h>
#include <arpa/inet.h>
#include <string.h>
#include <unistd.h>
#include <sys/stat.h>
#include <fcntl.h>int main(int argc, char const *argv[])
{if(argc != 2){printf("./a.out <filename>\n");return -1;}int sockfd = socket(AF_INET, SOCK_STREAM, 0);if(sockfd < 0){perror("socket error");return -1;}struct sockaddr_in sockaddr;sockaddr.sin_family = AF_INET;sockaddr.sin_port = htons(50002);sockaddr.sin_addr.s_addr = inet_addr("192.168.0.139");int connfd = connect(sockfd, (struct sockaddr *)&sockaddr, sizeof(sockaddr));int fd = open(argv[1], O_RDONLY);if(fd < 0){perror("open error");return -1;}char buf[1024] = {0};int ret = 0;do{   ret = read(fd, buf, sizeof(buf));size_t conter = send(sockfd, buf, ret, 0);}while(ret > 0);close(fd);close(sockfd);return 0;
}//服务端
#include <stdio.h>
#include <sys/types.h>          /* See NOTES */
#include <sys/socket.h>
#include <netinet/in.h>
#include <netinet/ip.h> /* superset of previous */
#include <netinet/in.h>
#include <arpa/inet.h>
#include <unistd.h>
#include <string.h>
#include <sys/stat.h>
#include <fcntl.h>int main(int argc, char const *argv[])
{if(argc != 2){printf("./a.out <filename>\n");return -1;}int sockfd = socket(AF_INET, SOCK_STREAM, 0);if(sockfd < 0){perror("socket error");return -1;}struct sockaddr_in sockaddr;sockaddr.sin_family = AF_INET;sockaddr.sin_port = htons(50002);sockaddr.sin_addr.s_addr = inet_addr("192.168.0.139");int ret = bind(sockfd, (struct sockaddr *)&sockaddr, sizeof(sockaddr));if(ret < 0){perror("bind error");return -1;}int n = listen(sockfd, 10);if(n < 0){perror("listen error");return -1;}struct sockaddr_in dest_sockaddr;socklen_t len = sizeof(dest_sockaddr);int connfd = accept(sockfd, (struct sockaddr *)&dest_sockaddr, &len);printf("[%s][%d] online\n", inet_ntoa(dest_sockaddr.sin_addr), ntohs(dest_sockaddr.sin_port));int fd = open(argv[1], O_WRONLY | O_TRUNC | O_CREAT, 0664);if(fd < 0){perror("open error");return -1;}char buf[1024] = {0};ssize_t cont = 0;do{   memset(buf, 0, sizeof(buf));cont = recv(connfd, buf, sizeof(buf), 0);write(fd, buf, cont);   }while(cont > 0);close(connfd);close(sockfd);return 0;
}

2. tcp实现全双工聊天

//客户端A:
#include <stdio.h>
#include <sys/types.h>          /* See NOTES */
#include <sys/socket.h>
#include <netinet/in.h>
#include <netinet/ip.h> /* superset of previous */
#include <netinet/in.h>
#include <arpa/inet.h>
#include <string.h>
#include <unistd.h>int sockfd = 0;
struct sockaddr_in sockaddr;int send_t()
{char buf[1024] = {0};while(1){   fgets(buf, sizeof(buf), stdin);buf[strlen(buf) - 1] = 0;size_t conter = send(sockfd, buf, strlen(buf), 0);if(conter > 0){printf("conter=%ld\n", conter);}if(conter < 0){perror("send error");return -1;}}close(sockfd);
}int recv_t()
{char buf[1024] = {0};do{   memset(buf, 0, sizeof(buf));ssize_t cont = recv(sockfd, buf, sizeof(buf), 0);if(cont > 0){printf("cont = %ld, buf = %s\n", cont, buf);}if(cont < 0){perror("send error");return -1;}  }while(1);close(sockfd);
}int main(int argc, char const *argv[])
{sockfd = socket(AF_INET, SOCK_STREAM, 0);if(sockfd < 0){perror("socket error");return -1;}sockaddr.sin_family = AF_INET;sockaddr.sin_port = htons(50001);sockaddr.sin_addr.s_addr = inet_addr("192.168.0.139");int connfd = connect(sockfd, (struct sockaddr *)&sockaddr, sizeof(sockaddr));//send_t();pid_t pid = fork();if(pid > 0){send_t(); }else if(pid == 0){recv_t(); }else{perror("fork error");return -1;}return 0;
}//服务端B
#include <stdio.h>
#include <sys/types.h>          /* See NOTES */
#include <sys/socket.h>
#include <netinet/in.h>
#include <netinet/ip.h> /* superset of previous */
#include <netinet/in.h>
#include <arpa/inet.h>
#include <unistd.h>
#include <string.h>struct sockaddr_in dest_sockaddr;
socklen_t len = sizeof(dest_sockaddr);
int sockfd = 0;
int connfd = 0;int recv_t()
{char buf[1024] = {0};do{   memset(buf, 0, sizeof(buf));ssize_t cont = recv(connfd, buf, sizeof(buf), 0);if(cont > 0){printf("cont = %ld, buf = %s\n", cont, buf);}if(cont < 0){perror("send error");return -1;}  }while(1);close(connfd);close(sockfd);
}int send_t()
{   char buf[1024] = {0};while(1){   fgets(buf, sizeof(buf), stdin);buf[strlen(buf) - 1] = 0;size_t conter = send(connfd, buf, strlen(buf), 0);if(conter > 0){printf("conter=%ld\n", conter);}if(conter < 0){perror("send error");return -1;}}close(connfd);close(sockfd);
}int main(int argc, char const *argv[])
{sockfd = socket(AF_INET, SOCK_STREAM, 0);if(sockfd < 0){perror("socket error");return -1;}struct sockaddr_in sockaddr;sockaddr.sin_family = AF_INET;sockaddr.sin_port = htons(50001);sockaddr.sin_addr.s_addr = inet_addr("192.168.0.139");int ret = bind(sockfd, (struct sockaddr *)&sockaddr, sizeof(sockaddr));if(ret < 0){perror("bind error");return -1;}int n = listen(sockfd, 10);if(n < 0){perror("listen error");return -1;}connfd = accept(sockfd, (struct sockaddr *)&dest_sockaddr, &len);printf("[%s][%d] online\n", inet_ntoa(dest_sockaddr.sin_addr), ntohs(dest_sockaddr.sin_port));//recv_t();pid_t pid = fork();if(pid > 0){recv_t();}else if(pid == 0){send_t();}else {perror("fork error");return -1;}return 0;
}

http://www.xdnf.cn/news/18446.html

相关文章：

  • LLM实践系列：利用LLM重构数据科学流程04 - 智能特征工程
  • 博士招生 | 英国谢菲尔德大学 招收计算机博士
  • 项目中优惠券计算逻辑全解析（处理高并发）
  • Unreal Engine UStaticMeshComponent
  • JUC之CompletionService
  • DFS序与树链剖分入门
  • 开发避坑指南(35)：mybaits if标签test条件判断等号=解析异常解决方案
  • 文件系统层面的可用块数量可用空间和比例
  • AI重塑职业教育：个性化学习计划提效率、VR实操模拟强技能，对接就业新路径
  • 拿到手一个前端项目，应该如何启动
  • 开发避坑指南(34)：mysql深度分页查询优化方案
  • Ubuntu解决makefile交叉编译的问题
  • Android Jetpack | Hilt
  • 机器人爆发、汽车换代，速腾聚创开始讲新故事
  • WindowsAPI|每天了解几个winAPI接口之网络配置相关文档Iphlpapi.h详细分析八
  • 【数据结构】选择排序：直接选择与堆排序详解
  • 前端项目打包+自动压缩打包文件+自动上传部署远程服务器
  • 为什么需要关注Flink并行度？
  • 【C#】观察者模式 + UI 线程调度、委托讲解
  • 大学校园安消一体化平台——多警合一实现智能联动与网格化管理
  • Redis 678
  • Hyperledger Fabric官方中文教程-改进笔记（十四）-向通道中添加组织
  • open webui源码分析7—过滤器
  • 获取后台返回的错误码
  • Linux822 shell:expect 批量
  • 车辆方向数据集 - 物体检测
  • 作品集PDF又大又卡？我用InDesign+Acrobat AI构建轻量化交互式文档工作流
  • 【LeetCode每日一题】238. 除自身以外数组的乘积
  • 【链表 - LeetCode】2. 两数相加
  • 服务器与客户端