c++网络编程

网络编程模型

    c/s 模型：客户端服务器模型b/s 模型：浏览器服务器模型

1.tcp网络流程

在这里插入图片描述
服务器流程：

    1.创建套接字2.完善服务器网络信息结构体3.绑定服务器网络信息结构体4.让服务器处于监听状态5.accept阻塞等待客户端连接信号6.收发数据7.关闭套接字

客户端流程：

    1.创建套接字2.连接connect3.收发数据4.关闭套接字

2.函数

2.1socket

#include <sys/types.h>          
#include <sys/socket.h>int socket(int domain, int type, int protocol);
功能：创建套接字参数：domain：通信域Name                                 Purpose                                                Man pageAF_UNIX,AF_LOCAL          Local communication(本地通信)          unix(7)AF_INET                             IPv4 Internet protocols                         ip(7)AF_INET6                           IPv6 Internet protocols                         ipv6(7)AF_PACKET                        原始套接字                                          packet(7)type:套接字的类型SOCK_STREAM            TCPSOCK_DGRAM              UDP使用SOCK_RAW                    原始套接字使用protocol：附加文件，没有写0返回值：成功：创建的新套接字(文件描述符)失败：-1  重置错误码

2.2bind

#include <sys/types.h>          
#include <sys/socket.h>int bind(int sockfd, const struct sockaddr *addr,socklen_t addrlen);
功能：绑定套接字和网络信息结构体参数：sockfd:socket函数产生的套接字文件描述符(socket函数返回值)addr：避免冲突警告

2.3listen

#include <sys/types.h>          
#include <sys/socket.h>int listen(int sockfd, int backlog);产生半连接队列功能：将套接字设置成被动监听状态，只有这个状态的套接字才能等待客户端连接参数：sockfd:socket函数返回值backlog：半连接队列的长度，一般传 5 10 都行 不是0就行返回值：成功：0失败：-1  重置错误码

accept

#include <sys/types.h>          
#include <sys/socket.h>int accept(int sockfd, struct sockaddr *addr, socklen_t *addrlen);产生全连接队列，返回值创                                                                                                        建的文件描述符
功能：提取半连接队列中的第一个客户端连接，成功，放到函数产生的全连接队列中，专门             用于和当前客户端通信，返回的套接字和原套接字类型相同参数：sockfd:listen后的sockfdaddr：客户端的网络信息结构体首地址，不关心写NULLaddrlen：客户端addr长度，不关心写NULL返回值：成功：创建的新的文件描述符  专门用于和当前客户端通信失败：-1  重置错误码

connect

#include <sys/types.h>          
#include <sys/socket.h>int connect(int sockfd, const struct sockaddr *addr, socklen_t addrlen);功能：与服务器建立连接 参数：sockfd:accept函数返回值addr：服务器的网络信息结构体addrlen：addr的长度返回值：成功：0失败：-1  重置错误码

服务器代码

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <netinet/ip.h>
#include <string.h>
#include <arpa/inet.h>
#define ERRLOG(msg) do{\printf("%s %s %d\n", __FILE__, __func__, __LINE__);\perror(msg);\exit(-1);\}while(0)int main(int argc, char const *argv[])
{//1.创建套接字int sockfd=0;//需要接函数返回值，后面函数会用if(-1==(sockfd=socket(AF_INET,SOCK_STREAM,0))){ERRLOG("socket error");}//2.服务器网络信息结构体填充//struct sockaddr addr;struct sockaddr_in ad;memset(&ad, 0, sizeof(ad));ad.sin_family=AF_INET;ad.sin_port=htons(7788);//自己随意指定，不冲突就行，冲突就换ad.sin_addr.s_addr=inet_addr("192.168.250.100");//3.绑定套接字和服务器网络信息结构体if(-1==bind(sockfd,(struct sockaddr*)&ad,sizeof(ad))){ERRLOG("bind error");}//4.让套接字处于被动监听状态if(-1==listen(sockfd,5)){ERRLOG("listen error");}//5.阻塞等待客户端连接printf("正在等待客户端发来信息\n");int newfd=0;if((newfd=accept(sockfd,NULL,NULL))==-1){ERRLOG("accept error");}printf("客户端连接成功\n");//6.收发数据char buff[128]={0};int lnum=0;char opr=0;int rnum=0;int result=0;read(newfd,buff,128);printf("客户端发来数据：%s\n",buff);sscanf(buff,"%d%c%d",&lnum,&opr,&rnum);switch(opr){case '+':result=lnum+rnum;break;case '-':result=lnum-rnum;break;case '*':result=lnum*rnum;break;case '/':result=(float)lnum/(float)rnum;break;}memset(buff,0,128);sprintf(buff,"result=%d",result);write(newfd,buff,128);//7.关闭套接字close(sockfd);close(newfd);return 0;
}

客户端代码

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <netinet/ip.h>
#include <string.h>
#include <arpa/inet.h>#define ERRLOG(msg) do{\printf("%s %s %d\n", __FILE__, __func__, __LINE__);\perror(msg);\exit(-1);\}while(0)int main(int argc, char const *argv[])
{//创建套接字int sockfd=0;if((sockfd=socket(AF_INET,SOCK_STREAM,0))==-1){ERRLOG("socket error");}//填充服务器结构体struct sockaddr_in addr;memset(&addr, 0, sizeof(addr));addr.sin_family=AF_INET;addr.sin_port=htons(6666);addr.sin_addr.s_addr=inet_addr("192.168.2.84");//连接服务器if(connect(sockfd,(struct sockaddr *)&addr,sizeof(addr))==-1){ERRLOG("connect error");}//收发数据char buff[128]={0};//写入的数据从终端获取fgets(buff,128,stdin);buff[strlen(buff)-1]='\0';write(sockfd,buff,128);memset(buff,0,128);read(sockfd,buff,128);printf("服务器发来的信息是：%s\n",buff);//7.关闭套接字close(sockfd);return 0;
}

send

#include <sys/types.h>          
#include <sys/socket.h>ssize_t send(int sockfd, const void *buf, size_t len, int flags);ssize_t sendto(int sockfd, const void *buf, size_t len, int flags,const struct sockaddr *dest_addr, socklen_t addrlen);功能：发送数据参数：sockfd:accept函数返回值buf:要发送的数据的缓冲区首地址len：要发送数据的长度flags：发送的标志位，0用法和write就一样了，MSG_DONTWAIT 表示非阻塞返回值：成功：实际发送的字节数失败：-1  重置错误码注意：如果对方关闭了套接字或者断开连接第一次send没有反应，第二次send会产生SIGPIPE信号下面三种用法是等价的：write(sockfd, buf, 128);send(sockfd, buf, 128, 0);sendto(sockfd, buf, 128, 0, NULL, NULL);

recv

#include <sys/types.h>          
#include <sys/socket.h>ssize_t recv(int sockfd, void *buf, size_t len, int flags);ssize_t recvfrom(int sockfd, void *buf, size_t len, int flags,struct sockaddr *src_addr, socklen_t *addrlen);功能：接收数据 参数：sockfd:accept函数返回值buf:要接收的数据的缓冲区首地址len：要接收数据的长度flags：发送的标志位，flags:接收的标志位，0用法和read就一样了，                                                   MSG_DONTWAIT 表示非阻塞返回值：成功：实际接收的字节数失败：-1  重置错误码注意： 如果对方关闭了套接字或者断开连接 recv 会返回0下面三种用法是等价的：read(sockfd, buf, 128);recv(sockfd, buf, 128, 0);recvfrom(sockfd, buf, 128, 0, NULL, NULL);

粘包问题产生原因

tcp在传输的时候不是一调用send就直接将数据发送给客户端的，而是将数据放到发送缓冲区里

tcp底层的nagle算法，会将一定短时间内发送的数据包组装成一个整体，发送给对方

而接受方无法区分消息的边界和类型，就可能会导致有冲突的情况发生

也就是说，当文件只剩最后一部分的时候，很有可能将最后的结束字符和文件最后一部分作为一个整体发送给接收方，也有可能将三个128和最后的30+12一起发给接收方，但不管是哪种方式，接收方写入的时候是以128为单位接受的，所以接收方缓冲区里是无法单独比较over的，所以会产生粘包问题。

解决方法：

1.既然是一定短时间内的数据成为一个整体，那么最后发送的over就不和前面一块发送了，在over之前加一个延时函数，让他单独发送

但是不常用，因为服务器里禁止使用sleep

2.发送定长的数据包，

解决方法一代码

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/12671.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

Appium+python自动化（二十八）- 高级滑动（超详解）

Appium+python自动化（二十八）- 高级滑动（超详解）

高级溜冰的滑动 滑动操作一般是两点之间的滑动&#xff0c;这种滑动在这里称其为低级的溜冰滑动&#xff1b;就是上一节给小伙伴们分享的。然而实际使用过程中用户可能要进行一些多点连续滑动操作。如九宫格滑动操作&#xff0c;连续拖动图片移动等场景。那么这种高级绚丽的溜…
阅读更多...
【node.js】04-模块化

【node.js】04-模块化

目录 一、什么是模块化 二、node.js中的模块化 1. node.js中模块的分类 2. 加载模块 3. node.js 中的模块作用域 4. 向外共享模块作用域中的成员 4.1 module对象 4.2 module.exports 对象 4.3 exports对象 5. node.js 中的模块化规范 一、什么是模块化 模块化是指解…
阅读更多...
Kafka中的主题（Topic）和分区（Partition）是什么？它们之间有什么关系？

Kafka中的主题（Topic）和分区（Partition）是什么？它们之间有什么关系？

在Kafka中&#xff0c;主题&#xff08;Topic&#xff09;和分区&#xff08;Partition&#xff09;都是用于组织和存储消息的概念&#xff0c;它们有密切的关系。 主题&#xff08;Topic&#xff09;&#xff1a;主题是消息的逻辑分类。可以将主题理解为一个逻辑上的消息容器&…
阅读更多...
使用python库uvicorn替代Nginx发布Vue3项目

使用python库uvicorn替代Nginx发布Vue3项目

目录 一、Vue3项目打包 二、将打包文件放到python项目 三、配置uvicorn服务 四、启动服务 【SpringBoot版传送门&#xff1a;使用SpringBoot替代Nginx发布Vue3项目_苍穹之跃的博客-CSDN博客】 一、Vue3项目打包 &#xff08;博主vue版本&#xff1a;3.2.44&#xff09; 由…
阅读更多...
Android平台GB28181设备接入侧如何同时对外输出RTSP流？

Android平台GB28181设备接入侧如何同时对外输出RTSP流？

技术背景 GB28181的应用场景非常广泛&#xff0c;如公共安全、交通管理、企业安全、教育、医疗等众多领域&#xff0c;细分场景可用于如执法记录仪、智能安全帽、智能监控、智慧零售、智慧教育、远程办公、明厨亮灶、智慧交通、智慧工地、雪亮工程、平安乡村、生产运输、车载终…
阅读更多...
2023年自然语言处理与信息检索国际会议(ECNLPIR 2023) | EI Compendex, Scopus双检索

2023年自然语言处理与信息检索国际会议(ECNLPIR 2023) | EI Compendex, Scopus双检索

会议简介 Brief Introduction 2023年自然语言处理与信息检索国际会议(ECNLPIR 2023) 会议时间&#xff1a;2023年9月22日-24日 召开地点&#xff1a;中国杭州 大会官网&#xff1a;ECNLPIR 2023-2023 Eurasian Conference on Natural Language Processing and Information Retr…
阅读更多...
【Linux】进程通信 — 管道

【Linux】进程通信 — 管道

文章目录 &#x1f4d6; 前言1. 通信背景1.1 进程通信的目的&#xff1a;1.2 管道的引入&#xff1a; 2. 匿名管道2.1 匿名管道的原理&#xff1a;2.2 匿名管道的创建&#xff1a;2.3 父子进程通信&#xff1a;2.3.1 read()阻塞等待 2.4 父进程给子进程派发任务&#xff1a;2.5…
阅读更多...
Kafka的消息传递模型是什么？

Kafka的消息传递模型是什么？

Kafka的消息传递模型采用了发布-订阅模式。它使用了一种分布式的提交日志&#xff08;commit log&#xff09;结构来持久化消息&#xff0c;并将消息以主题&#xff08;topic&#xff09;的方式进行组织和分类。在这个模型中&#xff0c;消息会被发布到一个或多个主题&#xff…
阅读更多...
使用adb通过电脑给安卓设备安装apk文件

使用adb通过电脑给安卓设备安装apk文件

最近碰到要在开发板上安装软件的问题&#xff0c;由于是开发板上的安卓系统没有解析apk文件的工具&#xff0c;所以无法通过直接打开apk文件来安装软件。因此查询各种资料后发现可以使用adb工具&#xff0c;这样一来可以在电脑上给安卓设备安装软件。 ADB 就是连接 Android 手…
阅读更多...
NFT市场泡沫破裂了吗？投资NFT是否仍然安全？

NFT市场泡沫破裂了吗？投资NFT是否仍然安全？

近期&#xff0c;NFT市场的价格出现了明显的下跌趋势&#xff0c;许多人开始担心NFT市场是否已经进入了泡沫破裂的阶段。但是&#xff0c;我们需要认真分析这个问题&#xff0c;并且探讨投资NFT是否仍然安全。 NFT&#xff08;Non-Fungible Token&#xff09;是一种非同质化代币…
阅读更多...
LeetCode 436. Find Right Interval【排序,二分；双指针,莫队】中等

LeetCode 436. Find Right Interval【排序,二分；双指针,莫队】中等

本文属于「征服LeetCode」系列文章之一&#xff0c;这一系列正式开始于2021/08/12。由于LeetCode上部分题目有锁&#xff0c;本系列将至少持续到刷完所有无锁题之日为止&#xff1b;由于LeetCode还在不断地创建新题&#xff0c;本系列的终止日期可能是永远。在这一系列刷题文章…
阅读更多...
perl GetOptions

perl GetOptions

在Perl中&#xff0c;你可以使用标准模块Getopt::Long来解析命令行选项&#xff08;Command Line Options&#xff09;。Getopt::Long模块允许你定义命令行选项以及它们的值&#xff0c;并且还可以处理各种类型的选项&#xff0c;如标志选项&#xff08;flag options&#xff0…
阅读更多...
算法竞赛入门【码蹄集新手村600题】(MT1060-1080）

算法竞赛入门【码蹄集新手村600题】(MT1060-1080）

算法竞赛入门【码蹄集新手村600题】(MT1060-1080&#xff09; 目录MT1061 圆锥体的体积MT1062 圆锥体表面积MT1063 立方体的体积MT1064 立方体的表面积MT1065 长方体的表面积MT1066 射线MT1067 线段MT1068 直线切平面MT1069 圆切平面MT1070 随机数的游戏MT1071 计算表达式的值M…
阅读更多...
网络防御之IDS

网络防御之IDS

1. 什么是IDS&#xff1f; IDS是入侵检测系统&#xff0c;一种对于网络传输进行及时监视&#xff0c;在发现可疑的传输时发出警报或者采取主动反应措施的网络安全设备。IDS是一种积极地主动的防御技术。 2. IDS和防火墙有什么不同&#xff1f; 防火墙是一种隔离并过滤非授权用…
阅读更多...
Leetcode-每日一题【剑指 Offer II 075. 数组相对排序】

Leetcode-每日一题【剑指 Offer II 075. 数组相对排序】

题目 给定两个数组&#xff0c;arr1 和 arr2&#xff0c; arr2 中的元素各不相同 arr2 中的每个元素都出现在 arr1 中 对 arr1 中的元素进行排序&#xff0c;使 arr1 中项的相对顺序和 arr2 中的相对顺序相同。未在 arr2 中出现过的元素需要按照升序放在 arr1 的末尾。 示例&…
阅读更多...
EtherNet/IP转CAN网关can协议标准

EtherNet/IP转CAN网关can协议标准

生产管理设备中&#xff0c;会有设备与其他设备的协议不同&#xff0c;数据无法互通&#xff0c;让你的工作陷入困境。这时&#xff0c;一款神奇的产品出现了——远创智控YC-EIP-CAN通讯网关&#xff01; 1, 这款通讯网关采用ETHERNET/IP从站功能&#xff0c;可以将各种CAN总线…
阅读更多...
Lambda表达式

Lambda表达式

Java Lambda表达式是Java 8中最重要的新特性之一。 它们是一种可传递的匿名函数&#xff0c;可以作为参数传递给方法或存储在变量中&#xff0c;因此可以在需要的时候调用它们。 基础 1. 简介 Lambda表达式的主要目的是简化Java代码&#xff0c;使其更易于阅读和编写。 Lam…
阅读更多...
【业务功能篇58】Springboot + Spring Security 权限管理 【中篇】

【业务功能篇58】Springboot + Spring Security 权限管理 【中篇】

4.2.3 认证 4.2.3.1 什么是认证&#xff08;Authentication&#xff09; 通俗地讲就是验证当前用户的身份&#xff0c;证明“你是你自己”&#xff08;比如&#xff1a;你每天上下班打卡&#xff0c;都需要通过指纹打卡&#xff0c;当你的指纹和系统里录入的指纹相匹配时&…
阅读更多...
前端存储之sessionStorage和localStorage

前端存储之sessionStorage和localStorage

sessionStorage sessionStorage是一种用于web浏览器中临时保存数据的客户端存储机制。它允许在同一个浏览器窗口的会话期间&#xff0c;保存和访问临时数据&#xff0c;而这些数据在用户关闭窗口或者标签页会被清除。每个sessionStorage对象都与当前的浏览器会话相关联&#x…
阅读更多...
12.python设计模式【观察者模式】

12.python设计模式【观察者模式】

内容&#xff1a;定义对象间的一种一对多的依赖关系&#xff0c;当一个对象的状态发生改变的时候&#xff0c;所有依赖于它的对象得到通知并被自动更新。观者者模式又称为“发布-订阅”模式。比如天气预报&#xff0c;气象局分发气象数据。 角色&#xff1a; 抽象主题&#xf…
阅读更多...
最新文章

Copyright @ 2022~2023