MQTT如何連接阿里云接收和發(fā)送數(shù)據(jù)

本篇內(nèi)容主要講解“MQTT如何連接阿里云接收和發(fā)送數(shù)據(jù)”，感興趣的朋友不妨來看看。本文介紹的方法操作簡單快捷，實用性強。下面就讓小編來帶大家學(xué)習(xí)“MQTT如何連接阿里云接收和發(fā)送數(shù)據(jù)”吧!

中移4G模塊-ML302-OpenCpu開發(fā)-(MQTT連接阿里云-接收和發(fā)送數(shù)據(jù))

根據(jù)上一條的學(xué)習(xí)，如果沒看過可以去看一下上面的2.1中移4G模塊-ML302-OpenCpu開發(fā)-(MQTT連接阿里云-訂閱主題)

數(shù)據(jù)是可以接收了，那怎么發(fā)送呢。

int example_publish(void *handle)
{
    int             res = 0;
    const char     *fmt = "/%s/%s/user/get";
    char           *topic = NULL;
    int             topic_len = 0;
    char           *payload = "{\"message\":\"hello!\"}";

    //*** 對topic的拼接***

    topic_len = strlen(fmt) + strlen(DEMO_PRODUCT_KEY) + strlen(DEMO_DEVICE_NAME) + 1;
    topic = HAL_Malloc(topic_len);
    if (topic == NULL) {
        cm_printf("[ALIYUN]: memory not enough\n");  
        return -1;
    }
    memset(topic, 0, topic_len);
    HAL_Snprintf(topic, topic_len, fmt, DEMO_PRODUCT_KEY, DEMO_DEVICE_NAME);

    //*** 對topic的拼接***
    
    // 調(diào)用IOT_MQTT_Publish_Simple發(fā)送數(shù)據(jù)
    res = IOT_MQTT_Publish_Simple(0, topic, IOTX_MQTT_QOS0, payload, strlen(payload));
    
    if (res < 0) {
        cm_printf("[ALIYUN]: publish failed, res = %d\n", res);
        HAL_Free(topic);
        return -1;
    }

    HAL_Free(topic);
    return 0;
}

IOT_MQTT_Publish_Simple函數(shù)

topic_name：topic名字

qos:qos

data:數(shù)據(jù)

len:發(fā)送數(shù)據(jù)長度

int IOT_MQTT_Publish_Simple(void *handle, const char *topic_name, int qos, void *data, int len)

這是一個比較簡單的MQTT發(fā)送程序

到此，相信大家對“MQTT如何連接阿里云接收和發(fā)送數(shù)據(jù)”有了更深的了解，不妨來實際操作一番吧！這里是億速云網(wǎng)站，更多相關(guān)內(nèi)容可以進入相關(guān)頻道進行查詢，關(guān)注我們，繼續(xù)學(xué)習(xí)！