OpenHarmony輕松連接華為云物聯(lián)網(wǎng)平臺

作者：cszzlsw 2021-12-28 16:06:15

系統(tǒng)

收到開發(fā)板之后在想做一個什么樣的demo呢,正好最近在參加鴻蒙開發(fā)成長計劃活動,擔(dān)任導(dǎo)師,需要對接到華為云,就正好上個華為云吧.

[[442565]]

想了解更多內(nèi)容，請訪問：

51CTO和華為官方合作共建的鴻蒙技術(shù)社區(qū)

https://harmonyos.51cto.com

一.開始

偶然的機會在網(wǎng)上看到了鴻蒙開發(fā)板XR806的試用活動,作為一個"老鴻蒙"豈能放棄這個機會,報名之后不出意料地得到了使用名額.

收到開發(fā)板之后在想做一個什么樣的demo呢,正好最近在參加鴻蒙開發(fā)成長計劃活動,擔(dān)任導(dǎo)師,需要對接到華為云,就正好上個華為云吧.

二.從華為云官方倉庫拉取連接平臺所用的sdk

閱讀華為云官方的開發(fā)手冊,下載sdk一氣呵成,值得吐槽的一點是官方的sdk竟然去年開始就沒更新了,也不知道能不能用,先用上吧.

sdk下載地址:https://support.huaweicloud.com/sdkreference-iothub/iot_10_1002.html 在這個頁面的下面:

#星光計劃2.0# openHarmony輕松連接華為云物聯(lián)網(wǎng)平臺-鴻蒙HarmonyOS技術(shù)社區(qū)

點擊鏈接跳轉(zhuǎn)到github,直接整個zip包下載.再次吐槽的一點作為自家的王牌,鴻蒙系統(tǒng)沒有只言片語,甚至是連個官方demo都沒有,我想說這幫人都在干啥呢.

把sdk下載過來,放到thirdparty目錄下:

三.使用sdk編寫代碼

上面說了官方連個demo都沒有,那我們又如何開始呢,好在不急,我們可以借鑒別人的經(jīng)驗,小熊派已經(jīng)做好了,參考小熊派的說明文檔:

https://gitee.com/bearpi/bearpi-hm_nano/tree/master/applications/BearPi/BearPi-HM_Nano/sample/D6_iot_cloud_oc

這個文檔講的還算詳細的,直接有代碼,可以copy過來,有幾個需要注意的地方,小熊派官方代碼里的url地址需要到平臺上找最新的:

那么這個地址又是如何得來的呢,需要我們先在華為云上創(chuàng)建好產(chǎn)品,至于怎么創(chuàng)建產(chǎn)品我這里也就不贅述了,創(chuàng)建好產(chǎn)品之后,點擊首頁,會有個接入地址的鏈接:

點擊這個鏈接,可以看到各種協(xié)議的url地址和端口:

我們使用的是mqtt協(xié)議,也就是不加密的,所以選這個.

還有一個是創(chuàng)建產(chǎn)品后需要添加設(shè)備,添加設(shè)備選用秘鑰方式,也就是創(chuàng)建設(shè)備的時候填入的secret,這里完事之后需要記得你填寫的secret,然后會得到你的設(shè)備id,利用設(shè)備id轉(zhuǎn)換出設(shè)備信息三元組,具體文檔在小熊派的倉庫里面也寫了:

這里再貼一遍:

https://iot-tool.obs-website.cn-north-4.myhuaweicloud.com/

接著就可以利用小熊派的demo來接入sdk了.

四.代碼修改及編譯

我們在BUILD.gn里面這么寫:

static_library("iotLink") { 
 
    sources = [ 
 
        "iot_thread.c", 
 
        "oc_mqtt_profile_package.c", 
 
        "oc_mqtt.c", 
 
        "light.c", 
 
        "//third_party/iot_link/cJSON/cJSON.c" 
 
        
 
    ] 
 
     
 
    cflags = [ "-Wno-unused-variable" ] 
 
    cflags += [ "-Wno-unused-but-set-variable" ] 
 
     
 
    include_dirs = [ 
 
        ".", 
 
        "//foundation/communication/softbus_lite/os_adapter/include", 
 
        "//utils/native/lite/include", 
 
        "//kernel/liteos_m/components/cmsis/2.0", 
 
        "//third_party/lwip/src/include", 
 
        "//third_party/lwip/test/unit", 
 
        "//base/iot_hardware/peripheral/interfaces/kits", 
 
        "//foundation/communication/wifi_lite/interfaces/wifiservice", 
 
        "//vendor/hisi/hi3861/hi3861/third_party/lwip_sack/include", 
 
 
 
        "//third_party/iot_link/inc", 
 
        "//third_party/iot_link/oc/oc_mqtt/oc_mqtt_tiny_v5", 
 
        "//third_party/iot_link/cJSON", 
 
 
 
        "//third_party/iot_link/network/mqtt/paho_mqtt/paho/MQTTPacket/src", 
 
        "//third_party/iot_link/network/mqtt/paho_mqtt/paho/MQTTClient-C/src", 
 
        "//third_party/iot_link/network/mqtt/paho_mqtt/paho/MQTTClient-C/src/liteOS", 
 
        "//third_party/iot_link/network/mqtt/paho_mqtt/paho/MQTTPacket/samples", 
 
         
 
    ] 
 
 
 
    deps = [  
 
             "//third_party/iot_link/network/mqtt/paho_mqtt:pahomqtt_static", 
 
    ] 
 
 
}

這里我們引用了sdk官方的JSON和華為的MQTT庫,其實1.x版本的鴻蒙系統(tǒng)還不夠精簡,需要做一些裁減,最基礎(chǔ)的庫會有很多綁定,主要的修改點在這兒:

以上兩個打箭頭的地方我們注釋掉,因為我們不用系統(tǒng)的,如果不注釋調(diào)會有沖突.

然后小熊派帶了一個LITEOS版本的mqtt適配,我們從小熊派那里拷貝過來.

然后需要做一些修改,具體哪些修改已經(jīng)不記得了,主要就是幾個系統(tǒng)文件,

把這些統(tǒng)統(tǒng)做完,能夠編譯通過了已經(jīng)成功一大半了.

五.板子連接無線網(wǎng)

板子連接無線網(wǎng)直接拿XR806官方的demo進行修改,主要用的就是那個連接wifi的例子,然后可以先運行這個試一下能不能連到wifi,但是官方的例子沒有自動獲取ip的代碼,所以我們又從小熊派的倉庫中拷貝拿ip的代碼,但是要稍作修改,如下:

static void MainThread(void *arg) 
 
{   wifi_connect(); 
 
 
    dhcp_start(g_lwip_netif); 
 
        printf("begain to dhcp"); 
 
        OS_Sleep(5); 
 
   
 
    iot_thread_start(NULL); 
 
}

這之后就啟動iot的線程,實現(xiàn)平臺的登錄.

六.踩坑

本來代碼到這已經(jīng)完了,可以實現(xiàn)平臺的登錄了,但是數(shù)據(jù)一直沒法發(fā)上去,經(jīng)過一天的苦苦尋找,結(jié)果發(fā)現(xiàn)問題出在linux_read這個函數(shù)里面:

原來的代碼,這個地方賦值一直會錯誤,導(dǎo)致recv函數(shù)一直到超時都拿不到數(shù)據(jù)，這個問題百思不得其解,然后就是想辦法繞過這個問題,改造吧,直接用timeout做參數(shù)去查詢有沒有數(shù)據(jù):

int linux_read(Network *n, unsigned char *buffer, int len, int timeout_ms) 
{ 
    printf("linux_read timeout_ms = %d\n",timeout_ms); 
    struct timeval interval = { 
        .tv_sec = timeout_ms / 1000, 
        .tv_usec =(timeout_ms % 1000) * 1000 
    }; 
    if (interval.tv_sec < 0 || (interval.tv_sec == 0 && interval.tv_usec <= 0)) 
    { 
        interval.tv_sec = 0; 
        interval.tv_usec = 100; 
    } 
    // setsockopt(n->my_socket, SOL_SOCKET, SO_RCVTIMEO, (char *)&interval, sizeof(struct timeval)); 
 
    int bytes = 0; 
 
    struct pollfd pfd ; 
 
    /* Initialize the file descriptor. 
        * #POLLPRI corresponds to high-priority data while #POLLIN corresponds 
        * to any other data that may be read. */ 
    pfd.events  = POLLIN | POLLPRI; 
    pfd.revents = 0; 
    /* Set the file descriptor for poll. */ 
    pfd.fd = n->my_socket; 
         
    while (bytes < len) 
    { 
        int rc = poll(&pfd, 1, timeout_ms); 
        if(rc > 0){ 
            rc = recv(n->my_socket, &buffer[bytes], (size_t)(len - bytes), 0); 
        }else{ 
            if(rc == 0){ 
                break; 
            }else{ 
                printf("rc ret = %d\n",rc); 
            } 
        } 
         
        if (rc == -1) 
        { 
            if (errno != EAGAIN && errno != EWOULDBLOCK) 
                bytes = -1; 
            break; 
        } 
        else if (rc == 0) 
        { 
            bytes = 0; 
            break; 
        } 
        else 
            bytes += rc; 
    } 
    printf("read %d bytes\n",bytes); 
    return bytes; 
}

這一步做完,就可以愉快地登錄云平臺實現(xiàn)數(shù)據(jù)收發(fā)了。

七.在云平臺上進行調(diào)試

到云平臺上點擊產(chǎn)品,然后選擇你的產(chǎn)品,再點擊在線調(diào)試,選擇你要調(diào)試的設(shè)備:

跳轉(zhuǎn)到在線調(diào)試頁面:

可以看到左邊有數(shù)據(jù),右邊有命令下發(fā),這時候我們設(shè)備還是離線的,把代碼燒寫到板子里,然后給系統(tǒng)上電,如果順利的話,是可以看到設(shè)備上線,并且有數(shù)據(jù)上傳,點擊命令下發(fā),填入一個指令,在頁面右下角有個發(fā)送按鈕,可以把命令發(fā)送出去,然后板子上就能收到數(shù)據(jù):