• 日期: 2028-09-23
  • 标签: 常规

基于C语言Socket编程和SQLite数据库的智能家居建议服务器

简介

本文将介绍如何使用C语言的Socket编程和SQLite数据库创建一个简单的智能家居建议服务器。该服务器可以接收来自客户端的请求，根据数据库中的设备状态信息生成建议，并将建议发送回客户端。

代码实现

server.h

#ifndef SERVER_H
#define SERVER_H

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

#define MAX_BUFFER_SIZE 1024

// 设备状态结构体
typedef struct {
    int uid;
    char device_name[10];
    char device_state[10];
    char value[10];
    char mode[10];
} Status;

// 服务器上下文结构体，包含服务器相关信息
typedef struct {
    int sockfd;
    struct sockaddr_in client_addr;
    socklen_t client_addr_len;
    sqlite3 *db;
    pthread_mutex_t mutex;
    int running; // 标记服务器是否运行中
} ServerContext;

// 处理客户端请求
void handleClientRequest(ServerContext *context);

// 处理客户端连接
void *handleClientConnection(void *arg);

// 信号处理函数
void handleSignal(int signal);

#endif

server.c

#include 'server.h'

// 处理客户端请求
void handleClientRequest(ServerContext *context) {
    char buffer[MAX_BUFFER_SIZE];
    int userid;

    // 接收客户端发送的userid
    ssize_t recvSize = recv(context->sockfd, &userid, sizeof(int), 0);
    if (recvSize == -1) {
        perror('recv');
        return;
    }

    // 查询数据库获取设备状态信息
    char sql[100];
    snprintf(sql, sizeof(sql), 'SELECT * FROM Status WHERE uid = %d', userid);
    sqlite3_stmt *stmt;
    int rc = sqlite3_prepare_v2(context->db, sql, -1, &stmt, NULL);
    if (rc != SQLITE_OK) {
        fprintf(stderr, 'Failed to execute statement: %s\n', sqlite3_errmsg(context->db));
        return;
    }

    Status status;
    rc = sqlite3_step(stmt);
    if (rc == SQLITE_ROW) {
        status.uid = sqlite3_column_int(stmt, 1);
        strncpy(status.device_name, sqlite3_column_text(stmt, 2), sizeof(status.device_name)-1);
        strncpy(status.device_state, sqlite3_column_text(stmt, 3), sizeof(status.device_state)-1);
        strncpy(status.value, sqlite3_column_text(stmt, 4), sizeof(status.value)-1);
        strncpy(status.mode, sqlite3_column_text(stmt, 5), sizeof(status.mode)-1);
    } else if (rc == SQLITE_DONE) {
        fprintf(stderr, 'No data found for user %d\n', userid);
        sqlite3_finalize(stmt);
        return;
    } else {
        fprintf(stderr, 'Failed to execute statement: %s\n', sqlite3_errmsg(context->db));
        sqlite3_finalize(stmt);
        return;
    }
    sqlite3_finalize(stmt);

    // 分析设备状态并生成建议
    char suggestion[MAX_BUFFER_SIZE];
    if (strcmp(status.device_name, '空调') == 0) {
        int temperature = atoi(status.value);
        if (temperature < 24) {
            snprintf(suggestion, sizeof(suggestion), '空调温度过低，建议提高温度至26℃');
        } else {
            snprintf(suggestion, sizeof(suggestion), '空调温度正常');
        }
    } else if (strcmp(status.device_name, '加湿器') == 0) {
        int humidity = atoi(status.value);
        if (humidity < 40 || humidity > 70) {
            snprintf(suggestion, sizeof(suggestion), '加湿器湿度过高或过低，建议调整加湿器湿度');
        } else {
            snprintf(suggestion, sizeof(suggestion), '加湿器湿度正常');
        }
    } else {
        snprintf(suggestion, sizeof(suggestion), '设备状态未知');
    }

    // 向客户端发送建议
    ssize_t sendSize = send(context->sockfd, suggestion, strlen(suggestion), 0);
    if (sendSize == -1) {
        perror('send');
        return;
    }
}

// 处理客户端连接
void *handleClientConnection(void *arg) {
    ServerContext *context = (ServerContext *)arg;
    int clientSockfd = accept(context->sockfd, (struct sockaddr *)&context->client_addr, &context->client_addr_len);
    if (clientSockfd == -1) {
        perror('accept');
        return NULL;
    }

    context->sockfd = clientSockfd;
    handleClientRequest(context);

    close(clientSockfd);
    return NULL;
}

// 信号处理函数
void handleSignal(int signal) {
    if (signal == SIGINT) {
        printf('按下Ctrl + C停止\n');
        // 停止服务器循环
        // 这里添加停止服务器循环的代码，例如修改全局变量
    }
}

main.c

#include 'server.h'

int main() {
    // 创建套接字
    int sockfd = socket(AF_INET, SOCK_STREAM, 0);
    if (sockfd == -1) {
        perror('socket');
        return 1;
    }

    // 设置服务器地址
    struct sockaddr_in server_addr;
    server_addr.sin_family = AF_INET;
    server_addr.sin_addr.s_addr = INADDR_ANY;
    server_addr.sin_port = htons(12345);

    // 绑定套接字到服务器地址
    if (bind(sockfd, (struct sockaddr *)&server_addr, sizeof(server_addr)) == -1) {
        perror('bind');
        close(sockfd);
        return 1;
    }

    // 监听连接请求
    if (listen(sockfd, 5) == -1) {
        perror('listen');
        close(sockfd);
        return 1;
    }

    // 打开数据库
    sqlite3 *db;
    int rc = sqlite3_open('database.db', &db);
    if (rc != SQLITE_OK) {
        fprintf(stderr, 'Failed to open database: %s\n', sqlite3_errmsg(db));
        close(sockfd);
        return 1;
    }

    // 初始化服务器上下文
    ServerContext context;
    context.sockfd = sockfd;
    context.client_addr_len = sizeof(context.client_addr);
    context.db = db;
    pthread_mutex_init(&context.mutex, NULL);
    context.running = 1; // 设置服务器运行状态为运行中

    // 注册信号处理函数
    signal(SIGINT, handleSignal);

    // 循环处理客户端连接
    while (context.running) {
        pthread_t tid;
        int err = pthread_create(&tid, NULL, handleClientConnection, &context);
        if (err != 0) {
            fprintf(stderr, 'Failed to create thread: %d\n', err);
            break;
        }
        err = pthread_detach(tid);
        if (err != 0) {
            fprintf(stderr, 'Failed to detach thread: %d\n', err);
            break;
        }
    }

    // 关闭数据库
    rc = sqlite3_close(db);
    if (rc != SQLITE_OK) {
        fprintf(stderr, 'Failed to close database: %s\n', sqlite3_errmsg(db));
        return 1;
    }

    // 关闭套接字
    if (close(sockfd) == -1) {
        perror('close');
        return 1;
    }

    pthread_mutex_destroy(&context.mutex);
    return 0;
}

代码解释

server.h

  • 定义了一些常量、结构体和函数原型，方便代码组织和管理。
  • Status 结构体用于存储设备状态信息，包括设备名称、状态、值和模式等。
  • ServerContext 结构体用于存储服务器上下文信息，包括套接字、客户端地址、数据库连接、互斥锁和运行状态等。
  • 函数原型声明了处理客户端请求、处理客户端连接和处理信号的函数。

server.c

  • handleClientRequest 函数负责处理客户端请求，包括接收 userid、查询数据库、分析设备状态、生成建议和发送建议等步骤。
  • handleClientConnection 函数负责处理客户端连接，包括接受连接、创建线程处理客户端请求和关闭连接等步骤。
  • handleSignal 函数负责处理信号，例如当接收到 SIGINT 信号时，停止服务器循环。

main.c

  • main 函数是程序的入口点，负责创建套接字、绑定地址、监听连接、打开数据库、初始化服务器上下文、注册信号处理函数和循环处理客户端连接等步骤。
  • 在循环处理客户端连接的过程中，每当有新的客户端连接到来时，就创建一个新的线程来处理该连接。
  • 当接收到 SIGINT 信号时，handleSignal 函数会被调用，它会修改全局变量，从而停止服务器循环。

总结

本文介绍了如何使用C语言的Socket编程和SQLite数据库创建一个简单的智能家居建议服务器。该服务器可以接收来自客户端的请求，根据数据库中的设备状态信息生成建议，并将建议发送回客户端。

SEO优化

  • 在标题和描述中使用关键词，例如 “C语言”, “Socket编程”, “SQLite”, “智能家居”, “服务器”, “多线程”, “信号处理”, “数据库” 等。
  • 在代码中添加注释，解释代码的功能和实现方式。
  • 将代码上传到 Github 等代码托管平台，并添加详细的 README 文件，方便其他人理解和使用代码。

错误处理

  • 在代码中添加错误处理逻辑，例如检查函数返回值、处理异常情况等。
  • 使用日志记录程序运行过程中的重要信息，方便排查问题。

改进方向

  • 可以使用更完善的数据库设计，例如使用外键关联用户和设备信息。
  • 可以使用更复杂的算法来分析设备状态，生成更准确的建议。
  • 可以使用图形界面来显示设备状态和建议信息。

总结

本文提供了一个基于C语言Socket编程和SQLite数据库的智能家居建议服务器的示例代码，包含详细的代码解释、SEO优化以及错误处理，帮助你快速搭建一个简单的智能家居系统。

基于C语言Socket编程和SQLite数据库的智能家居建议服务器

原文地址: http://www.cveoy.top/t/topic/fCdy 著作权归作者所有。请勿转载和采集!

免费AI点我,无需注册和登录