02.07 TCP服务器与客户端的搭建

一.思维导图

二.使用动态协议包实现服务器与客户端

1. 协议包的结构定义

首先，是协议包的结构定义。在两段代码中，pack_t结构体都被用来表示协议包：

typedef struct Pack {int size;        // 记录整个协议包的实际大小enum Type type;  // 协议包的类型char buf[2048];  // 存储实际数据int count;       // 记录buf中已使用的字节数
} pack_t;

enum Type定义了协议包的类型，例如TYPE_REGIST和TYPE_LOGIN，分别表示注册和登录操作。

2. 服务器端的协议包解析

在服务器端代码中，read_pack函数负责解析从客户端接收到的协议包。该函数的主要步骤如下：

  1. 读取数据大小：从buf中读取前2个字节，表示接下来要读取的数据大小。

  2. 读取数据：根据读取到的数据大小，从buf中读取相应长度的数据。

  3. 处理数据：将读取到的数据打印出来。

    void read_pack(pack_t* pack) {char *buf = pack->buf;int readed_size = 0;while(1) {short data_size = *(short*)(buf + readed_size);if(data_size == 0) {printf("数据解析完毕\n");break;}readed_size += 2;char temp[data_size + 1];memset(temp, 0, data_size + 1);memcpy(temp, buf + readed_size, data_size);readed_size += data_size;printf("temp = %s\n", temp);}
}

    3. 客户端的协议包构建

    在客户端代码中，append函数负责将数据按照协议格式添加到pack_t结构体中。该函数的主要步骤如下：

  4. 记录数据长度：将数据的长度存储在buf的前2个字节中。

  5. 存储数据：将数据本身存储在buf中。

  6. 更新协议包大小：更新pack_t结构体中的size和count字段。

    void append(pack_t* pack, const char* data) {char* buf = pack->buf;int len = strlen(data);*(short*)(buf + pack->count) = len;pack->count += 2;memcpy(buf + pack->count, data, len);pack->count += len;pack->size = pack->count + 8;
}

    4. 客户端与服务器的交互

    在客户端代码中，用户输入账号和密码后，append函数将数据添加到协议包中，然后通过write函数将协议包发送给服务器。

    while(1) {pack_t pack = {0};pack.type = TYPE_LOGIN;char name[20] = "";char pswd[20] = "";printf("请输入账号:");scanf("%19s", name);while(getchar() != 10);printf("请输入密码:");scanf("%19s", pswd);while(getchar() != 10);append(&pack, name);append(&pack, pswd);write(client, &pack, pack.size);
}

    在服务器端，read函数接收客户端发送的协议包，并调用read_pack函数解析数据。

    while(1) {int pack_size = 0;read(client, &pack_size, 4);pack_t pack = {0};read(client, (char*)&pack + 4, pack_size - 4);pack.size = pack_size;read_pack(&pack);
}

    5. 总结

    通过这两段代码，我们可以看到如何在C语言中实现一个简单的网络协议包的构建与解析。服务器端负责接收和解析协议包，而客户端则负责构建和发送协议包。这种设计模式在网络编程中非常常见，理解其原理对于开发网络应用程序至关重要。

      6.完整代码

1>服务器

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <unistd.h>typedef struct sockaddr_in addr_in_t;
typedef struct sockaddr addr_t;
typedef struct sockaddr_un addr_un_t;enum Type {TYPE_REGIST,TYPE_LOGIN
};typedef struct Pack {int size;enum Type type;char buf[2048];int count;
} pack_t;void read_pack(pack_t *pack) {char *buf = pack->buf;int readed_size = 0;while (1) {short data_size = *(short *)(buf + readed_size);if (data_size == 0) {printf("数据解析完毕\n");break;}readed_size += 2;char temp[data_size + 1];memset(temp, 0, data_size + 1);memcpy(temp, buf + readed_size, data_size);readed_size += data_size;printf("temp = %s\n", temp);}
}int main(int argc, const char *argv[]) {if (argc != 2) {printf("请输入端口号\n");return 1;}int port = atoi(argv[1]);int server = socket(AF_INET, SOCK_STREAM, 0);addr_in_t addr = {0};addr.sin_family = AF_INET;addr.sin_port = htons(port);addr.sin_addr.s_addr = inet_addr("0.0.0.0");if (bind(server, (addr_t *)&addr, sizeof(addr)) == -1) {perror("bind");return 1;}listen(server, 10);addr_in_t client_addr = {0};int client_addr_len = sizeof(client_addr);int client = accept(server, (addr_t *)&client_addr, &client_addr_len);if (client != -1) {printf("有客户端连接\n");}while (1) {int pack_size = 0;read(client, &pack_size, 4);pack_t pack = {0};read(client, (char *)&pack + 4, pack_size - 4);pack.size = pack_size;read_pack(&pack);}return 0;
}

2>客户端

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <unistd.h>typedef struct sockaddr_in addr_in_t;
typedef struct sockaddr addr_t;
typedef struct sockaddr_un addr_un_t;enum Type {TYPE_REGIST,TYPE_LOGIN
};typedef struct Pack {int size;enum Type type;char buf[2048];int count;
} pack_t;void append(pack_t *pack, const char *data) {char *buf = pack->buf;int len = strlen(data);*(short *)(buf + pack->count) = len;memcpy(buf + pack->count + 2, data, len);pack->count += 2;pack->count += len;pack->size = pack->count + 8;
}int main(int argc, const char *argv[]) {if (argc != 2) {printf("请输入端口号\n");return 1;}int port = atoi(argv[1]);int client = socket(AF_INET, SOCK_STREAM, 0);addr_in_t addr = {0};addr.sin_family = AF_INET;addr.sin_port = htons(port);addr.sin_addr.s_addr = inet_addr("192.168.60.77");if (connect(client, (addr_t *)&addr, sizeof(addr)) == -1) {perror("connect");return 1;}while (1) {pack_t pack = {0};pack.type = TYPE_LOGIN;char name[20] = "";char pswd[20] = "";printf("请输入账号：");scanf("%19s", name);while (getchar() != '\n');printf("请输入密码：");scanf("%19s", pswd);while (getchar() != '\n');append(&pack, name);append(&pack, pswd);write(client, &pack, pack.size);}return 0;
}

三、基于以上代码，将读取到的一条条代码保存到链表中

1.服务器代码

#include <stdio.h>
#include <string.h>
#include <unistd.h>
#include <stdlib.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <pthread.h>
#include <semaphore.h>
#include <wait.h>
#include <signal.h>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <sys/socket.h>
#include <sys/ipc.h>
#include <sys/sem.h>
#include <semaphore.h>
#include <sys/msg.h>
#include <sys/shm.h>
#include <sys/un.h>// 定义网络地址结构体类型
typedef struct sockaddr_in addr_in_t;
typedef struct sockaddr addr_t;
typedef struct sockaddr_un addr_un_t;// 定义协议包类型枚举
enum Type {TYPE_REGIST,  // 注册类型TYPE_LOGIN    // 登录类型
};// 定义协议包结构体
typedef struct Pack {int size;         // 协议包的总大小enum Type type;   // 协议包的类型char buf[2048];   // 数据缓冲区int count;        // 记录缓冲区中已使用的字节数
} pack_t;// 定义链表节点结构体
typedef struct Node {char* data;       struct Node* next; 
} Node;// 创建新节点
Node* create_node(const char* data) {Node* node = (Node*)malloc(sizeof(Node)); if (data != NULL) {size_t len = strlen(data) + 1;node->data = (char*)malloc(len * sizeof(char));if (node->data != NULL) {strcpy(node->data, data);} else {fprintf(stderr, "内存分配失败！\n");exit(EXIT_FAILURE);}
} else {// 处理输入为 NULL 的情况node->data = NULL;
} node->next = NULL; return node;
}// 将数据添加到链表
void append_to_list(Node** head, const char* data) {Node* new_node = create_node(data);if (*head == NULL) {*head = new_node; } else {Node* current = *head;while (current->next != NULL) {current = current->next;}current->next = new_node; }
}// 释放链表内存
void free_list(Node* head) {Node* current = head;while (current != NULL) {Node* next = current->next; free(current->data); free(current); current = next; }
}// 解析协议包并将数据保存到链表
void read_pack(pack_t* pack, Node** head) {char *buf = pack->buf; int readed_size = 0; // 记录已读取的字节数while(1) {short data_size = *(short*)(buf + readed_size); // 读取数据大小if(data_size == 0) {printf("数据解析完毕\n"); break;}readed_size += 2; char temp[data_size + 1]; memset(temp, 0, data_size + 1); memcpy(temp, buf + readed_size, data_size); readed_size += data_size; // 更新已读取的字节数printf("temp = %s\n", temp); append_to_list(head, temp); // 将数据添加到链表}
}// 主函数
int main(int argc, const char *argv[]) 
{if(argc != 2) {printf("请输入端口号\n"); return 1;}int port = atoi(argv[1]); // 将端口号字符串转换为整数// 创建服务器套接字int server = socket(AF_INET, SOCK_STREAM, 0);addr_in_t addr = {0};addr.sin_family = AF_INET; addr.sin_port = htons(port); addr.sin_addr.s_addr = inet_addr("0.0.0.0"); // 绑定套接字到地址if(bind(server, (struct sockaddr*)&addr, sizeof(addr)) == -1) {perror("bind"); // 绑定失败return 1;}// 监听连接listen(server, 10);// 接受客户端连接addr_in_t client_addr = {0};int client_addr_len = sizeof(client_addr);int client = accept(server, (struct sockaddr*)&client_addr, &client_addr_len);if(client != -1) {printf("有客户端连接\n"); }Node* head = NULL; // 初始化链表头while(1) {int pack_size = 0;int ret = read(client, &pack_size, 4); // 读取协议包大小if (ret == -1) {printf("客户端断开连接\n"); break; // 退出循环}pack_t pack = {0};ret = read(client, (char*)&pack + 4, pack_size - 4); // 读取协议包数据if (ret == -1) {printf("客户端断开连接\n"); // 客户端断开连接break; // 退出循环}pack.size = pack_size; // 设置协议包大小read_pack(&pack, &head); // 解析协议包并保存数据到链表// 打印链表中的数据Node* current = head;printf("--------保存的数据如下--------\n");while (current != NULL) {printf("链表数据: %s\n", current->data);current = current->next;}printf("\n");}free_list(head); // 释放链表内存return 0;
}

2.客户端代码

#include <stdio.h>
#include <string.h>
#include <unistd.h>
#include <stdlib.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <pthread.h>
#include <semaphore.h>
#include <wait.h>
#include <signal.h>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <sys/socket.h>
#include <sys/ipc.h>
#include <sys/sem.h>
#include <semaphore.h>
#include <sys/msg.h>
#include <sys/shm.h>
#include <sys/un.h>typedef struct sockaddr_in addr_in_t;  
typedef struct sockaddr addr_t;        
typedef struct sockaddr_un addr_un_t;  // 定义消息类型枚举
enum Type{TYPE_REGIST,    // 注册类型TYPE_LOGIN      // 登录类型
};// 自定义数据包结构体
typedef struct Pack
{int size;           enum Type type;     char buf[2048];    int count;         
}pack_t;void append(pack_t* pack, const char* data)
{char *buf = pack->buf;int len = strlen(data);*(short*)(buf + pack->count) = len;  pack->count += 2;                   memcpy(buf + pack->count, data, len); pack->count += len;                   // 更新数据包总大小（头部8字节 + 数据长度）pack->size = pack->count + 8;         
}int main(int argc, const char *argv[])
{if(argc != 2){printf("Usage: %s <port>\n", argv[0]);return 1;}int port = atoi(argv[1]);  // 将端口参数转为整数// 创建TCP套接字int client = socket(AF_INET, SOCK_STREAM, 0);if(client == -1){perror("socket creation failed");return 1;}// 配置服务器地址信息addr_in_t addr = {0};addr.sin_family = AF_INET;                   addr.sin_port = htons(port);                addr.sin_addr.s_addr = inet_addr("192.168.126.233");// 连接服务器if(connect(client, (addr_t*)&addr, sizeof(addr)) == -1){perror("connect failed");return 1;}while(1){pack_t pack = {0};      pack.type = TYPE_LOGIN; char name[20] = "";char pswd[20] = "";// 获取用户名输入printf("请输入账号:");scanf("%19s", name);while(getchar() != '\n'); // 清空输入缓冲区// 获取密码输入printf("请输入密码:");scanf("%19s", pswd);while(getchar() != '\n'); // 清空输入缓冲区// 将用户名和密码打包到数据包append(&pack, name);append(&pack, pswd);// 发送整个数据包（发送大小为计算后的总大小）write(client, &pack, pack.size);}return 0;
}

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

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

相关文章

笔灵ai写作技术浅析（六）：智能改写与续写

笔灵ai写作技术浅析（六）：智能改写与续写

笔灵AI写作中的智能改写和续写技术是其核心功能之一，旨在帮助用户生成高质量、多样化的文本内容。 一、智能改写技术 1. 基本原理 智能改写的目标是在保持原文语义不变的前提下，对文本进行重新表述，生成语法正确、语义连贯且风格多样的新文本。其核心思想是通过语义理解和…
阅读更多...
3.如何标注数据集

3.如何标注数据集

软件安装&#xff1a; Labelme&#xff0c;打开链接之后跳转如下&#xff1a; 这里往下翻&#xff0c;如下&#xff1a; 选择上图圈起来的exe进行下载就可以了&#xff0c;下载完成之后就可以双击直接打开了。如果通过github下载很慢的话可以直接选择通过网盘分享的文件&…
阅读更多...
【分布式理论7】分布式调用之：服务间的（RPC）远程调用

【分布式理论7】分布式调用之：服务间的（RPC）远程调用

文章目录 一、RPC 调用过程二、RPC 动态代理&#xff1a;屏蔽远程通讯细节1. 动态代理示例2. 如何将动态代理应用于 RPC 三、RPC序列化与协议编码1. RPC 序列化2. RPC 协议编码2.1. 协议编码的作用2.2. RPC 协议消息组成 四、RPC 网络传输1. 网络传输流程2. 关键优化点 一、RPC…
阅读更多...
SSA-TCN麻雀算法优化时间卷积神经网络时间序列预测未来Matlab实现

SSA-TCN麻雀算法优化时间卷积神经网络时间序列预测未来Matlab实现

SSA-TCN麻雀算法优化时间卷积神经网络时间序列预测未来Matlab实现 目录 SSA-TCN麻雀算法优化时间卷积神经网络时间序列预测未来Matlab实现预测效果基本介绍程序设计参考资料 预测效果 基本介绍 1.Matlab实现SSA-TCN麻雀算法优化时间卷积神经网络时间序列预测未来&#xff08;优…
阅读更多...
智慧停车场解决方案（文末联系，领取整套资料，可做论文）

智慧停车场解决方案（文末联系，领取整套资料，可做论文）

一、方案概述 本智慧停车场解决方案旨在通过硬件设备与软件系统的深度整合&#xff0c;实现停车场的智能化管理与服务&#xff0c;提升车主的停车体验&#xff0c;优化停车场运营效率。 二、硬件架构 硬件设备说明&#xff1a; 车牌识别摄像机&#xff1a;安装在停车场入口和…
阅读更多...
DeepSeek开源多模态大模型Janus-Pro部署

DeepSeek开源多模态大模型Janus-Pro部署

DeepSeek多模态大模型部署 请自行根据电脑配置选择合适环境配置安装conda以及gitJanus 项目以及依赖安装运行cpu运行gpu运行 进入ui界面 请自行根据电脑配置选择合适 本人家用电脑为1060&#xff0c;因此部署的7B模型。配置高的可以考虑更大参数的模型。 环境配置 安装conda…
阅读更多...
C#常用集合优缺点对比

C#常用集合优缺点对比

先上结论&#xff1a; 在C#中&#xff0c;链表、一维数组、字典、List<T>和ArrayList是常见的数据集合类型&#xff0c;它们各有优缺点&#xff0c;适用于不同的场景。以下是它们的比较&#xff1a; 1. 一维数组 (T[]) 优点&#xff1a; 性能高&#xff1a;数组在内存中…
阅读更多...
python-leetcode-删除有序数组中的重复项 II

python-leetcode-删除有序数组中的重复项 II

80. 删除有序数组中的重复项 II - 力扣&#xff08;LeetCode&#xff09; class Solution:def removeDuplicates(self, nums: List[int]) -> int:if len(nums) < 2:return len(nums)j 2 # 允许最多两个相同的元素for i in range(2, len(nums)):if nums[i] ! nums[j - 2…
阅读更多...
如何启用 Apache Rewrite 重写模块 ?

如何启用 Apache Rewrite 重写模块 ?

Apache 的 mod_rewrite 是最强大的 URL 操作模块之一。使用 mod_rewrite&#xff0c;您可以重定向和重写 url&#xff0c;这对于在您的网站上实现 seo 友好的 URL 结构特别有用。在本文中&#xff0c;我们将引导您了解如何在基于 Debian 和基于 RHEL 的系统上在 Apache 中启用 …
阅读更多...
动手学图神经网络（9）：利用图神经网络进行节点分类 WeightsBiases

动手学图神经网络（9）：利用图神经网络进行节点分类 WeightsBiases

利用图神经网络进行节点分类Weights&Biases 引言 在本篇博客中，将深入探讨如何使用图神经网络（GNNs）来完成节点分类任务。以 Cora 数据集为例，该数据集是一个引用网络，节点代表文档，推断每个文档的类别。同时，使用 Weights & Biases（W&B）来跟踪实验过程和…
阅读更多...
STM32单片机学习记录（2.9）

STM32单片机学习记录（2.9）

一、STM32 15.1 - FLASH闪存 1. FLASH简介 &#xff08;1&#xff09;STM32系列的FLASH包含程序存储器、系统存储器和选项字节三个部分&#xff0c;通过闪存存储器接口&#xff08;外设&#xff09;可以对程序存储器和选项字节进行擦除和编程&#xff1b; &#xff08;2&#x…
阅读更多...
＜论文＞DeepSeek-R1：通过强化学习激励大语言模型的推理能力（深度思考）

＜论文＞DeepSeek-R1：通过强化学习激励大语言模型的推理能力（深度思考）

一、摘要 本文跟大家来一起阅读DeepSeek团队发表于2025年1月的一篇论文《DeepSeek-R1: Incentivizing Reasoning Capability in LLMs via Reinforcement Learning | Papers With Code》&#xff0c;新鲜的DeepSeek-R1推理模型&#xff0c;作者规模属实庞大。如果你正在使用Deep…
阅读更多...
Spring Boot 3.4 中 MockMvcTester 的新特性解析

Spring Boot 3.4 中 MockMvcTester 的新特性解析

引言 在 Spring Boot 3.4 版本中&#xff0c;引入了一个全新的 MockMvcTester 类&#xff0c;使 MockMvc 测试可以直接支持 AssertJ 断言。本文将深入探讨这一新特性&#xff0c;分析它如何优化 MockMvc 测试并提升测试的可读性。 Spring MVC 示例 为了演示 MockMvcTester 的…
阅读更多...
来自国外的实用软件 ，已接触所有限制！

来自国外的实用软件 ，已接触所有限制！

今天我给大家带来了一款超棒的全自动抠图软件&#xff0c;真的是一个来自国外的宝藏工具&#xff01;而且好消息是&#xff0c;它现在完全解除了限制&#xff0c;可以无限畅快地使用了。 Teorex PhotoScissors 抠图软件 这款软件特别贴心&#xff0c;根本不需要安装&#xff0…
阅读更多...
Jetbrains IDE http客户端使用教程

Jetbrains IDE http客户端使用教程

简介 JetBrains IDE&#xff08;如IntelliJ IDEA&#xff0c; WebStorm&#xff0c; PhpStorm和PyCharm&#xff09;自带一个内置的HTTP客户端&#xff0c;允许直接从IDE发送HTTP请求&#xff0c;而无需使用第三方工具&#xff0c;如Postman或cURL。 JetBrains IDE 中的 HTTP…
阅读更多...
活动预告 |【Part1】Microsoft Azure 在线技术公开课：AI 基础知识

活动预告 |【Part1】Microsoft Azure 在线技术公开课：AI 基础知识

课程介绍 参加“Azure 在线技术公开课&#xff1a;AI 基础知识”活动&#xff0c;了解 AI 核心概念。参加我们举办的本次免费培训活动&#xff0c;了解组织如何使用 AI 技术克服实际挑战&#xff0c;以及如何借助 Azure AI 服务构建智能应用程序。本次培训适用于任何对 AI 解决…
阅读更多...
小红书提出新面部视频交换方法DynamicFace，可生成高质量且一致的视频面部图像。

小红书提出新面部视频交换方法DynamicFace，可生成高质量且一致的视频面部图像。

DynamicFace是一种新颖的面部视频交换方法&#xff0c;旨在生成高质量且一致的视频面部图像。该方法结合了扩散模型的强大能力和可插拔的时间层&#xff0c;以解决传统面部交换技术面临的两个主要挑战&#xff1a;在保持源面部身份的同时&#xff0c;准确传递目标面部的运动信息…
阅读更多...
如何使用 DataX 连接 Easysearch

如何使用 DataX 连接 Easysearch

DataX DataX 是阿里开源的一款离线数据同步工具&#xff0c;致力于实现包括关系型数据库(MySQL、Oracle 等)、HDFS、Hive、ODPS、HBase、FTP 等各种异构数据源之间稳定高效的数据同步功能。 本篇主要介绍 DataX 如何将数据写入到 Easysearch&#xff0c;对于各种数据源的连接…
阅读更多...
数据治理双证通关经验分享 | CDGA/CDGP备考全指南

数据治理双证通关经验分享 | CDGA/CDGP备考全指南

历经1个月多的系统准备&#xff0c;本人于2024年顺利通过DAMA China的CDGA&#xff08;数据治理工程师&#xff09;和CDGP&#xff08;数据治理专家&#xff09;双认证。现将备考经验与资源体系化整理&#xff0c;助力从业者高效通关。 &#x1f31f; 认证价值与政策背景 根据…
阅读更多...
结合个人经历谈谈企业数字化

结合个人经历谈谈企业数字化

转眼间专注于从事企业数字化转型的工作已经3年。在这之前我做了8年的开发工作&#xff0c;8年间从最开始的软件开发岗位到高级开发工程师&#xff0c;再到资深开发工程师&#xff0c;主要使用的语言是java&#xff0c;其次js、python、存储过程plsql等。因为各种原因&#xff0…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023