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

14.8 Socket 一收一发通信

通常情况下我们在编写套接字通信程序时都会实现一收一发的通信模式,当客户端发送数据到服务端后,我们希望服务端处理请求后同样返回给我们一个状态值,并以此判断我们的请求是否被执行成功了,另外增加收发同步有助于避免数据包粘包问题的产生,在多数开发场景中我们都会实现该功能。

Socket粘包是指在使用TCP协议传输数据时,发送方连续向接收方发送多个数据包时,接收方可能会将它们合并成一个或多个大的数据包,而不是按照发送方发送的原始数据包拆分成多个小的数据包进行接收。

造成粘包的原因主要有以下几个方面:

  • TCP协议的特性:TCP是一种面向连接的可靠传输协议,保证了数据的正确性和可靠性。在TCP协议中,发送方和接收方之间建立了一条虚拟的连接,通过三次握手来建立连接。当数据在传输过程中出现丢失、损坏或延迟等问题时,TCP会自动进行重传、校验等处理,这些处理会导致接收方在接收数据时可能会一次性接收多个数据包。
  • 缓冲区的大小限制:在接收方的缓冲区大小有限的情况下,如果发送方发送的多个小数据包的总大小超过了接收方缓冲区的大小,接收方可能会将它们合并成一个大的数据包来接收。
  • 数据的处理方式:接收方在处理数据时,可能会使用不同的方式来处理数据,比如按照字节流方式读取数据,或者按照固定长度读取数据等方式。不同的处理方式可能会导致接收方将多个数据包合并成一个大的数据包。

如果读者是一名Windows平台开发人员并从事过网络套接字开发,那么一定很清楚此缺陷的产生,当我们连续调用send()时就会产生粘包现象,而解决此类方法的最好办法是在每次send()后调用一次recv()函数接收一个返回值,至此由于数据包不连续则也就不会产生粘包的现象。

14.8.1 服务端实现

服务端我们实现的功能只有一个接收,其中RecvFunction函数主要用于接收数据包,通过使用recv函数接收来自socket连接通道的数据,并根据接收到的数据判断条件,决定是否发送数据回应。如果接收到的数据中命令参数满足command_int_a=10command_int_b=20,那么该函数会构建一个新的数据包,将其发送回客户端,其中包括一个表示成功执行的标志、一个包含欢迎信息的字符串以及其他数据信息。如果接收到的数据命令参数不满足上述条件,则函数会构建一个新的数据包,将其发送回客户端,其中只包括一个表示执行失败的标志。最后,函数返回一个BOOL类型的布尔值,表示接收函数是否成功执行。

#include <iostream>
#include <winsock2.h>
#include <WS2tcpip.h>#pragma comment(lib,"ws2_32.lib")typedef struct
{int command_int_a;int command_int_b;int command_int_c;int command_int_d;unsigned int command_uint_a;unsigned int command_uint_b;char command_string_a[256];char command_string_b[256];char command_string_c[256];char command_string_d[256];int flag;int count;
}send_recv_struct;// 调用接收函数
BOOL RecvFunction(SOCKET &sock)
{// 接收数据char recv_buffer[8192] = { 0 };int recv_flag = recv(sock, (char *)&recv_buffer, sizeof(send_recv_struct), 0);if (recv_flag <= 0){return FALSE;}send_recv_struct *buffer = (send_recv_struct *)recv_buffer;std::cout << "接收参数A: " << buffer->command_int_a << std::endl;// 接收后判断,判断后发送标志或携带参数if (buffer->command_int_a == 10 && buffer->command_int_b == 20){send_recv_struct send_buffer = { 0 };send_buffer.flag = 1;strcpy(send_buffer.command_string_a, "hello lyshark");// 发送数据int send_flag = send(sock, (char *)&send_buffer, sizeof(send_recv_struct), 0);if (send_flag <= 0){return FALSE;}}else{send_recv_struct send_buffer = { 0 };send_buffer.flag = 0;// 发送数据int send_flag = send(sock, (char *)&send_buffer, sizeof(send_recv_struct), 0);if (send_flag <= 0){return FALSE;}return FALSE;}return TRUE;
}int main(int argc, char *argv[])
{WSADATA WSAData;if (WSAStartup(MAKEWORD(2, 0), &WSAData) == SOCKET_ERROR){std::cout << "WSA动态库初始化失败" << std::endl;return 0;}SOCKET server_socket;if ((server_socket = socket(AF_INET, SOCK_STREAM, 0)) == ERROR){std::cout << "Socket 创建失败" << std::endl;WSACleanup();return 0;}struct sockaddr_in ServerAddr;ServerAddr.sin_family = AF_INET;ServerAddr.sin_port = htons(9999);ServerAddr.sin_addr.s_addr = inet_addr("127.0.0.1");if (bind(server_socket, (LPSOCKADDR)&ServerAddr, sizeof(ServerAddr)) == SOCKET_ERROR){std::cout << "绑定套接字失败" << std::endl;closesocket(server_socket);WSACleanup();return 0;}if (listen(server_socket, 10) == SOCKET_ERROR){std::cout << "侦听套接字失败" << std::endl;closesocket(server_socket);WSACleanup();return 0;}SOCKET message_socket;char buf[8192] = { 0 };if ((message_socket = accept(server_socket, (LPSOCKADDR)0, (int*)0)) == INVALID_SOCKET){return 0;}send_recv_struct recv_buffer = { 0 };// 接收对端数据到recv_bufferBOOL flag = RecvFunction(message_socket);std::cout << "接收状态: " << flag << std::endl;closesocket(message_socket);closesocket(server_socket);WSACleanup();return 0;
}

14.8.2 客户端实现

对于客户端而言,其与服务端保持一致,只需要封装一个对等的SendFunction函数,该函数使用send函数将一个send_recv_struct类型的指针send_ptr发送到指定的socket连接通道。在发送完成后,函数使用recv函数从socket连接通道接收数据,并将其存储到一个char型数组recv_buffer中。接下来,该函数使用send_recv_struct类型的指针buffer将该char型数组中的数据复制到一个新的send_recv_struct类型的结构体变量recv_ptr中,最后返回一个BOOL类型的布尔值,表示发送接收函数是否成功执行。

#include <iostream>
#include <winsock2.h>#pragma comment(lib,"ws2_32.lib")typedef struct
{int command_int_a;int command_int_b;int command_int_c;int command_int_d;unsigned int command_uint_a;unsigned int command_uint_b;char command_string_a[256];char command_string_b[256];char command_string_c[256];char command_string_d[256];int flag;int count;
}send_recv_struct;// 调用发送接收函数
BOOL SendFunction(SOCKET &sock, send_recv_struct &send_ptr, send_recv_struct &recv_ptr)
{// 发送数据int send_flag = send(sock, (char *)&send_ptr, sizeof(send_recv_struct), 0);if (send_flag <= 0){return FALSE;}// 接收数据char recv_buffer[8192] = { 0 };int recv_flag = recv(sock, (char *)&recv_buffer, sizeof(send_recv_struct), 0);if (recv_flag <= 0){return FALSE;}send_recv_struct *buffer = (send_recv_struct *)recv_buffer;memcpy((void *)&recv_ptr, buffer, sizeof(send_recv_struct));return TRUE;
}int main(int argc, char* argv[])
{WSADATA WSAData;if (WSAStartup(MAKEWORD(2, 0), &WSAData) == SOCKET_ERROR){return 0;}SOCKET client_socket;if ((client_socket = socket(AF_INET, SOCK_STREAM, 0)) == SOCKET_ERROR){WSACleanup();return 0;}struct sockaddr_in ClientAddr;ClientAddr.sin_family = AF_INET;ClientAddr.sin_port = htons(9999);ClientAddr.sin_addr.s_addr = inet_addr("127.0.0.1");if (connect(client_socket, (LPSOCKADDR)&ClientAddr, sizeof(ClientAddr)) == SOCKET_ERROR){closesocket(client_socket);WSACleanup();return 0;}send_recv_struct send_buffer = {0};send_recv_struct response_buffer = { 0 };// 填充发送数据包send_buffer.command_int_a = 10;send_buffer.command_int_b = 20;send_buffer.flag = 0;// 发送数据包,并接收返回结果BOOL flag = SendFunction(client_socket, send_buffer, response_buffer);if (flag == FALSE){return 0;}std::cout << "响应状态: " << response_buffer.flag << std::endl;if (response_buffer.flag == 1){std::cout << "响应数据: " << response_buffer.command_string_a << std::endl;}closesocket(client_socket);WSACleanup();return 0;
}

运行上述代码片段,读者可看到如下图所示的输出信息;

本文作者: 王瑞
本文链接: https://www.lyshark.com/post/4796bde3.html
版权声明: 本博客所有文章除特别声明外,均采用 BY-NC-SA 许可协议。转载请注明出处!

相关文章:

14.8 Socket 一收一发通信

通常情况下我们在编写套接字通信程序时都会实现一收一发的通信模式&#xff0c;当客户端发送数据到服务端后&#xff0c;我们希望服务端处理请求后同样返回给我们一个状态值&#xff0c;并以此判断我们的请求是否被执行成功了&#xff0c;另外增加收发同步有助于避免数据包粘包…...

7天狂揽 1.3w star 的 MetaGPT,他们的目标让软件公司为之一惊

在 AI 产品爆炸的今天&#xff0c;拥有各种本领的 AI 产品层出不穷&#xff0c;但 MetaGPT 的出现仍然显的格外耀眼&#xff0c;其可以实现只输入单一 prompt&#xff0c;就可以输出需求分析、需求文档、技术架构、最终代码等等产物&#xff0c;这相当于一个开发团队的输出成果…...

工控网络协议模糊测试:用peach对modbus协议进行模糊测试

0x00 背景 本人第一次在FB发帖&#xff0c;进入工控安全行业时间不算很长&#xff0c;可能对模糊测试见解出现偏差&#xff0c;请见谅。 在接触工控安全这一段时间内&#xff0c;对于挖掘工控设备的漏洞&#xff0c;必须对工控各种协议有一定的了解&#xff0c;然后对工控协议…...

python+opencv+机器学习车牌识别 计算机竞赛

0 前言 &#x1f525; 优质竞赛项目系列&#xff0c;今天要分享的是 &#x1f6a9; 基于机器学习的车牌识别系统 &#x1f947;学长这里给一个题目综合评分(每项满分5分) 难度系数&#xff1a;4分工作量&#xff1a;4分创新点&#xff1a;3分 该项目较为新颖&#xff0c;适…...

魔域服务端数据库说明

Magic.DB MagID: 魔法ID Mag:Magic MagName: 魔法名称 EffectType: 效果类型 Effect: 效果 Spell: 魔力&#xff08;魔法值&#xff09; Power: 能力&#xff0c;力量 MaxPower: 最大能力 DefSpell: 变化后的魔力Def&#xff1a;deformation DefPower: 变化后能力 DefMaxPower:…...

笔记本无线网卡MAC一直改动

今天在网管处把我无线网卡的MAC地址添加后&#xff0c;回来链接无线网却一直显示网络链接失败&#xff0c;以为是自己的驱动问题&#xff0c;去官网下载了最新的驱动结果依然无法链接。之前在家或者公共场合链接WiFi从来没有出现过类似情况。 百思不得其解之际发现自己的无线网…...

【Tomcat】Apache发布两个新版本Tomcat修复多个Bug

Apache 官网发布了两个最新的 Tomcat 版本包&#xff0c;分别是&#xff1a;8.5.94、9.0.81 这两个最新版本修复了多个漏洞&#xff0c;统计信息如下表所示。有关漏洞的详细信息&#xff0c;请查阅官方相关文档&#xff08;见&#xff1a;参考&#xff09;。 严重等级漏洞说明…...

Empowering Low-Light Image Enhancer through Customized Learnable Priors 论文阅读笔记

中科大、西安交大、南开大学发表在ICCV2023的论文&#xff0c;作者里有李重仪老师和中科大的Jie Huang&#xff08;ECCV2022的FEC CVPR2022的ENC和CVPR2023的ERL的一作&#xff09;喔&#xff0c;看来可能是和Jie Huang同一个课题组的&#xff0c;而且同样代码是开源的&#xf…...

LeetCode 2652. 倍数求和【数学,容斥原理】简单

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

ansible-playbook剧本

一&#xff0c;playbook组成&#xff1a; &#xff08;1&#xff09;Tasks&#xff1a;任务&#xff0c;即通过 task 调用 ansible 的模板将多个操作组织在一个 playbook 中运行 &#xff08;2&#xff09;Variables&#xff1a;变量 &#xff08;3&#xff09;Templates&…...

竞赛选题 深度学习LSTM新冠数据预测

文章目录 0 前言1 课题简介2 预测算法2.1 Logistic回归模型2.2 基于动力学SEIR模型改进的SEITR模型2.3 LSTM神经网络模型 3 预测效果3.1 Logistic回归模型3.2 SEITR模型3.3 LSTM神经网络模型 4 结论5 最后 0 前言 &#x1f525; 优质竞赛项目系列&#xff0c;今天要分享的是 …...

机械设计师应该在工作中培养哪些良好习惯?

图纸规范 1、一定要按照制图标准设计图纸&#xff01;图纸上任何一条直线&#xff08;无论是点划线、粗实线、细实线等等&#xff09;、数值、公差、图标等&#xff0c;都必须有理有据&#xff0c;不能想当然。图纸是产品生产的基础&#xff0c;无论是生产、加工、装配&#x…...

小程序新增功能页面

需求背景: 小程序主页面有个报名板块,我打算替换主页面报名板块菜单,迁移到我的页面里面, 替换成资讯栏目,我喜欢分享最新技术,开源课题,IT资讯,本想做成论坛的效果,由于时间问题,先替换添加板块 替换后效果: 模块功能: 添加、修改、删除、查看 文件目录:// 添…...

LeetCode每日一题——2652. Sum Multiples

文章目录 一、题目二、题解 一、题目 Given a positive integer n, find the sum of all integers in the range [1, n] inclusive that are divisible by 3, 5, or 7. Return an integer denoting the sum of all numbers in the given range satisfying the constraint. E…...

Python问答题(更新中)

1. 列表&#xff08;list&#xff09;和元组&#xff08;tuple&#xff09;有什么区别&#xff1f; 列表是可变的&#xff0c;创建后可以对其进行修改&#xff1b;元组是不可变的&#xff0c;元组一旦创建&#xff0c;就不能对其进行更改。列表表示的是顺序。它们是有序序列&a…...

服务器中了locked勒索病毒怎么办,勒索病毒解密,数据恢复

最近一段时间内&#xff0c;相信很多使用金蝶或用友的办公软件的企业&#xff0c;有很多都经历了locked勒索病毒的攻击&#xff0c;导致企业服务器被加密无法正常使用&#xff0c;严重影响了企业的正常工作。通过云天数据恢复中心的解密恢复发现&#xff0c;在今年locked勒索病…...

游游的字母串 (环形数组两点之间的位置)

题目链接&#xff1a;登录—专业IT笔试面试备考平台_牛客网 题目&#xff1a; 样例&#xff1a; 输入 yab 输出 3 思路&#xff1a; 暴力枚举&#xff0c;全部变成对应的26个字母字符需要的操作步数&#xff0c;取最少的一个操作步数&#xff0c; 这里的操作步数&#xff0…...

Flink的ResourceManager详解(一)

ResourceManager 总结 一、概述 1、ResourceManager 管理 Flink 集群中的计算资源&#xff0c;计算资源主要来自 TaskManager 组件。 2、如果集群采用 Native【本地模式】部署&#xff0c;则 ResourceManager 会动态地向集群资源管理器申请 Container 并启动TaskManager&…...

Tornado 可以使用 nginx 提供负载均衡

Tornado和nginx都是网络服务器的重要组成部分&#xff0c;但它们在职能和使用场景上存在显著的差异。 Tornado可以独立运行&#xff0c;而不需要依赖nginx等其他Web服务器。这是因为Tornado本身就是一个完整的Web服务器&#xff0c;可以独立处理HTTP请求并返回响应数据。 ngi…...

Golang 面向对象编程 多态

基本介绍 变量(实例)具有多种形态。面向对象的第三大特征&#xff0c;在Go语言&#xff0c;多态特征是通过接口实现的&#xff08;接口能够体现多态的特征&#xff09;。可以按照统一的接口来调用不同的实现。这时接口变量就呈现不同的形态。 在前面的Usb接口案例&#xff0c;u…...

C++初阶-list的底层

目录 1.std::list实现的所有代码 2.list的简单介绍 2.1实现list的类 2.2_list_iterator的实现 2.2.1_list_iterator实现的原因和好处 2.2.2_list_iterator实现 2.3_list_node的实现 2.3.1. 避免递归的模板依赖 2.3.2. 内存布局一致性 2.3.3. 类型安全的替代方案 2.3.…...

【JVM】- 内存结构

引言 JVM&#xff1a;Java Virtual Machine 定义&#xff1a;Java虚拟机&#xff0c;Java二进制字节码的运行环境好处&#xff1a; 一次编写&#xff0c;到处运行自动内存管理&#xff0c;垃圾回收的功能数组下标越界检查&#xff08;会抛异常&#xff0c;不会覆盖到其他代码…...

江苏艾立泰跨国资源接力:废料变黄金的绿色供应链革命

在华东塑料包装行业面临限塑令深度调整的背景下&#xff0c;江苏艾立泰以一场跨国资源接力的创新实践&#xff0c;重新定义了绿色供应链的边界。 跨国回收网络&#xff1a;废料变黄金的全球棋局 艾立泰在欧洲、东南亚建立再生塑料回收点&#xff0c;将海外废弃包装箱通过标准…...

CocosCreator 之 JavaScript/TypeScript和Java的相互交互

引擎版本&#xff1a; 3.8.1 语言&#xff1a; JavaScript/TypeScript、C、Java 环境&#xff1a;Window 参考&#xff1a;Java原生反射机制 您好&#xff0c;我是鹤九日&#xff01; 回顾 在上篇文章中&#xff1a;CocosCreator Android项目接入UnityAds 广告SDK。 我们简单讲…...

基于Docker Compose部署Java微服务项目

一. 创建根项目 根项目&#xff08;父项目&#xff09;主要用于依赖管理 一些需要注意的点&#xff1a; 打包方式需要为 pom<modules>里需要注册子模块不要引入maven的打包插件&#xff0c;否则打包时会出问题 <?xml version"1.0" encoding"UTF-8…...

Spring Boot面试题精选汇总

&#x1f91f;致敬读者 &#x1f7e9;感谢阅读&#x1f7e6;笑口常开&#x1f7ea;生日快乐⬛早点睡觉 &#x1f4d8;博主相关 &#x1f7e7;博主信息&#x1f7e8;博客首页&#x1f7eb;专栏推荐&#x1f7e5;活动信息 文章目录 Spring Boot面试题精选汇总⚙️ **一、核心概…...

【HTML-16】深入理解HTML中的块元素与行内元素

HTML元素根据其显示特性可以分为两大类&#xff1a;块元素(Block-level Elements)和行内元素(Inline Elements)。理解这两者的区别对于构建良好的网页布局至关重要。本文将全面解析这两种元素的特性、区别以及实际应用场景。 1. 块元素(Block-level Elements) 1.1 基本特性 …...

高防服务器能够抵御哪些网络攻击呢?

高防服务器作为一种有着高度防御能力的服务器&#xff0c;可以帮助网站应对分布式拒绝服务攻击&#xff0c;有效识别和清理一些恶意的网络流量&#xff0c;为用户提供安全且稳定的网络环境&#xff0c;那么&#xff0c;高防服务器一般都可以抵御哪些网络攻击呢&#xff1f;下面…...

RNN避坑指南:从数学推导到LSTM/GRU工业级部署实战流程

本文较长&#xff0c;建议点赞收藏&#xff0c;以免遗失。更多AI大模型应用开发学习视频及资料&#xff0c;尽在聚客AI学院。 本文全面剖析RNN核心原理&#xff0c;深入讲解梯度消失/爆炸问题&#xff0c;并通过LSTM/GRU结构实现解决方案&#xff0c;提供时间序列预测和文本生成…...

3-11单元格区域边界定位(End属性)学习笔记

返回一个Range 对象&#xff0c;只读。该对象代表包含源区域的区域上端下端左端右端的最后一个单元格。等同于按键 End 向上键(End(xlUp))、End向下键(End(xlDown))、End向左键(End(xlToLeft)End向右键(End(xlToRight)) 注意&#xff1a;它移动的位置必须是相连的有内容的单元格…...