mqtt json格式 mosquitto发送端发送txt文件中的数据以json格式，订阅端收到后进行解析，发布端收到订阅端以json格式发送的成功接收信息并进行解析

要在Mosquitto发送端将txt文件中的数据以JSON格式发送，并在订阅端进行解析，然后发布端接收订阅端发送的成功接收信息并进行解析，你可以使用C语言中的标准库、Mosquitto库和cJSON库来实现。以下是一个示例代码，演示了如何实现这个功能：

发送端代码：

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <mosquitto.h>
#include <cJSON.h>

#define MQTT_ADDRESS "mqtt.example.com"
#define MQTT_PORT 1883
#define MQTT_TOPIC "data"

// Mosquitto回调函数，用于处理连接成功和连接断开时的事件
void on_connect(struct mosquitto *mosq, void *userdata, int result) {
    if(result == 0) {
        printf("Connected to MQTT broker\n");

        // 读取txt文件数据
        FILE *file = fopen("data.txt", "r");
        if(file == NULL) {
            fprintf(stderr, "Failed to open file\n");
            return;
        }

        // 获取文件大小
        fseek(file, 0, SEEK_END);
        long file_size = ftell(file);
        fseek(file, 0, SEEK_SET);

        // 分配内存并读取文件数据
        char *file_data = (char *)malloc(file_size + 1);
        fread(file_data, 1, file_size, file);
        file_data[file_size] = '\0';

        // 创建JSON对象
        cJSON *json = cJSON_CreateObject();
        cJSON_AddStringToObject(json, "file_content", file_data);

        // 将JSON对象转换为字符串
        char *json_str = cJSON_PrintUnformatted(json);

        // 发布JSON格式消息
        mosquitto_publish(mosq, NULL, MQTT_TOPIC, strlen(json_str), json_str, 0, false);

        // 释放内存
        free(file_data);
        free(json_str);
        cJSON_Delete(json);

        // 关闭文件
        fclose(file);
    } else {
        fprintf(stderr, "Connect failed: %s\n", mosquitto_strerror(result));
    }
}

void on_disconnect(struct mosquitto *mosq, void *userdata, int rc) {
    printf("Disconnected from MQTT broker\n");
}

int main() {
    // 初始化Mosquitto库
    mosquitto_lib_init();

    // 创建Mosquitto客户端实例
    struct mosquitto *mosq = mosquitto_new(NULL, true, NULL);
    if(mosq == NULL) {
        fprintf(stderr, "Failed to create Mosquitto instance\n");
        mosquitto_lib_cleanup();
        return 1;
    }

    // 设置连接和连接断开的回调函数
    mosquitto_connect_callback_set(mosq, on_connect);
    mosquitto_disconnect_callback_set(mosq, on_disconnect);

    // 连接到MQTT代理服务器
    int rc = mosquitto_connect(mosq, MQTT_ADDRESS, MQTT_PORT, 0);
    if(rc != MOSQ_ERR_SUCCESS) {
        fprintf(stderr, "Connect failed: %s\n", mosquitto_strerror(rc));
        mosquitto_destroy(mosq);
        mosquitto_lib_cleanup();
        return 1;
    }

    // 循环处理MQTT事件
    while(mosquitto_loop(mosq, 0, 1) == MOSQ_ERR_SUCCESS) {}

    // 断开连接并释放资源
    mosquitto_disconnect(mosq);
    mosquitto_destroy(mosq);
    mosquitto_lib_cleanup();

    return 0;
}

订阅端代码：

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <mosquitto.h>
#include <cJSON.h>

#define MQTT_ADDRESS "mqtt.example.com"
#define MQTT_PORT 1883
#define MQTT_TOPIC "data"

// Mosquitto回调函数，用于处理连接成功、消息接收和连接断开时的事件
void on_connect(struct mosquitto *mosq, void *userdata, int result) {
    if(result == 0) {
        printf("Connected to MQTT broker\n");
        mosquitto_subscribe(mosq, NULL, MQTT_TOPIC, 0);
    } else {
        fprintf(stderr, "Connect failed: %s\n", mosquitto_strerror(result));
    }
}

void on_message(struct mosquitto *mosq, void *userdata, const struct mosquitto_message *message) {
    if(message->payloadlen > 0) {
        // 解析JSON消息
        cJSON *root = cJSON_Parse(message->payload);
        if(root == NULL) {
            fprintf(stderr, "Failed to parse JSON message\n");
            return;
        }

        // 从JSON中提取数据
        cJSON *file_content = cJSON_GetObjectItem(root, "file_content");
        if(file_content != NULL && file_content->type == cJSON_String) {
            printf("Received file content: %s\n", file_content->valuestring);

            // 创建JSON对象
            cJSON *json = cJSON_CreateObject();
            cJSON_AddStringToObject(json, "status", "success");
            cJSON_AddStringToObject(json, "message", "Received file content");

            // 将JSON对象转换为字符串
            char *json_str = cJSON_PrintUnformatted(json);

            // 发布JSON格式消息
            mosquitto_publish(mosq, NULL, MQTT_TOPIC, strlen(json_str), json_str, 0, false);

            // 释放内存
            free(json_str);
            cJSON_Delete(json);
        }

        // 释放JSON对象
        cJSON_Delete(root);
    }
}

void on_disconnect(struct mosquitto *mosq, void *userdata, int rc) {
    printf("Disconnected from MQTT broker\n");
}

int main() {
    // 初始化Mosquitto库
    mosquitto_lib_init();

    // 创建Mosquitto客户端实例
    struct mosquitto *mosq = mosquitto_new(NULL, true, NULL);
    if(mosq == NULL) {
        fprintf(stderr, "Failed to create Mosquitto instance\n");
        mosquitto_lib_cleanup();
        return 1;
    }

    // 设置连接、消息接收和连接断开的回调函数
    mosquitto_connect_callback_set(mosq, on_connect);
    mosquitto_message_callback_set(mosq, on_message);
    mosquitto_disconnect_callback_set(mosq, on_disconnect);

    // 连接到MQTT代理服务器
    int rc = mosquitto_connect(mosq, MQTT_ADDRESS, MQTT_PORT, 0);
    if(rc != MOSQ_ERR_SUCCESS) {
        fprintf(stderr, "Connect failed: %s\n", mosquitto_strerror(rc));
        mosquitto_destroy(mosq);
        mosquitto_lib_cleanup();
        return 1;
    }

    // 循环处理MQTT事件
    while(mosquitto_loop(mosq, 0, 1) == MOSQ_ERR_SUCCESS) {}

    // 断开连接并释放资源
    mosquitto_disconnect(mosq);
    mosquitto_destroy(mosq);
    mosquitto_lib_cleanup();

    return 0;
}

在发送端的代码中，我们首先在`on_connect`回调函数中读取txt文件的数据，并创建一个JSON对象，将文件内容添加到JSON对象中。

然后，我们使用`cJSON_PrintUnformatted`函数将JSON对象转换为字符串，并使用`mosquitto_publish`函数将JSON格式的消息发布到指定的主题。

在订阅端的代码中，我们在`on_message`回调函数中解析收到的JSON格式的消息，并提取出文件内容字段。

接着，我们创建一个反馈的JSON对象，并将相关字段添加到该JSON对象中。

然后，我们使用`cJSON_PrintUnformatted`函数将反馈JSON对象转换为字符串，并使用`mosquitto_publish`函数将反馈消息以JSON格式发送给发布端。

请确保在编译和运行代码之前，你已正确安装了所需的Mosquitto库和cJSON库，并将相关的头文件和库文件包含到你的项目中。同时，将`MQTT_ADDRESS`、`MQTT_PORT`和`MQTT_TOPIC`替换为你的MQTT服务器的地址、端口以及相应的主题。