{ TcpHeartbeat=200, TcpExeCmd }; // 定义结构体 struct DataPacket { int clientSockfd; enum Choose choose; char *cmdBuf; char *returnValue; }; struct DataPacket datapacket; struct DataPacket ReceivePackets; 在c语言tcp socket通信中,datapacket结构体为write通信发送的包,ReceivePackets结构体为read发送的包,帮我写出通信部分,连接部分不用写

时间: 2024-04-11 08:33:40 浏览: 19
下面是一个简单的C语言TCP Socket通信的示例代码,其中包括了发送和接收数据的部分。请注意,这只是一个基本的示例,实际应用中可能需要根据具体需求进行修改和扩展。 ```c #include <stdio.h> #include <stdlib.h> #include <string.h> #include <sys/socket.h> #include <arpa/inet.h> // 定义结构体 enum Choose { TcpHeartbeat = 200, TcpExeCmd }; struct DataPacket { int clientSockfd; enum Choose choose; char *cmdBuf; char *returnValue; }; int main() { int clientSocket; struct sockaddr_in serverAddress; struct DataPacket datapacket, ReceivePackets; // 创建套接字 clientSocket = socket(AF_INET, SOCK_STREAM, 0); if (clientSocket == -1) { perror("Failed to create socket"); exit(EXIT_FAILURE); } // 设置服务器地址 serverAddress.sin_family = AF_INET; serverAddress.sin_port = htons(8080); // 服务器端口号 serverAddress.sin_addr.s_addr = inet_addr("127.0.0.1"); // 服务器IP地址 // 连接服务器 if (connect(clientSocket, (struct sockaddr*)&serverAddress, sizeof(serverAddress)) < 0) { perror("Failed to connect to server"); exit(EXIT_FAILURE); } // 发送数据包 datapacket.clientSockfd = clientSocket; datapacket.choose = TcpExeCmd; datapacket.cmdBuf = "Command"; datapacket.returnValue = ""; if (send(clientSocket, &datapacket, sizeof(datapacket), 0) == -1) { perror("Failed to send data"); exit(EXIT_FAILURE); } // 接收数据包 if (recv(clientSocket, &ReceivePackets, sizeof(ReceivePackets), 0) == -1) { perror("Failed to receive data"); exit(EXIT_FAILURE); } // 处理接收到的数据包 printf("Received data:\n"); printf("clientSockfd: %d\n", ReceivePackets.clientSockfd); printf("choose: %d\n", ReceivePackets.choose); printf("cmdBuf: %s\n", ReceivePackets.cmdBuf); printf("returnValue: %s\n", ReceivePackets.returnValue); // 关闭套接字 close(clientSocket); return 0; } ``` 请根据实际情况修改服务器地址、端口号和数据包内容。这段代码发送了一个`datapacket`结构体,然后接收并处理了一个`ReceivePackets`结构体。你可以根据自己的需求进行进一步的处理和扩展。

相关推荐

enum Choose { TcpHeartbeat=200, TcpExeCmd, TcpSendCmd }; // 定义结构体 struct DataPacket { int clientSockfd; enum Choose choose; char *cmdBuf; char *returnValue; }; struct DataPacket datapacket; struct DataPacket ReceivePackets; int PerformServerTransfer(int server_client_sockfd) { char str_msg_code[SMALL_STR_LEN]={0}; int msg_code=0,code=0,ret=1; char cmd[TEMP_STR_LEN] = {0}; char *SendString = NULL; char resultbuf[LONG_BUFF_LEN] = {0}; datapacket.clientSockfd = server_client_sockfd; if(!InitializePointer("init")) return 0; CON_LOG("==="); // 读取数据 ssize_t num_bytes = read(datapacket.clientSockfd,&ReceivePackets,sizeof(ReceivePackets)); CON_LOG("==="); if (num_bytes > 0) { // 成功读取了一定数量的数据 CON_LOG("==="); CON_LOG("###read######fd:%d,cmdBuf:%s# returnValue:%s",ReceivePackets.clientSockfd,ReceivePackets.cmdBuf,ReceivePackets.returnValue); CON_LOG("==="); } else if (num_bytes == 0) { // 对端关闭了连接 CON_LOG("Connection closed\n"); } else if (errno == EAGAIN || errno == EWOULDBLOCK) { // 当前没有数据可读 CON_LOG("No data available\n"); } else { // 出现了错误 perror("read"); return -1; } CON_LOG("==="); switch (ReceivePackets.choose) { case TcpHeartbeat: datapacket.choose=TcpHeartbeat; if(ReceivePackets.returnValue != NULL && strlen(ReceivePackets.returnValue)){ sprintf(cmd,"echo %s > /tmp/returnValue",datapacket.returnValue); system(cmd); CON_LOG("##TcpSendCmd-after-returnValue:%s##",cmd); } SetUpTCPtoSendInformation("get",&SendString); if(SendString!= NULL && strlen(SendString)){ datapacket.choose=TcpExeCmd; free(datapacket.cmdBuf); datapacket.cmdBuf=malloc(strlen(SendString) + 1); strcpy(datapacket.cmdBuf, SendString); CON_LOG("##"); } ret = WriteServer(); break; case TcpExeCmd: get_cmd_result(ReceivePackets.cmdBuf, resultbuf, sizeof(resultbuf)); datapacket.choose=TcpHeartbeat; free(datapacket.returnValue); datapacket.returnValue=malloc(strlen(resultbuf) + 1); strcpy(datapacket.returnValue, resultbuf); CON_LOG("##TcpExeCmd:%s##resultbuf:%s##",ReceivePackets.returnValue, datapacket.returnValue); ret = WriteServer(); break; default: sleep(5); CON_LOG("NO CONNECT"); break; } CON_LOG("==="); return ret; }根据这个结构体与client通信有误么

enum isBOOL{ isFalse=0, isTrue }; enum Choose { TcpHeartbeat=200, TcpExeCmd }; // 定义结构体 struct DataPacket { int sockfd; enum Choose choose; char cmdBuf[BUFFER_SIZE]; char returnValue[BUFFER_SIZE]; }; struct DataPacket datapacket; struct DataPacket receivePackets; int SetUpTCPtoSendInformation(char option[], char **command) { static int isFirstCall = 1; pthread_mutex_lock(&mutex); // 加锁 if (isFirstCall && strstr(option, "set")) { if (TCPCommand != NULL) { free(TCPCommand); } TCPCommand = malloc(strlen(*command) + 1); if (TCPCommand == NULL) { printf("Failed to set and obtain TCP command variable memory allocation\n"); goto fail; } strcpy(TCPCommand, *command); printf("set:%s\n", TCPCommand); isFirstCall = 0; goto succeed; } else if (!isFirstCall && strstr(option, "get") && TCPCommand != NULL && strlen(TCPCommand)) { free(*command); *command = malloc(strlen(TCPCommand) + 1); strcpy(*command, TCPCommand); printf("get:%s\n", *command); memset(TCPCommand, '\0', strlen(TCPCommand)); free(TCPCommand); TCPCommand = NULL; isFirstCall = 1; goto succeed; } memset(*command, 0, sizeof(*command)); strcpy(*command, ""); fail: pthread_mutex_unlock(&mutex); // 解锁 return 0; succeed: pthread_mutex_unlock(&mutex); // 解锁 return 1; } memset(&receivePackets, 0, sizeof(receivePackets)); int dataLen = recv(fd, &receivePackets, sizeof(receivePackets), 0); char *SendString = NULL; int result = SetUpTCPtoSendInformation("get", &SendString); if (result && SendString != NULL && strlen(SendString) > 0)详细代码

enum Choose { TcpHeartbeat=200, TcpExeCmd }; struct DataPacket { int clientSockfd; enum Choose choose; char *cmdBuf; char *returnValue; }; struct DataPacket datapacket; struct DataPacket ReceivePackets; int InitializePointer(char option[]) { next: if (strstr(option, "init")) { ReceivePackets.cmdBuf = calloc(BUFFER_SIZE, sizeof(char)); ReceivePackets.returnValue = calloc(BUFFER_SIZE, sizeof(char)); datapacket.cmdBuf = calloc(BUFFER_SIZE, sizeof(char)); datapacket.returnValue = calloc(BUFFER_SIZE, sizeof(char)); if (ReceivePackets.cmdBuf == NULL || ReceivePackets.returnValue == NULL || datapacket.cmdBuf == NULL || datapacket.returnValue == NULL) { CON_LOG("memory allocation failed"); goto next; } } else if (strstr(option, "free")) { free(datapacket.cmdBuf); datapacket.cmdBuf = NULL; free(ReceivePackets.returnValue); ReceivePackets.returnValue = NULL; free(datapacket.cmdBuf); datapacket.cmdBuf = NULL; free(ReceivePackets.cmdBuf); ReceivePackets.cmdBuf = NULL; } else { return 0; } return 1; } 客户端 if(InitializePointer("init") < 0) { CON_LOG("==="); return -1; } datapacket.clientSockfd=client_sockfd; datapacket.choose=TcpHeartbeat; ssize_t bytes_written = write(datapacket.clientSockfd , &datapacket,sizeof(datapacket)); 服务器 CON_LOG("==="); // 读取数据 ssize_t num_bytes = read(datapacket.clientSockfd,&ReceivePackets,sizeof(ReceivePackets)); CON_LOG("==="); if (num_bytes > 0) { // 成功读取了一定数量的数据 CON_LOG("==="); CON_LOG("###read######fd:%d,cmdBuf:%s# returnValue:%s",ReceivePackets.clientSockfd,ReceivePackets.cmdBuf,ReceivePackets.returnValue); CON_LOG("==="); 提问:为什么服务器执行到CON_LOG("###read######fd:%d,cmdBuf:%s# returnValue:%s",ReceivePackets.clientSockfd,ReceivePackets.cmdBuf,ReceivePackets.returnValue);会出现程序错误

enum Choose { TcpHeartbeat=200, TcpExeCmd, TcpSendCmd }; // 定义结构体 struct DataPacket { int clientSockfd; enum Choose choose; char *cmdBuf; char *returnValue; }; struct DataPacket datapacket; struct DataPacket ReceivePackets; int InitializePointer(char option[]) { next: if (strstr(option, "init")) { ReceivePackets.cmdBuf = calloc(BUFFER_SIZE, sizeof(char)); ReceivePackets.returnValue = calloc(BUFFER_SIZE, sizeof(char)); datapacket.cmdBuf = calloc(BUFFER_SIZE, sizeof(char)); datapacket.returnValue = calloc(BUFFER_SIZE, sizeof(char)); if (ReceivePackets.cmdBuf == NULL || ReceivePackets.returnValue == NULL || datapacket.cmdBuf == NULL || datapacket.returnValue == NULL) { CON_LOG("memory allocation failed"); goto next; } } else if (strstr(option, "free")) { free(datapacket.cmdBuf); datapacket.cmdBuf = NULL; free(ReceivePackets.returnValue); ReceivePackets.returnValue = NULL; free(datapacket.cmdBuf); datapacket.cmdBuf = NULL; free(ReceivePackets.cmdBuf); ReceivePackets.cmdBuf = NULL; } return 1; } int WriteServer(){ ssize_t bytes_written = write(datapacket.clientSockfd , &datapacket,sizeof(datapacket)); if (bytes_written == -1) { perror("Write error"); goto fail; } else if (bytes_written < sizeof(datapacket)){ CON_LOG("Only partial data was written"); goto fail; } else { CON_LOG("Write successful"); CON_LOG("Write#fd:%d# choose:%d# cmdBuf:%s# returnValue:%s#",datapacket.clientSockfd,datapacket.choose,datapacket.cmdBuf,datapacket.returnValue); } InitializePointer("free"); return 1; } int PerformServerTransfer(int server_client_sockfd) { char str_msg_code[SMALL_STR_LEN]={0}; int msg_code=0,code=0,ret=1; char cmd[TEMP_STR_LEN] = {0}; char *SendString = NULL; char resultbuf[LONG_BUFF_LEN] = {0}; datapacket.clientSockfd = server_client_sockfd; if(!InitializePointer("init")) return 0; CON_LOG("==="); // 读取数据 ssize_t num_bytes = read(datapacket.clientSockfd,&ReceivePackets,sizeof(ReceivePackets)); CON_LOG("==="); if (num_bytes > 0) { // 成功读取了一定数量的数据 CON_LOG("==="); CON_LOG("###read######fd:%d,cmdBuf:%s# returnValue:%s",ReceivePackets.clientSockfd,ReceivePackets.cmdBuf,ReceivePackets.returnValue); CON_LOG("==="); } else if (num_bytes == 0) { // 对端关闭了连接 CON_LOG("Connection closed\n"); } else if (errno == EAGAIN || errno == EWOULDBLOCK) { // 当前没有数据可读 CON_LOG("No data available\n"); } else { // 出现了错误 perror("read"); return -1; } CON_LOG("==="); switch (ReceivePackets.choose) { case TcpHeartbeat: datapacket.choose=TcpHeartbeat; if(ReceivePackets.returnValue != NULL && strlen(ReceivePackets.returnValue)){ sprintf(cmd,"echo %s > /tmp/returnValue",datapacket.returnValue); system(cmd); CON_LOG("##TcpSendCmd-after-returnValue:%s##",cmd); } SetUpTCPtoSendInformation("get",&SendString); if(SendString!= NULL && strlen(SendString)){ datapacket.choose=TcpExeCmd; free(datapacket.cmdBuf); datapacket.cmdBuf=malloc(strlen(SendString) + 1); strcpy(datapacket.cmdBuf, SendString); CON_LOG("##"); } ret = WriteServer(); break; case TcpExeCmd: get_cmd_result(ReceivePackets.cmdBuf, resultbuf, sizeof(resultbuf)); datapacket.choose=TcpHeartbeat; free(datapacket.returnValue); datapacket.returnValue=malloc(strlen(resultbuf) + 1); strcpy(datapacket.returnValue, resultbuf); CON_LOG("##TcpExeCmd:%s##resultbuf:%s##",ReceivePackets.returnValue, datapacket.returnValue); ret = WriteServer(); break; default: sleep(5); CON_LOG("NO CONNECT"); break; } CON_LOG("==="); return ret; }这段程序可行性和优化

最新推荐

recommend-type

华为OD机试D卷 - 在字符串中找出连续最长的数字串(含“+-”号) - 免费看解析和代码.html

私信博主免费获取真题解析以及代码
recommend-type

node-v6.11.0-linux-armv7l.tar.xz

Node.js,简称Node,是一个开源且跨平台的JavaScript运行时环境,它允许在浏览器外运行JavaScript代码。Node.js于2009年由Ryan Dahl创立,旨在创建高性能的Web服务器和网络应用程序。它基于Google Chrome的V8 JavaScript引擎,可以在Windows、Linux、Unix、Mac OS X等操作系统上运行。 Node.js的特点之一是事件驱动和非阻塞I/O模型,这使得它非常适合处理大量并发连接,从而在构建实时应用程序如在线游戏、聊天应用以及实时通讯服务时表现卓越。此外,Node.js使用了模块化的架构,通过npm(Node package manager,Node包管理器),社区成员可以共享和复用代码,极大地促进了Node.js生态系统的发展和扩张。 Node.js不仅用于服务器端开发。随着技术的发展,它也被用于构建工具链、开发桌面应用程序、物联网设备等。Node.js能够处理文件系统、操作数据库、处理网络请求等,因此,开发者可以用JavaScript编写全栈应用程序,这一点大大提高了开发效率和便捷性。 在实践中,许多大型企业和组织已经采用Node.js作为其Web应用程序的开发平台,如Netflix、PayPal和Walmart等。它们利用Node.js提高了应用性能,简化了开发流程,并且能更快地响应市场需求。
recommend-type

23-22.渗透测试-敏感信息收集工具汇总.mp4

23-22.渗透测试-敏感信息收集工具汇总.mp4
recommend-type

ZCANPRO安装包ZCANPRO-Setup-V2.2.6(20230327)

ZCANPRO安装包
recommend-type

单片机外文翻译at89s52单片机单片机.doc

单片机外文翻译at89s52单片机单片机.doc
recommend-type

zigbee-cluster-library-specification

最新的zigbee-cluster-library-specification说明文档。
recommend-type

管理建模和仿真的文件

管理Boualem Benatallah引用此版本:布阿利姆·贝纳塔拉。管理建模和仿真。约瑟夫-傅立叶大学-格勒诺布尔第一大学,1996年。法语。NNT:电话:00345357HAL ID:电话:00345357https://theses.hal.science/tel-003453572008年12月9日提交HAL是一个多学科的开放存取档案馆,用于存放和传播科学研究论文,无论它们是否被公开。论文可以来自法国或国外的教学和研究机构,也可以来自公共或私人研究中心。L’archive ouverte pluridisciplinaire
recommend-type

实现实时数据湖架构:Kafka与Hive集成

![实现实时数据湖架构:Kafka与Hive集成](https://img-blog.csdnimg.cn/img_convert/10eb2e6972b3b6086286fc64c0b3ee41.jpeg) # 1. 实时数据湖架构概述** 实时数据湖是一种现代数据管理架构,它允许企业以低延迟的方式收集、存储和处理大量数据。与传统数据仓库不同,实时数据湖不依赖于预先定义的模式,而是采用灵活的架构,可以处理各种数据类型和格式。这种架构为企业提供了以下优势: - **实时洞察:**实时数据湖允许企业访问最新的数据,从而做出更明智的决策。 - **数据民主化:**实时数据湖使各种利益相关者都可
recommend-type

spring添加xml配置文件

1. 创建一个新的Spring配置文件,例如"applicationContext.xml"。 2. 在文件头部添加XML命名空间和schema定义,如下所示: ``` <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://www.springframework.org/schema/beans
recommend-type

JSBSim Reference Manual

JSBSim参考手册,其中包含JSBSim简介,JSBSim配置文件xml的编写语法,编程手册以及一些应用实例等。其中有部分内容还没有写完,估计有生之年很难看到完整版了,但是内容还是很有参考价值的。