智能家居系统：基于Qt的客户端与服务器通信

"#ifndef PROCESSION_H\n#define PROCESSION_H\n\n#include ""\n#include ""\n#include ""\n#include ""\n#include ""\n\nnamespace Ui {\nclass Procession;\n}\n\nclass Procession : public QWidget\n{\n Q_OBJECT\n\npublic:\n explicit Procession(int userid,QWidget *parent = nullptr);\n ~Procession();\n void processionWidget();\n\nprivate slots:\n void connected();\n void readyRead();\n void displayError(QAbstractSocket::SocketError error);\n void on_connectBtn_clicked();\n\nprivate:\n Ui::Procession ui;\n int userid;\n QTcpSocket m_socket;\n};\n\n#endif // PROCESSION_H\n#include "procession.h"\n#include "ui_procession.h"\n#include ""\n#include ""\n\nProcession::Procession(int userid,QWidget *parent) :\n QWidget(parent),\n ui(new Ui::Procession),\n userid(userid)\n{\n ui->setupUi(this);\n processionWidget();\n m_socket = new QTcpSocket(this);\n\n connect(m_socket, &QTcpSocket::readyRead, this, &Procession::readyRead);\n connect(m_socket, &QTcpSocket::connected, this, &Procession::connected);\n\n connect(m_socket, QOverloadQAbstractSocket::SocketError::of(&QTcpSocket::error), this, &Procession::displayError);\n}\n\nProcession::~Procession()\n{\n delete ui;\n // 在程序结束前关闭套接字\n m_socket->close();\n}\n\nvoid Procession::processionWidget()\n{\n setWindowTitle("服务器通信");\n setAutoFillBackground(true);\n QPalette palette=this->palette();\n QPixmap pixmap(":/user/image/image/net.jpg");\n palette.setBrush(QPalette::Window, QBrush(pixmap));\n setPalette(palette);\n setFixedSize(600,400);\n}\n\n\nvoid Procession::connected()\n{\n ui->message->append("连接成功");\n QByteArray block;\n QDataStream out(&block, QIODevice::WriteOnly);\n out << static_cast(this->userid);\n qDebug()<<static_cast(this->userid);\n if (m_socket->write(block) == -1) {\n ui->message->append("发送userid失败");\n m_socket->close();\n }\n}\n\n\n\nvoid Procession::readyRead()\n{\n QByteArray data = m_socket->readAll();\n if (data.isEmpty()) {\n ui->message->append("读取的数据为空");\n return;\n }\n /// 解析服务器返回的数据\n QString suggestion = QString::fromUtf8(data);\n ui->message->append(suggestion);\n}\n\n\nvoid Procession::displayError(QAbstractSocket::SocketError error)\n{\n QString errorMessage;\n switch (error) {\n case QAbstractSocket::ConnectionRefusedError:\n errorMessage = "连接被拒绝";\n break;\n case QAbstractSocket::HostNotFoundError:\n errorMessage = "未找到主机";\n break;\n case QAbstractSocket::SocketTimeoutError:\n errorMessage = "连接超时";\n break;\n case QAbstractSocket::NetworkError:\n errorMessage = "网络错误";\n break;\n default:\n errorMessage = "未知错误";\n break;\n }\n ui->message->append(errorMessage);\n}\n\nvoid Procession::on_connectBtn_clicked()\n{\n if (m_socket->state() == QAbstractSocket::ConnectedState) {\n m_socket->disconnectFromHost(); // 先关闭套接字\n }\n\n QString ip = ui->IP->text();\n QString port = ui->port->text();\n\n if (ip.isEmpty() || port.isEmpty()) {\n ui->message->clear();\n ui->message->append("请输入有效的IP地址和端口号");\n return;\n }\n\n ui->message->clear();\n ui->message->append("正在连接中...");\n m_socket->connectToHost(ip, static_cast(ui->port->text().toInt()));\n}\n\n服务器端 \n#include "<stdio.h>"\n#include "<stdlib.h>"\n#include "server.h"\n\nint main() {\n startServer();\n return 0;\n}\n \n#ifndef SERVER_H\n#define SERVER_H\n\n#include "<netinet/in.h>"\n#include "<sqlite3.h>"\n\n\ntypedef struct {\n int uid;\n char device_name[20];\n char device_state[20];\n char value[20];\n char mode[20];\n} Status;\n\ntypedef struct {\n int sockfd;\n struct sockaddr_in client_addr;\n socklen_t client_addr_len;\n sqlite3 *db;\n} ServerContext;\n\nvoid startServer(); // 启动服务器\nint createSocket(); // 创建套接字\nvoid bindSocket(int sockfd, struct sockaddr_in server_addr); // 绑定套接字\nvoid listenSocket(int sockfd); // 监听套接字\nsqlite3 openDatabase(); // 打开数据库连接\nvoid closeSocket(int sockfd); // 关闭套接字\nvoid closeDatabase(sqlite3 *db); // 关闭数据库连接\nvoid sig_handler(int signo) ;//信号处理函数\n\n#endif\n#include "<stdio.h>"\n#include "<stdlib.h>"\n#include "<sys/socket.h>"\n#include "<unistd.h>"\n#include "<arpa/inet.h>"\n#include "<netinet/in.h>"\n#include "<sqlite3.h>"\n#include "<signal.h>"\n#include "server.h"\n#include "handle.h"\n\nint createSocket() {\n int sockfd = socket(AF_INET, SOCK_STREAM, 0);\n if (sockfd == -1) {\n perror("连接失败\nsocket");\n exit(1);\n }\n return sockfd;\n}\n\nvoid bindSocket(int sockfd, struct sockaddr_in *server_addr) {\n if (bind(sockfd, (struct sockaddr *)server_addr, sizeof(server_addr)) == -1) {\n perror("连接失败\nbind");\n close(sockfd);\n exit(1);\n }\n}\n\nvoid listenSocket(int sockfd) {\n if (listen(sockfd, 5) == -1) {\n perror("连接失败\nlisten");\n close(sockfd);\n exit(1);\n }\n}\n\nvoid closeSocket(int sockfd) {\n if (close(sockfd) == -1) {\n perror("套接字关闭失败\nclose");\n exit(1);\n }\n}\n\nsqlite3 openDatabase() {\n sqlite3 *db;\n int rc = sqlite3_open("/mnt/g/Qt/Client/Smarthome_Client/database/database.db", &db);//根据实际数据库路径进行更改，此路径挂载G盘共享文件夹\n if (rc != SQLITE_OK) {\n fprintf(stderr, "数据库打开失败: %s\n", sqlite3_errmsg(db));\n exit(1);\n }\n return db;\n}\n\nvoid closeDatabase(sqlite3 *db) {\n if (sqlite3_close(db) != SQLITE_OK) {\n fprintf(stderr, "数据库关闭失败: %s\n", sqlite3_errmsg(db));\n exit(1);\n }\n}\n\nvoid sig_handler(int signo) {\n if (signo == SIGTSTP) {\n printf("服务器登出\n");\n exit(-1);\n }\n}\n\nvoid startServer() {\n printf("正在连接中...\n");\n // 注册信号处理函数\n signal(SIGTSTP, sig_handler);\n int sockfd = createSocket();\n\n struct sockaddr_in server_addr;\n server_addr.sin_family = AF_INET;\n server_addr.sin_addr.s_addr = inet_addr("172.21.91.176");\n server_addr.sin_port = htons(12345);\n\n bindSocket(sockfd, &server_addr);\n listenSocket(sockfd);\n\n sqlite3 *db = openDatabase();\n\n ServerContext context;\n context.sockfd = sockfd;\n context.client_addr_len = sizeof(context.client_addr);\n context.db = db;\n\n handleClientRequests(&context, sockfd);\n\n closeSocket(sockfd);\n closeDatabase(db);\n}\n#ifndef HANDLE_H\n#define HANDLE_H\n\n#include "<string.h>"\n#include "<stdlib.h>"\n#include "<sys/socket.h>"\n#include "<netinet/in.h>"\n#include "<sqlite3.h>"\n#include "server.h"\n#define MAX_BUFFER_SIZE 1024\n\nvoid handleClientRequests(ServerContext *context,int sockfd);// 处理客户端请求\nvoid handleClientRequest(ServerContext context);// 处理单个客户端请求\nint receiveUserId(int sockfd);// 接收客户端发送的userid\nsqlite3_stmt prepareStatement(sqlite3 *db, int userid); // 准备数据库查询语句\nvoid initializeStatus(Status *status);// 初始化设备状态\nvoid updateAcStatus(Status *acStatus, int uid, const unsigned char *device_state, const unsigned char *value) ;// 更新设备状态\nvoid generateAcSuggestion(const Status *acStatus, char *suggestion);// 生成空调建议\nvoid generateHumidifierSuggestion(const Status *humidifierStatus, char suggestion);//生成加湿器建议\nchar combineSuggestions(const char *suggestion, const char *humidifierSuggestion); // 合并建议\nvoid sendSuggestion(int sockfd,char suggestion) ;// 发送建议\n\n#endif\n#include "<stdio.h>"\n#include "<unistd.h>"\n#include "<sys/socket.h>"\n#include "<arpa/inet.h>"\n#include "handle.h"\n\nint receiveUserId(int sockfd) {\n int userid;\n ssize_t recvSize = recv(sockfd, &userid, sizeof(int), 0);\n if (recvSize == -1 || recvSize == 0 || recvSize != sizeof(int)) {\n perror("接收userid失败");\n return -1;\n }\n return ntohl(userid);\n}\n\nsqlite3_stmt prepareStatement(sqlite3 *db, int userid) {\n char sql[100];\n snprintf(sql, sizeof(sql), "SELECT * FROM Status WHERE uid = %d", userid);\n sqlite3_stmt *stmt = NULL;\n int rc = sqlite3_prepare_v2(db, sql, -1, &stmt, NULL);\n if (rc != SQLITE_OK) {\n fprintf(stderr, "无法执行的语句: %s\n", sqlite3_errmsg(db));\n return NULL;\n }\n return stmt;\n}\n\nvoid initializeStatus(Status *status) {\n memset(status, 0, sizeof(Status));\n status->uid = 0;\n status->device_name[0] = '\0';\n}\n\nvoid updateAcStatus(Status *acStatus, int uid, const unsigned char *device_state, const unsigned char *value) {\n acStatus->uid = uid;\n strncpy(acStatus->device_state, device_state, sizeof(acStatus->device_state) - 1);\n acStatus->device_state[sizeof(acStatus->device_state) - 1] = '\0';\n strncpy(acStatus->value, value, sizeof(acStatus->value) - 1);\n acStatus->value[sizeof(acStatus->value) - 1] = '\0';\n\n}\n\nvoid generateAcSuggestion(const Status *acStatus, char *suggestion) {\n int temperature = atoi(acStatus->value);\n \n if (temperature < 24) {\n snprintf(suggestion, MAX_BUFFER_SIZE, "空调温度过低，建议提高温度至26℃");\n } else if(temperature>35){\n snprintf(suggestion, MAX_BUFFER_SIZE, "空调温度过高，建议降低温度至26℃");\n }\n else{\n snprintf(suggestion, MAX_BUFFER_SIZE, "空调温度适宜");\n }\n}\n\nvoid generateHumidifierSuggestion(const Status *humidifierStatus, char suggestion) {\n int humidity = atoi(humidifierStatus->value);\n if (humidity < 40) {\n snprintf(suggestion, MAX_BUFFER_SIZE, "加湿器湿度过低，建议调整加湿器湿度");\n } else if (humidity > 70) {\n snprintf(suggestion, MAX_BUFFER_SIZE, "加湿器湿度过高，建议调整加湿器湿度");\n } else {\n snprintf(suggestion, MAX_BUFFER_SIZE, "加湿器湿度适宜");\n }\n}\n\nchar combineSuggestions(const char *suggestion, const char *humidifierSuggestion) {\n int combinedSuggestionSize = strlen(suggestion) + strlen(humidifierSuggestion) + 2;\n char *combinedSuggestion = malloc(combinedSuggestionSize);\n snprintf(combinedSuggestion, combinedSuggestionSize, "%s\n%s", suggestion, humidifierSuggestion);\n return combinedSuggestion;\n}\n\nvoid sendSuggestion(int sockfd, char *suggestion) {\n ssize_t sendSize = send(sockfd, suggestion, strlen(suggestion)+1, 0);\n if (sendSize == -1) {\n perror("发送失败\nsend");\n free(suggestion);\n return;\n } else {\n printf("建议已发送\n");\n }\n}\n\nvoid handleClientRequest(ServerContext *context) {\n int userid = receiveUserId(context->sockfd);\n if (userid == -1) {\n perror("接收userid失败");\n return;\n }\n\n printf("客户端已连接\n");\n printf("userid:%d\n", userid);\n\n sqlite3_stmt *stmt = prepareStatement(context->db, userid);\n if (stmt == NULL) {\n fprintf(stderr, "无法执行的语句: %s\n", sqlite3_errmsg(context->db));\n return;\n }\n\n Status acStatus, humidifierStatus;\n initializeStatus(&acStatus);\n initializeStatus(&humidifierStatus);\n\n char suggestion[MAX_BUFFER_SIZE] = "";\n char humidifierSuggestion[MAX_BUFFER_SIZE] = "";\n\n int acOpened = 0;\n int humidifierOpened = 0;\n\n while (sqlite3_step(stmt) == SQLITE_ROW) {\n int uid = sqlite3_column_int(stmt, 1);\n const unsigned char *device_name = sqlite3_column_text(stmt, 2);\n const unsigned char *device_state = sqlite3_column_text(stmt, 3);\n const unsigned char *value = sqlite3_column_text(stmt, 4);\n\n if (strcmp(device_name, "空调" ) == 0) {\n if (strcmp(device_state, "开启" ) == 0){\n updateAcStatus(&acStatus, uid, device_state, value);\n generateAcSuggestion(&acStatus, suggestion);\n acOpened = 1;\n } else if (strcmp(device_state, "关闭" ) == 0) {\n updateAcStatus(&acStatus, uid, device_state, value);\n // 更新设备状态为关闭\n acOpened = 0;\n }\n } else if (strcmp(device_name, "加湿器" ) == 0) {\n if (strcmp(device_state, "开启" ) == 0){\n updateAcStatus(&humidifierStatus, uid, device_state, value);\n generateHumidifierSuggestion(&humidifierStatus, humidifierSuggestion);\n humidifierOpened = 1;\n } else if (strcmp(device_state, "关闭" ) == 0) {\n updateAcStatus(&humidifierStatus, uid, device_state, value);\n // 更新设备状态为关闭\n humidifierOpened = 0;\n }\n }\n }\n\n sqlite3_finalize(stmt);\n\n if (!acOpened) {\n snprintf(suggestion, MAX_BUFFER_SIZE, "空调未开启");\n }\n\n if (!humidifierOpened) {\n snprintf(humidifierSuggestion, MAX_BUFFER_SIZE, "加湿器未开启");\n }\n\n char *combinedSuggestion = combineSuggestions(suggestion, humidifierSuggestion);\n sendSuggestion(context->sockfd, combinedSuggestion);\n printf("建议为：\n%s\n", combinedSuggestion);\n\n free(combinedSuggestion);\n\n // 关闭连接\n shutdown(context->sockfd, SHUT_RDWR);\n printf("按下Ctrl + Z登出...\n");\n}\n\nvoid handleClientRequests(ServerContext context, int sockfd) {\n fd_set readfds;\n int maxfd = sockfd;\n\n while (1) {\n FD_ZERO(&readfds);\n FD_SET(sockfd, &readfds);\n\n int activity = select(maxfd + 1, &readfds, NULL, NULL, NULL);\n if (activity == -1) {\n perror("select");\n break;\n }\n\n if (FD_ISSET(sockfd, &readfds)) {\n int clientSockfd = accept(sockfd, (struct sockaddr )&context->client_addr, &context->client_addr_len);\n if (clientSockfd == -1) {\n perror("套接字接收失败\naccept");\n break;\n }\n\n context->sockfd = clientSockfd;\n handleClientRequest(context);\n\n close(clientSockfd);\n }\n }\n}\n根据格式写出接口函数说明\n函数名\t文件名\t功能概要\t参数\n类型\t变量名\tI/O\t说明\t\t返回值\t值\n类型\t\t说明\t\t\t详细说明\n使用注意事项内容：startServer\t\tserver.h\t启动服务器\t无\t无\t无\t无\t\t无\t\t无\t\t无\t\t无\t\t无\t\t函数用于启动服务器，创建套接字并绑定端口，监听客户端连接请求，并处理客户端请求。在处理客户端请求时，会从数据库中查询设备状态，并生成相应的建议发送给客户端。需要注意的是，在服务器端运行时，按下Ctrl + Z可以退出服务器。\t\n\ncreateSocket\t\tserver.h\t创建套接字\t无\t无\t无\tint\t无\t返回创建的套接字描述符\t函数用于创建一个新的套接字，如果创建失败则会退出程序。返回创建的套接字描述符。\t\n\nbindSocket\t\tserver.h\t绑定套接字\tint\tsockfd\tI\t套接字描述符\tstruct sockaddr_in\tserver_addr\tI\t服务器地址结构体指针\t无\t无\t函数用于将套接字绑定到特定的IP地址和端口号上。如果绑定失败，则会关闭套接字并退出程序。\t\n\nlistenSocket\t\tserver.h\t监听套接字\tint\tsockfd\tI\t套接字描述符\t无\t无\t无\t函数用于将套接字设置为监听状态，等待客户端的连接请求。如果监听失败，则会关闭套接字并退出程序。\t\n\nopenDatabase\t\tserver.h\t打开数据库连接\t无\t无\t无\tsqlite3\t无\t返回打开的数据库连接指针\t函数用于打开数据库连接，并返回数据库连接指针。如果打开失败，则会打印错误信息并退出程序。\t\n\ncloseSocket\t\tserver.h\t关闭套接字\tint\tsockfd\tI\t套接字描述符\t无\t无\t无\t函数用于关闭套接