通过Socket协议发送JSON数据至服务器(C++) - ToB企服应用市场:ToB评测及商务社交产业平台

/*
summary:socket client
author:main
date:2024.08.26
*/
// 引入头文件
#include <iostream> // 引入标准输入输出库，如 cout 等。
#include <stdio.h> // 引入标准输入输出库，如 printf 等。
#include <string.h> // 引入字符串处理库，如 strlen 等。
#include <unistd.h> // 引入 POSIX 标准的 API，如 fork, exec, waitpid 等。
#include <stdlib.h> // 引入标准库，如 exit 等。
#include <netdb.h> // 引入网络地址转换库，如 hostent 等。
#include <sys/socket.h> // 引入 socket API，如 socket, bind, listen, accept 等。
#include <arpa/inet.h> // 引入网络地址转换库，如 inet_addr 等。
#include <sys/types.h> // 引入系统类型定义库，如 pid_t 等。
#include<chrono> // 引入时间库，如 chrono 等。
#include<thread> // 引入线程库，如 thread 等。
using namespace std; // 引入标准命名空间，用于简化代码。
const char *ip_address = "255.255.255.255"; // 服务器IP地址
const char *port = "8080"; // 服务器端口号
/*
@brief 延时函数
@param ms 延时时间，单位为毫秒
@return 无
*/
void delay(int ms)
{
std::this_thread::sleep_for(std::chrono::milliseconds(ms));
}
/*
@brief 创建客户端类
@param ip_address 服务器IP地址
@param port 服务器端口号
@return 无
*/
class SOCKET_CLIENT
{
public:
int sockfd;
int iret; // 定义返回值
/*--------------------------------------创建套接字-------------------------------------------------*/
int sock_create() {
if ((sockfd = socket(AF_INET, SOCK_STREAM, 0)) == -1){ // 如果创建失败返回-1
perror("socket"); // 输出错误信息
return -1;
}
}
/*--------------------------------------连接服务器-------------------------------------------------*/
int sock_connect() {
struct sockaddr_in servaddr; // 初始化服务器地址结构体
memset(&servaddr, 0, sizeof(servaddr)); // 将结构体清零
servaddr.sin_family = AF_INET; // 设置协议族为 IPv4
servaddr.sin_port = htons(atoi(port)); // 设置端口号
servaddr.sin_addr.s_addr = inet_addr(ip_address); // 设置 IP 地址
if (connect(sockfd, (struct sockaddr *)&servaddr, sizeof(servaddr)) != 0) // 如果连接服务器失败返回-1
{
perror("connect"); // 输出错误信息
close(sockfd); // 关闭套接字
return -1;
}
}
/*--------------------------------------发送数据--------------------------------------------------*/
int sock_send(char*msg) {
char buffer[1024]; // 创建缓冲区 - 栈
memset(buffer, 0, sizeof(buffer)); // 清空缓冲区
size_t len = strlen(msg); // 获取消息长度
if (len >= sizeof(buffer))
{
perror("消息长度超过缓冲区大小"); // 输出错误信息
return -1;
}
strncpy(buffer, msg, len); // 将消息复制到缓冲区
buffer[strlen(buffer)] = '\0'; // 添加字符串结束符
if ((iret = send(sockfd, buffer, strlen(buffer), 0)) <= 0) // 发送数据
{
printf("数据发送错误,IRET=%d",iret); // 输出错误信息
return -1;
}
printf("send data is %s\n",buffer); // 打印发送的数据
memset(buffer, 0, sizeof(buffer)); // 清空缓冲区
}
/*--------------------------------------接收数据--------------------------------------------------*/
int sock_recv() {
char buffer[1024]; // 创建缓冲区
memset(buffer, 0, sizeof(buffer)); // 清空缓冲区
if ((iret = recv(sockfd, buffer, sizeof(buffer), 0)) <= 0) // 接收数据
{
printf("数据接受错误,iret=%d",iret); // 打印错误信息
return -1;
}
printf("recv data is %s",buffer); // 打印接收到的数据
memset(buffer, 0, sizeof(buffer)); // 清空缓冲区
return 0;
}
/*--------------------------------------关闭套接字------------------------------------------------*/
void sock_close() {
close(sockfd); // 关闭套接字
}
};
class JSON_DATA
{
public:
string facility_1(char time, char HS, char TEMP, char ATM, char HLux, char LLux){
return "{"
"\'imei\':\'***************\'," // 设备IMEI
"\'time\':\'" + to_string(time) + "\'," // 上报时间
"\'name\':\'WeatherSensors\'," // 气象传感器
"\'data\':{"
"\'HS\':\'" + to_string(HS) + "\'," // 湿度值
"\'TEMP\':\'" + to_string(TEMP) + "\'," // 湿度值
"\'ATM\':\'" + to_string(ATM) + "\'," // 气压值
"\'HLux\':\'" + to_string(HLux) + "\'," // 光照最高值
"\'LLux\':\'" + to_string(LLux) + "\'}" // 光照最低值
"}";
}
string facility_2(char time, char PPM, char TEMP_2, char EC, char PH){
return "{"
"\'imei\':\'***************\'," // 设备IMEI
"\'time\':\'" + to_string(time) + "\'," // 上报时间
"\'name\':\'SoilSensor\'," // 土壤传感器
"\'data\':{"
"\'PPM\':\'" + to_string(PPM) + "\'," // 水分值
"\'TEMP\':\'" + to_string(TEMP_2) + "\'," // 温度值
"\'EC\':\'" + to_string(EC) + "\'," // 导电率
"\'PH\':\'" + to_string(PH) + "\'}" // PH值
"}";
}
string facility_3(char time, char PRCP){
return "{"
"\'imei\':\'***************\'," // 设备IMEI
"\'time\':\'" + to_string(time) + "\'," // 上报时间
"\'name\':\'RainSensor\'," // 雨量传感器
"\'data\':{"
"\'PRCP\':\'" + to_string(PRCP) + "\'}" // 雨量值
"}";
}
};
int main()
{
SOCKET_CLIENT client1; // 创建客户端对象
JSON_DATA json_socket; // 创建JSON数据对象
string json_data; // JSON数据字符串
if (client1.sock_create() == -1) return -1; // 创建套接字
if (client1.sock_connect() == -1) return -1; // 连接服务器
json_data = json_socket.facility_2(time(NULL), 50, 25, 10, 10); // 赋值JSON数据
client1.sock_send((char*)json_data.c_str()); // 发送数据
client1.sock_recv(); // 接收数据
client1.sock_close(); // 关闭套接字
}

复制代码