MQTT如何連接阿里云訂閱主題

本篇內容主要講解“MQTT如何連接阿里云訂閱主題”，感興趣的朋友不妨來看看。本文介紹的方法操作簡單快捷，實用性強。下面就讓小編來帶大家學習“MQTT如何連接阿里云訂閱主題”吧!

成都創新互聯公司是一家專業從事網站制作、成都做網站的網絡公司。作為專業的建站公司,成都創新互聯公司依托的技術實力、以及多年的網站運營經驗,為您提供專業的成都網站建設、營銷型網站建設及網站設計開發服務！

中移4G模塊-ML302-OpenCpu開發-(MQTT連接阿里云-訂閱主題)

模塊OpenCpu部分

cm_main.c文件里面的cm_main_task是主函數,在主函數里面調用cm_test_aliyun函數。

cm_test_aliyun函數：

void cm_test_aliyun(){
    cm_printf("[ALIYUN]: aliyun demo start\n");

    void                   *pclient = NULL;
    int                     res = 0;
    int                     rpc_res = 0;
    int                     loop_cnt = 0;
    iotx_mqtt_param_t       mqtt_params;

    HAL_GetProductKey(DEMO_PRODUCT_KEY);
    HAL_GetDeviceName(DEMO_DEVICE_NAME);
    HAL_GetDeviceSecret(DEMO_DEVICE_SECRET);

    memset(&mqtt_params, 0x0, sizeof(mqtt_params));

    mqtt_params.handle_event.h_fp = example_event_handle;

    pclient = IOT_MQTT_Construct(&mqtt_params);
    if (NULL == pclient) {
        cm_printf("[ALIYUN]: MQTT construct failed\n");
        return -1;
    }

    res = example_subscribe(pclient);      //調用example_subscribe函數
    if (res < 0) {
        IOT_MQTT_Destroy(&pclient);
        return -1;
    }

    while (1) {
        if (0 == loop_cnt % 20) {
            example_publish(pclient);
        }

        IOT_MQTT_Yield(pclient, 200);

        loop_cnt += 1;

        if(loop_cnt >= 100)  {
            //break;
        }
    }
    
    cm_printf("[ALIYUN]: aliyun demo end\n");
}

example_subscribe函數：

example_subscribe一開始進行字符串連接，把${YourProductKey}/${YourDeviceName}/user/get拼接出來，然后調用IOT_MQTT_Subscribe函數訂閱topic

int example_subscribe(void *handle){
    int res = 0;
    const char *fmt = "/%s/%s/user/get";    //訂閱的MQTT路徑
    char *topic = NULL;
    int topic_len = 0;

    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);

    //通過HAL_Snprintf函數的拼接得出最終的MQTT路徑
    //示例：${YourProductKey}/${YourDeviceName}/user/get
    //其中的：example_message_arrive函數為接收的數據的回調函數    

    res = IOT_MQTT_Subscribe(handle, topic, IOTX_MQTT_QOS0, example_message_arrive, NULL);
    if (res < 0) {
        cm_printf("[ALIYUN]: subscribe failed\n");
        HAL_Free(topic);
        return -1;
    }

    HAL_Free(topic);
    return 0;
}

example_message_arrive函數

example_subscribe為topic接收回調函數，當接收到此topic的數據時會放到這里處理

void example_message_arrive(void *pcontext, void *pclient, iotx_mqtt_event_msg_pt msg){
    iotx_mqtt_topic_info_t     *topic_info = (iotx_mqtt_topic_info_pt) msg->msg;

    cm_printf("example_message_arrive \n");

    switch (msg->event_type) {
        case IOTX_MQTT_EVENT_PUBLISH_RECEIVED:
            /* print topic name and topic message */
            cm_printf("[ALIYUN]: Message Arrived:");
            cm_printf("Topic  : %.*s", topic_info->topic_len, topic_info->ptopic);
            cm_printf("Payload: %.*s", topic_info->payload_len, topic_info->payload);
            cm_printf("\n");

            // topic_info->payload為接收到的數據

            if(strcmp(topic_info->payload,"1") == 0){
                cm_printf("開燈\n");
                cm_gpio_write(21,CM_GPIO_LOW);
            }else{
                cm_printf("關燈\n");
                cm_gpio_write(21,CM_GPIO_HIGH);
            }



            break;
        default:
            break;
    }

}

服務器部分

前端通過傳入lightState來控制GPIO21是高電平還是低電平

@GetMapping(path="hello")
    public WebResult setGPIOState(int lightState){

        // XXXXXX：ProductKey
        // YYYYYY: 設備名稱

        PubRequest request = new PubRequest();
        request.setProductKey("XXXXXXXXXXXX");
          request.setMessageContent(Base64.encodeBase64String((Integer.toString(lightState)).getBytes()));
        request.setTopicFullName("/XXXXXXXXXX/YYYYYYYYYYY/user/get");
        request.setQos(0); //目前支持QoS0和QoS1。
        try {
            PubResponse response = defaultAcsClient.getAcsResponse(request);
            //System.out.println(response.getSuccess());
            //System.out.println(response.getErrorMessage());
        } catch (ServerException e) {
            e.printStackTrace();
        } catch (ClientException e) {
            e.printStackTrace();
        }


        return WebResult.success(1,"hello");
    }

前端網頁部分

MQTT如何連接阿里云訂閱主題

<div class="my-2 my-tab">
                <v-btn small @click="setLightState(1)">燈光開</v-btn>
                <v-btn small  @click="setLightState(0)">燈光關</v-btn>
            </div>

methods:{
        setLightState(state){
            console.log(state);
            // 開關燈
            axios({
                method: 'get',
                url: "/iot/hello",
                params: {
                    'lightState':state
                }
            }).then(res => {
                console.log(res)
            })
        },
    }

到此，相信大家對“MQTT如何連接阿里云訂閱主題”有了更深的了解，不妨來實際操作一番吧！這里是創新互聯網站，更多相關內容可以進入相關頻道進行查詢，關注我們，繼續學習！

當前名稱：MQTT如何連接阿里云訂閱主題
標題路徑：http://m.kartarina.com/article8/pphcop.html

成都網站建設公司_創新互聯，為您提供營銷型網站建設、域名注冊、自適應網站、微信小程序、網站制作、網站策劃

聲明：本網站發布的內容（圖片、視頻和文字）以用戶投稿、用戶轉載內容為主，如果涉及侵權請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網站立場，如需處理請聯系客服。電話：028-86922220；郵箱：631063699@qq.com。內容未經允許不得轉載，或轉載時需注明來源：創新互聯

猜你還喜歡下面的內容