0

我有一个结构 IoT_Publish_Message_Params 需要准备以准备在 AWS IoT 上发布。当我将字符串作为有效负载传递时，下面的代码片段完全可以正常工作。

/**
 * @brief Publish Message Parameters Type
 *
 * Defines a type for MQTT Publish messages. Used for both incoming and out going messages
 *
 */
typedef struct {
    QoS qos;        ///< Message Quality of Service
    uint8_t isRetained; ///< Retained messages are \b NOT supported by the AWS IoT Service at the time of this SDK release.
    uint8_t isDup;      ///< Is this message a duplicate QoS > 0 message?  Handled automatically by the MQTT client.
    uint16_t id;        ///< Message sequence identifier.  Handled automatically by the MQTT client.
    void *payload;      ///< Pointer to MQTT message payload (bytes).
    size_t payloadLen;  ///< Length of MQTT payload.
} IoT_Publish_Message_Params;

IoT_Publish_Message_Params paramsQOS0;
sprintf(cPayload, "%s : %d ", "Hello from HOME!!", i);

paramsQOS0.qos = QOS0;
paramsQOS0.payload = (void *) cPayload;
paramsQOS0.isRetained = 0;
paramsQOS0.payloadLen = strlen(cPayload);
rc = aws_iot_mqtt_publish(&client, TOPIC, TOPIC_LEN, &paramsQOS0);

现在我想发送一个实际的 JSON 有效负载，但我不确定我该怎么做。我尝试使用 cJSON 创建 JSON 对象：

cJSON *root,*fmt;
root=cJSON_CreateObject();
paramsQOS0.payload = (void *) root
cJSON_AddItemToObject(root, "response", fmt=cJSON_CreateObject());
cJSON_AddNumberToObject(fmt,"hello", 123);
cJSON_AddNumberToObject(fmt,"bye", 321);

但是，我的问题是，我在这里传递什么作为 IoT_Publish_Message_Params.payloadLen ？以及如何将 json 对象传递给 IoT_Publish_Message_Params.payload？

4

2 回答 2

0

IoT_Publish_Message_Paramshaspayload和payloadLen成员，因此您可以提供要发送的任何有效内存和字节长度。在您的第一个示例中，您提供了一个静态分配的字符串及其长度。

JSON 是一种基于字符串的编码协议，因此payload将是一个char指针，payloadLen可以使用strlen.

cJSON_Print返回对象的 json 字符串，使用它返回的指针并将其分配给payload.

请阅读cJSON API 文档如何使用它。下面是如何使用修改代码来发送 JSON 字符串。

IoT_Publish_Message_Params paramsQOS0;
char *json_str;

/* create a json message */
cJSON *root, *response;
root = cJSON_CreateObject();
response = cJSON_CreateObject();
cJSON_AddItemToObject(root, "response", response);
cJSON_AddNumberToObject(response, "hello", 123);
cJSON_AddNumberToObject(response, "bye", 321);

json_str = cJSON_Print(root);
if (json_str != NULL)
{
    paramsQOS0.qos = QOS0;
    paramsQOS0.isRetained = 0;
    paramsQOS0.payload = json_str;
    paramsQOS0.payloadLen = strlen(json_str);
    rc = aws_iot_mqtt_publish(&client, TOPIC, TOPIC_LEN, &paramsQOS0);
    free(json_str);
}

cJSON_Delete(root);
于 2020-09-18T05:00:43.163 回答
0

在我看来，您有两种选择。将 JSON 作为字符串或原始字节发送。

如果您想将其作为字符串发送（例如{"CarType":"BMW","carID":"bmw123"}），那么您想将其转换为字符串。在这里找到了一些代码。

char* str = cJSON_Print(root);  
paramsQOS0.payload = (void *) str;
paramsQOS0.payloadLen = strlen(str);

但是，将其作为原始字节发送会更有效。为此，您需要一个指向对象开头的指针，以及对象的大小（以字节为单位）。快速扫描我发现显然返回对象大小的GitHub 页面。cJSON_GetArraySize

然后它应该看起来像这样：

paramsQOS0.payload = (void *) root;
paramsQOS0.payloadLen = cJSON_GetArraySize(root); // Not sure about this one

免责声明，我没有使用过 cJSON，也没有测试过代码。我试图告诉你该走哪个方向。

于 2020-09-09T12:28:34.427 回答