OpenHarmony輕松連接華為云物聯(lián)網(wǎng)平臺
一.開始
偶然的機會在網(wǎng)上看到了鴻蒙開發(fā)板XR806的試用活動,作為一個"老鴻蒙"豈能放棄這個機會,報名之后不出意料地得到了使用名額.
收到開發(fā)板之后在想做一個什么樣的demo呢,正好最近在參加鴻蒙開發(fā)成長計劃活動,擔任導師,需要對接到華為云,就正好上個華為云吧.
二.從華為云官方倉庫拉取連接平臺所用的sdk
閱讀華為云官方的開發(fā)手冊,下載sdk一氣呵成,值得吐槽的一點是官方的sdk竟然去年開始就沒更新了,也不知道能不能用,先用上吧.
sdk下載地址:https://support.huaweicloud.com/sdkreference-iothub/iot_10_1002.html 在這個頁面的下面:
點擊鏈接跳轉(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)品后需要添加設備,添加設備選用秘鑰方式,也就是創(chuàng)建設備的時候填入的secret,這里完事之后需要記得你填寫的secret,然后會得到你的設備id,利用設備id轉(zhuǎn)換出設備信息三元組,具體文檔在小熊派的倉庫里面也寫了:
這里再貼一遍:
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)還不夠精簡,需要做一些裁減,最基礎的庫會有很多綁定,主要的修改點在這兒:
以上兩個打箭頭的地方我們注釋掉,因為我們不用系統(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)過一天的苦苦尋找,結果發(fā)現(xiàn)問題出在linux_read這個函數(shù)里面:
原來的代碼,這個地方賦值一直會錯誤,導致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)試的設備:
跳轉(zhuǎn)到在線調(diào)試頁面:
可以看到左邊有數(shù)據(jù),右邊有命令下發(fā),這時候我們設備還是離線的,把代碼燒寫到板子里,然后給系統(tǒng)上電,如果順利的話,是可以看到設備上線,并且有數(shù)據(jù)上傳,點擊命令下發(fā),填入一個指令,在頁面右下角有個發(fā)送按鈕,可以把命令發(fā)送出去,然后板子上就能收到數(shù)據(jù):
可以看到設備已經(jīng)上線了,而我們的設備,也收到了平臺下發(fā)的指令:
到這里我們就實現(xiàn)了華為云Iot平臺的數(shù)據(jù)通信。
八.總結
到這里,我們XR806設備上云就完成了,華為云除了文檔有點糟心其實還可以的哈,其實物聯(lián)網(wǎng)沒有想象中的那么難哈,還在等什么,趕緊開動起來吧.
【編輯推薦】
