14.8 Socket 一收一发通信

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

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

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

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

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

14.8.1 服务端实现

服务端我们实现的功能只有一个接收，其中RecvFunction函数主要用于接收数据包，通过使用recv函数接收来自socket连接通道的数据，并根据接收到的数据判断条件，决定是否发送数据回应。如果接收到的数据中命令参数满足command_int_a=10和command_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 许可协议。转载请注明出处！

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

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

相关文章

【Kotlin精简】第4章 函数

【Kotlin精简】第4章 函数

1 简介 函数是用来运行代码的载体&#xff0c;可以在一个函数里编写很多行代码&#xff0c;当运行这个函数时&#xff0c;函数中的所有代码会全部运行。 Kotlin中的函数同Java完全面向对象的规则不太一样&#xff0c;在Kotlin的世界里&#xff0c;函数也是准C位的&#xff0c;…
阅读更多...
微服务架构 | 超时管理

微服务架构 | 超时管理

INDEX LSA 级别与全年停机时间速查表LSA 级别实战TP 性能超时时间设计原则 LSA 级别与全年停机时间速查表 计算公式&#xff1a;60 * 60 * 24 * 365 * (1-LSA) 31,536,000‬ * (1-LSA) 系统级别LSA级别全年停机时间099.999%5分钟099.99%52分钟199.9%8.8小时299%3.65 天 LSA…
阅读更多...
基于 ACK Fluid 的混合云优化数据访问（五）：自动化跨区域中心数据分发

基于 ACK Fluid 的混合云优化数据访问（五）：自动化跨区域中心数据分发

作者&#xff1a;车漾 前文回顾&#xff1a; 本系列将介绍如何基于 ACK Fluid 支持和优化混合云的数据访问场景&#xff0c;相关文章请参考&#xff1a; -基于 ACK Fluid 的混合云优化数据访问&#xff08;一&#xff09;&#xff1a;场景与架构 -基于 ACK Fluid 的混合云优…
阅读更多...
科研上新 | 第2期：可驱动3D肖像生成；阅读文本密集图像的大模型；文本控制音色；基于大模型的推荐智能体

科研上新 | 第2期：可驱动3D肖像生成；阅读文本密集图像的大模型；文本控制音色；基于大模型的推荐智能体

编者按&#xff1a;欢迎阅读“科研上新”栏目&#xff01;“科研上新”汇聚了微软亚洲研究院最新的创新成果与科研动态。在这里&#xff0c;你可以快速浏览研究院的亮点资讯&#xff0c;保持对前沿领域的敏锐嗅觉&#xff0c;同时也能找到先进实用的开源工具。 本期内容速览 …
阅读更多...
基于yolov2深度学习网络的猫脸检测识别matlab仿真

基于yolov2深度学习网络的猫脸检测识别matlab仿真

目录 1.算法运行效果图预览 2.算法运行软件版本 3.部分核心程序 4.算法理论概述 5.算法完整程序工程 1.算法运行效果图预览 2.算法运行软件版本 matlab2022a 3.部分核心程序 load yolov2.mat% 加载训练好的目标检测器 img_size [224,224]; imgPath test/; % 图…
阅读更多...
至强服务器BIOS/UEFI驱动开发笔记

至强服务器BIOS/UEFI驱动开发笔记

至强服务器BIOS/UEFI驱动开发笔记 驱动开发基础Hello UEFI Driver 项目选择项目位置初始化驱动代码文件结构驱动程序入口和基本功能导入AMI工程AMI平台Hello UEFI Driver 编译问题测试结果打印设备列表继续开发`HelloWorldSupported`函数依赖配置使用脚本编译编译测试此DXE驱动…
阅读更多...
SQL如何导入数据以及第一次上机作业

SQL如何导入数据以及第一次上机作业

如何导入excel数据 首先得学会导入数据 使用excel格式不需要改成其它格式&#xff08;如csv&#xff0c;txt&#xff09;&#xff0c;因为你改了到时候还是会报错&#xff08;实践过使用Sum统计总数一直说我数据格式有问题&#xff09; 首先右键TSGL数据库->任务->导入数…
阅读更多...
C++前缀和算法应用：矩形区域不超过 K 的最大数值和

C++前缀和算法应用：矩形区域不超过 K 的最大数值和

基础知识点 C算法&#xff1a;前缀和、前缀乘积、前缀异或的原理、源码及测试用例 题目 给你一个 m x n 的矩阵 matrix 和一个整数 k &#xff0c;找出并返回矩阵内部矩形区域的不超过 k 的最大数值和。 题目数据保证总会存在一个数值和不超过 k 的矩形区域。 示例 1&#x…
阅读更多...
机器学习-概述与贝叶斯算法

机器学习-概述与贝叶斯算法

机器学习的一般步骤&#xff1a;数据搜集、数据清洗、特征工程、数学建模。数据划分&#xff1a;训练集、验证集、测试集。K折交叉验证&#xff1a;解决数据量不够大问题&#xff0c;解决参数调优问题。深度学习不用做特征工程&#xff0c;传统机器学习要。损失函数&#xff0c…
阅读更多...
深圳寄包裹到德国

深圳寄包裹到德国

深圳&#xff0c;作为全球最发达的城市之一&#xff0c;以其高效的物流服务在全球范围内享有盛名。如果你正在寻找一种方式将包裹从深圳寄送到德国&#xff0c;那么本文将为你提供详细的步骤和建议。 第一步&#xff1a;了解国际邮寄的基本信息 首先&#xff0c;你需要了解包裹…
阅读更多...
Bitquiz重塑Learn to Earn热潮，用户零投入让学习创造价值

Bitquiz重塑Learn to Earn热潮，用户零投入让学习创造价值

Axie 带来的暴富效应、StepN 带来的出圈效应&#xff0c;近期Bigtime 在熊市中的大火&#xff0c;为加密参与者带来的赚取效应&#xff0c;X to Earn 重新成为整个市场关注的重点&#xff0c;GameFi 再次站在了风口浪尖。 大家开始寻找下一个Bigtime&#xff0c;希望能够抓住一…
阅读更多...
低代码技术这么香，如何把它的开发特点发挥到极致？

低代码技术这么香，如何把它的开发特点发挥到极致？

前言 什么是低代码技术&#xff1f; 低代码是一种可视化软件开发方法&#xff0c;通过最少的编码更快地交付应用程序。图形用户界面和拖放功能使开发过程的各个方面自动化&#xff0c;消除了对传统计算机编程方法的依赖。 文章目录 前言低代码平台怎么选&#xff1f;用友Yonbu…
阅读更多...
压缩炸弹，Java怎么防止

压缩炸弹，Java怎么防止

一、什么是压缩炸弹&#xff0c;会有什么危害 1.1 什么是压缩炸弹 压缩炸弹(ZIP)&#xff1a;一个压缩包只有几十KB&#xff0c;但是解压缩后有几十GB&#xff0c;甚至可以去到几百TB&#xff0c;直接撑爆硬盘&#xff0c;或者是在解压过程中CPU飙到100%造成服务器宕机。虽然…
阅读更多...
JOSEF约瑟 多档切换式漏电（剩余）继电器JHOK-ZBL1 30/100/300/500mA

JOSEF约瑟 多档切换式漏电（剩余）继电器JHOK-ZBL1 30/100/300/500mA

系列型号&#xff1a; JHOK-ZBL多档切换式漏电&#xff08;剩余&#xff09;继电器&#xff08;导轨&#xff09; JHOK-ZBL1多档切换式漏电&#xff08;剩余&#xff09;继电器 JHOK-ZBL2多档切换式漏电&#xff08;剩余&#xff09;继电器 JHOK-ZBM多档切换式漏电&#xf…
阅读更多...
Unity 3D基础——缓动效果

Unity 3D基础——缓动效果

1.在场景中新建两个 Cube 立方体&#xff0c;在 Scene 视图中将两个 Cude的位置错开。 2.新建 C# 脚本 MoveToTarget.cs&#xff08;写完记得保存&#xff09; using System.Collections; using System.Collections.Generic; using UnityEngine;public class MoveToTarget : M…
阅读更多...
SystemC入门学习-第8章 测试平台的编写

SystemC入门学习-第8章 测试平台的编写

之前的章节&#xff0c;一直把重点放在用SystemC来描述硬件电路上&#xff0c;即如何编写SystemC 的RTL。本章的注意力集中在验证和编写测试平台上。 重点包括&#xff1a; 如何生成时钟信号和激励波形如何编写有响应能力的测试平台如何记录仿真结果 8.1 编写测试平台 测试平…
阅读更多...
论文阅读：Rethinking Range View Representation for LiDAR Segmentation

论文阅读：Rethinking Range View Representation for LiDAR Segmentation

来源ICCV2023 0、摘要 LiDAR分割对于自动驾驶感知至关重要。最近的趋势有利于基于点或体素的方法&#xff0c;因为它们通常产生比传统的距离视图表示更好的性能。在这项工作中&#xff0c;我们揭示了建立强大的距离视图模型的几个关键因素。我们观察到&#xff0c;“多对一”…
阅读更多...
JOSEF约瑟 漏电继电器 JD1-200 工作电压：380V 孔径：45mm 50～500mA

JOSEF约瑟 漏电继电器 JD1-200 工作电压：380V 孔径：45mm 50～500mA

JD1系列漏电继电器 系列型号 JD1-100漏电继电器 JD1-200漏电继电器 JD1-250漏电继电器 JD1系列漏电继电器原为分体式固定式安装&#xff0c;为适应现行安装场合需要&#xff0c;上海约瑟继电器厂在产品原JD1一体式漏电继电器基础上进行产品升级&#xff0c;开发出现在较为…
阅读更多...
【Rust基础①】基本类型、所有权与借用、复合类型

【Rust基础①】基本类型、所有权与借用、复合类型

文章目录 1 基本类型1.1 数值类型1.1.1 Rust 中的内置的整数类型&#xff1a;1.1.2 浮点类型1.1.3 数学运算1.1.4 位运算1.1.5 序列(Range) 1.2 字符、布尔、单元类型1.3 语句和表达式1.4 函数 2 所有权与借用2.1 栈(Stack)与堆(Heap)2.2 所有权原则2.2.1 转移所有权2.2.2 克隆…
阅读更多...
【Redis】Java Spring操作redis

【Redis】Java Spring操作redis

目录 引入Redis依赖StringRedisTemplate使用String使用List使用Set使用hash使用zset 引入Redis依赖 StringRedisTemplate 此处RedisTemplate是把这些操作Redis的方法&#xff0c;分成了几个类别&#xff0c;分门别类的来组织的。 此处提供的一些接口风格&#xff0c;和原生的Re…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023