智能家居系统代码示例

服务器代码 (C 语言)

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <sqlite3.h>

#define MAX_BUFFER_SIZE 1024

// 数据库文件路径
#define DB_FILE 'database.db'

// 数据库回调函数
int db_callback(void *data, int argc, char **argv, char **azColName) {
    // 处理查询结果
    // 这里可以根据需要进行逻辑处理，比如将查询结果存储到全局变量中等
    return 0;
}

int main() {
    int server_fd, client_fd;
    struct sockaddr_in server_addr, client_addr;
    socklen_t client_addr_len;
    char buffer[MAX_BUFFER_SIZE];

    // 创建服务器socket
    server_fd = socket(AF_INET, SOCK_STREAM, 0);
    if (server_fd == -1) {
        perror('Failed to create socket');
        exit(EXIT_FAILURE);
    }

    // 设置服务器地址和端口
    server_addr.sin_family = AF_INET;
    server_addr.sin_addr.s_addr = INADDR_ANY;
    server_addr.sin_port = htons(8888);

    // 绑定服务器地址和端口
    if (bind(server_fd, (struct sockaddr *)&server_addr, sizeof(server_addr)) == -1) {
        perror('Failed to bind');
        exit(EXIT_FAILURE);
    }

    // 监听连接请求
    if (listen(server_fd, 1) == -1) {
        perror('Failed to listen');
        exit(EXIT_FAILURE);
    }

    printf('Server started, waiting for client...
');

    while (1) {
        // 接受客户端连接
        client_addr_len = sizeof(client_addr);
        client_fd = accept(server_fd, (struct sockaddr *)&client_addr, &client_addr_len);
        if (client_fd == -1) {
            perror('Failed to accept');
            exit(EXIT_FAILURE);
        }

        printf('Client connected: %s:%d
', inet_ntoa(client_addr.sin_addr), ntohs(client_addr.sin_port));

        // 接收客户端发送的数据
        ssize_t num_bytes = recv(client_fd, buffer, sizeof(buffer), 0);
        if (num_bytes == -1) {
            perror('Failed to receive data');
            exit(EXIT_FAILURE);
        }

        // 解析客户端发送的数据
        int userid = atoi(buffer);

        // 连接数据库
        sqlite3 *db;
        int rc = sqlite3_open(DB_FILE, &db);
        if (rc != SQLITE_OK) {
            fprintf(stderr, 'Failed to open database: %s
', sqlite3_errmsg(db));
            exit(EXIT_FAILURE);
        }

        // 查询数据库
        char sql[100];
        snprintf(sql, sizeof(sql), 'SELECT device_name, value FROM Status WHERE uid = %d', userid);
        rc = sqlite3_exec(db, sql, db_callback, NULL, NULL);
        if (rc != SQLITE_OK) {
            fprintf(stderr, 'Failed to execute query: %s
', sqlite3_errmsg(db));
            exit(EXIT_FAILURE);
        }

        // 处理查询结果并发送建议给客户端
        // 这里可以根据查询结果进行逻辑处理，比如判断温度和湿度是否符合条件，然后发送相应的建议给客户端

        // 关闭数据库连接
        sqlite3_close(db);

        // 发送建议给客户端
        char suggestion[MAX_BUFFER_SIZE] = '空调温度过低，建议提高温度至26℃；加湿器湿度过高或过低，建议调整加湿器湿度';
        send(client_fd, suggestion, strlen(suggestion), 0);

        // 关闭客户端连接
        close(client_fd);
    }

    // 关闭服务器socket
    close(server_fd);

    return 0;
}

客户端代码 (QT C++)

client.h

#ifndef CLIENT_H
#define CLIENT_H

#include <QtWidgets>
#include <QTcpSocket>

class Client : public QWidget {
    Q_OBJECT

public:
    Client(QWidget *parent = nullptr);

private slots:
    void connectToServer();

private:
    QTextEdit *textEdit;
};

#endif // CLIENT_H

client.cpp

#include 'client.h'

Client::Client(QWidget *parent) : QWidget(parent) {
    // 创建界面元素
    QPushButton *button = new QPushButton('Connect', this);
    textEdit = new QTextEdit(this);

    // 连接按钮点击事件
    connect(button, &QPushButton::clicked, this, &Client::connectToServer);

    // 创建布局
    QVBoxLayout *layout = new QVBoxLayout;
    layout->addWidget(button);
    layout->addWidget(textEdit);

    // 设置布局
    setLayout(layout);
}

void Client::connectToServer() {
    // 创建socket
    QTcpSocket socket;

    // 连接服务器
    socket.connectToHost('127.0.0.1', 8888);

    // 等待连接成功
    if (!socket.waitForConnected()) {
        textEdit->setText('Failed to connect to server');
        return;
    }

    // 发送userid给服务器
    QString userid = '123'; // 这里替换为实际的userid
    socket.write(userid.toUtf8());

    // 等待服务器发送建议
    if (!socket.waitForReadyRead()) {
        textEdit->setText('Failed to receive suggestion');
        return;
    }

    // 接收服务器发送的建议
    QString suggestion = socket.readAll();

    // 在界面上显示建议
    textEdit->setText(suggestion);
}

运行

1. 确保已安装 SQLite3 库和 QT 开发环境。
2. 运行服务器代码。
3. 运行客户端代码。
4. 点击客户端的 'Connect' 按钮连接服务器。
5. 服务器会根据用户 ID 从数据库获取信息并发送建议给客户端，客户端会将建议显示在文本框中。

说明

• 代码示例仅供参考，需要根据实际需求进行修改和完善。
• 服务器代码中使用了 SQLite3 数据库，需要确保已安装 SQLite3 库。
• 客户端代码使用了 QT 库，需要确保已安装 QT 开发环境。
• 客户端代码中发送的 userid 为 '123'，需要根据实际情况进行修改。
• 服务器代码中发送的建议信息需要根据实际情况进行修改。
• 代码示例中没有进行错误处理，需要在实际开发中进行完善。

其他

• 可以使用其他数据库，例如 MySQL 或 PostgreSQL。
• 可以使用其他 UI 库，例如 wxWidgets 或 GTK+。
• 可以根据需要进行功能扩展，例如添加更多设备类型、添加用户管理功能等。