qtt json格式 mosquitto订阅端解析并反馈给发布段以json格式，并打印出已经成功接受

要在Mosquitto订阅端解析收到的MQTT消息，并将反馈以JSON格式发送给发布段，并打印已成功接收的消息，你可以使用C语言中的标准库和Mosquitto库，以及一个JSON库（例如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 "sensors"
#define MQTT_FEEDBACK_TOPIC "feedback"

// 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 *feedback = cJSON_CreateObject();
            cJSON_AddStringToObject(feedback, "status", "success");
            cJSON_AddStringToObject(feedback, "message", "Received file content");
            
            // 将反馈JSON对象转换为字符串
            char *feedback_str = cJSON_PrintUnformatted(feedback);
            
            // 发送反馈给发布段
            mosquitto_publish(mosq, NULL, MQTT_FEEDBACK_TOPIC, strlen(feedback_str), feedback_str, 0, false);
            
            // 打印已成功接收的消息
            printf("Feedback sent: %s\n", feedback_str);
            
            // 释放内存
            free(feedback_str);
            cJSON_Delete(feedback);
        }

        // 释放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;
}

在上述示例中，我们使用Mosquitto库创建了一个Mosquitto客户端实例，并设置了连接、消息接收和连接断开的回调函数。

在`on_message`回调函数中，我们首先将收到的MQTT消息的payload（即消息内容）解析为JSON对象。然后，我们提取了名为`file_content`的字符串键值对，并打印出已成功接收的文件内容。

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

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

最后，我们打印出已成功接收的消息，并释放内存。

请确保在编译和运行代码之前，你已正确安装了所需的Mosquitto库和cJSON库，并将相关的头文件和库文件包含到你的项目中。