基于ESP-IDF框架用C通过MQTT向AWS IoT发送JSON payload的疑问

阿华AIGC实验室

2026-5-9

如何用cJSON将JSON对象传递给AWS IoT MQTT的Publish参数？

你遇到的核心问题是：cJSON对象是内存中的结构化数据，不能直接作为MQTT的payload传递——MQTT发布的是字节流形式的JSON字符串，所以需要先把cJSON对象序列化成字符串，再设置对应的参数。另外你原来的代码还有顺序问题（先把空的root赋值给payload，再添加JSON元素），这也会导致错误。

下面是完整的正确实现步骤和代码：

关键步骤说明

先创建并填充cJSON对象，不要提前把它赋值给payload
使用cJSON_PrintUnformatted()（或cJSON_Print()）将cJSON对象序列化为JSON字符串，前者生成无空格的紧凑格式，更适合网络传输
将序列化后的字符串指针赋值给payload，用strlen()获取字符串长度作为payloadLen
发布完成后，必须释放cJSON对象和序列化的字符串，避免内存泄漏

修正后的完整代码示例

// 1. 创建并填充cJSON对象
cJSON *root = cJSON_CreateObject();
if (root == NULL) {
    // 处理创建失败的情况
    printf("Failed to create cJSON root object\n");
    return;
}

cJSON *response = cJSON_CreateObject();
if (response == NULL) {
    cJSON_Delete(root);
    printf("Failed to create response object\n");
    return;
}
cJSON_AddItemToObject(root, "response", response);

// 添加数据到JSON对象
cJSON_AddNumberToObject(response, "hello", 123);
cJSON_AddNumberToObject(response, "bye", 321);

// 2. 将cJSON对象序列化为字符串（紧凑格式）
char *json_payload = cJSON_PrintUnformatted(root);
if (json_payload == NULL) {
    cJSON_Delete(root);
    printf("Failed to serialize cJSON object\n");
    return;
}

// 3. 设置MQTT发布参数
IoT_Publish_Message_Params paramsQOS0 = {0}; // 初始化结构体，避免垃圾值
paramsQOS0.qos = QOS0;
paramsQOS0.payload = json_payload;
paramsQOS0.isRetained = 0;
paramsQOS0.payloadLen = strlen(json_payload);

// 4. 发布消息
int rc = aws_iot_mqtt_publish(&client, TOPIC, TOPIC_LEN, &paramsQOS0);
if (rc == SUCCESS) {
    printf("JSON message published successfully\n");
} else {
    printf("Publish failed with error code: %d\n", rc);
}

// 5. 释放资源，避免内存泄漏
cJSON_Delete(root);
free(json_payload);