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，一经查实，立即删除！

相关文章

Java 读取 PDF 模板文档并替换内容重新生成 PDF

Java 读取 PDF 模板文档并替换内容重新生成 PDF

朋友们&#xff01;在实际开发里&#xff0c;经常会遇到需要根据 PDF 模板文档生成特定 PDF 的需求&#xff0c;比如合同、证书等。咱们可以借助 iText 库来实现读取 PDF 模板文档、替换指定内容&#xff0c;最后重新生成新 PDF 的功能。下面我就详细给大家讲讲具体怎么做。 1.…
阅读更多...
动手写ORM框架 - GeeORM第一天 database/sql 基础

动手写ORM框架 - GeeORM第一天 database/sql 基础

文章目录 1 初识 SQLite2 database/sql 标准库3 实现一个简单的 log 库4 核心结构 Session本文是7天用Go从零实现ORM框架GeeORM的第一篇。介绍了 SQLite 的基础操作（连接数据库，创建表、增删记录等）。使用 Go 语言标准库 database/sql 连接并操作 SQLite 数据库，并简单封装…
阅读更多...
DeepSeek和ChatGPT的对比

DeepSeek和ChatGPT的对比

最近DeepSeek大放异彩&#xff0c;两者之间有什么差异呢&#xff1f;根据了解到的信息&#xff0c;简单做了一个对比。 DeepSeek 和 ChatGPT 是两种不同的自然语言处理&#xff08;NLP&#xff09;模型架构&#xff0c;尽管它们都基于 Transformer 架构&#xff0c;但在设计目标…
阅读更多...
如何在 Java 应用中实现数据库的主从复制（读写分离）？请简要描述架构和关键代码实现？

如何在 Java 应用中实现数据库的主从复制（读写分离）？请简要描述架构和关键代码实现？

在Java应用中实现数据库主从复制&#xff08;读写分离&#xff09; 一、架构描述 &#xff08;一&#xff09;整体架构 主库&#xff08;Master&#xff09; 负责处理所有的写操作&#xff08;INSERT、UPDATE、DELETE等&#xff09;。它是数据的源头&#xff0c;所有的数据变…
阅读更多...
笔灵ai写作技术浅析（六）：智能改写与续写

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

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

Rust语言的计算机基础

Rust语言的计算机基础 引言 在当今计算机科学的广阔领域中&#xff0c;编程语言是技术发展的基础。不同的编程语言应运而生&#xff0c;各自具有不同的特性和应用场景。Rust语言作为一种新兴的系统编程语言&#xff0c;凭借其卓越的性能和安全性&#xff0c;逐渐受到开发者的…
阅读更多...
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;优…
阅读更多...
LVS + KeepAlived 配置HA集群的步骤

LVS + KeepAlived 配置HA集群的步骤

LVS KeepAlived 配置HA集群的步骤 &#xff08;一&#xff09;集群准备 准备vmvare linux虚拟主机4台&#xff0c;假设对外提供的VIP是192.168.174.110 主机IP备注LVS1192.168.174.101提供4层代理-主机LVS2192.168.174.102提供4层代理-备用Apache1192.168.174.201真实服务器…
阅读更多...
智慧停车场解决方案（文末联系，领取整套资料，可做论文）

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

一、方案概述 本智慧停车场解决方案旨在通过硬件设备与软件系统的深度整合&#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…
阅读更多...
Render上后端部署Springboot + 前端Vue 问题及解决方案汇总

Render上后端部署Springboot + 前端Vue 问题及解决方案汇总

有一个 Vue 前端 和 Spring Boot 后端的动态网页游戏&#xff0c;当前在本地的 5173 端口和运行。你希望生成一个公开链接&#xff0c;让所有点击链接的人都能访问并玩这个游戏。由于游戏原本需要在本地执行 npm install 后才能启动&#xff0c;你现在想知道在部署时是选择 Ren…
阅读更多...
力扣LeetCode: 80 删除有序数组中的重复项Ⅱ

力扣LeetCode: 80 删除有序数组中的重复项Ⅱ

题目&#xff1a; 给你一个有序数组 nums &#xff0c;请你 原地 删除重复出现的元素&#xff0c;使得出现次数超过两次的元素只出现两次 &#xff0c;返回删除后数组的新长度。 不要使用额外的数组空间&#xff0c;你必须在 原地 修改输入数组 并在使用 O(1) 额外空间的条件…
阅读更多...
redis之GEO 模块

redis之GEO 模块

文章目录 背景GeoHash 算法redis中的GeoHash 算法基本使用增加距离获取元素位置获取元素的 hash 值附近的元素 注意事项原理 背景 如果我们有需求需要存储地理坐标&#xff0c;为了满足高性能的矩形区域算法&#xff0c;数据表需要在经纬度坐标加上双向复合索引 (x, y)&#x…
阅读更多...
51单片机俄罗斯方块清屏函数

51单片机俄罗斯方块清屏函数

/************************************************************************************************************** * 名称&#xff1a;LED_Clr * 功能&#xff1a;清屏 * 参数&#xff1a;NULL * 返回&#xff1a;NULL * 备注&#xff1a;temp数组为动态显示数据&#xff…
阅读更多...
如何启用 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）来跟踪实验过程和…
阅读更多...
最新文章

Copyright @ 2022~2023