OpenHarmony輕松連接華為云物聯網平臺
一.開始
偶然的機會在網上看到了鴻蒙開發板XR806的試用活動,作為一個"老鴻蒙"豈能放棄這個機會,報名之后不出意料地得到了使用名額.
收到開發板之后在想做一個什么樣的demo呢,正好最近在參加鴻蒙開發成長計劃活動,擔任導師,需要對接到華為云,就正好上個華為云吧.
二.從華為云官方倉庫拉取連接平臺所用的sdk
閱讀華為云官方的開發手冊,下載sdk一氣呵成,值得吐槽的一點是官方的sdk竟然去年開始就沒更新了,也不知道能不能用,先用上吧.
sdk下載地址:https://support.huaweicloud.com/sdkreference-iothub/iot_10_1002.html 在這個頁面的下面:
點擊鏈接跳轉到github,直接整個zip包下載.再次吐槽的一點作為自家的王牌,鴻蒙系統沒有只言片語,甚至是連個官方demo都沒有,我想說這幫人都在干啥呢.
把sdk下載過來,放到thirdparty目錄下:
三.使用sdk編寫代碼
上面說了官方連個demo都沒有,那我們又如何開始呢,好在不急,我們可以借鑒別人的經驗,小熊派已經做好了,參考小熊派的說明文檔:
https://gitee.com/bearpi/bearpi-hm_nano/tree/master/applications/BearPi/BearPi-HM_Nano/sample/D6_iot_cloud_oc
這個文檔講的還算詳細的,直接有代碼,可以copy過來,有幾個需要注意的地方,小熊派官方代碼里的url地址需要到平臺上找最新的:
那么這個地址又是如何得來的呢,需要我們先在華為云上創建好產品,至于怎么創建產品我這里也就不贅述了,創建好產品之后,點擊首頁,會有個接入地址的鏈接:
點擊這個鏈接,可以看到各種協議的url地址和端口:
我們使用的是mqtt協議,也就是不加密的,所以選這個.
還有一個是創建產品后需要添加設備,添加設備選用秘鑰方式,也就是創建設備的時候填入的secret,這里完事之后需要記得你填寫的secret,然后會得到你的設備id,利用設備id轉換出設備信息三元組,具體文檔在小熊派的倉庫里面也寫了:
這里再貼一遍:
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版本的鴻蒙系統還不夠精簡,需要做一些裁減,最基礎的庫會有很多綁定,主要的修改點在這兒:
以上兩個打箭頭的地方我們注釋掉,因為我們不用系統的,如果不注釋調會有沖突.
然后小熊派帶了一個LITEOS版本的mqtt適配,我們從小熊派那里拷貝過來.
然后需要做一些修改,具體哪些修改已經不記得了,主要就是幾個系統文件,
把這些統統做完,能夠編譯通過了已經成功一大半了.
五.板子連接無線網
板子連接無線網直接拿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的線程,實現平臺的登錄.
六.踩坑
本來代碼到這已經完了,可以實現平臺的登錄了,但是數據一直沒法發上去,經過一天的苦苦尋找,結果發現問題出在linux_read這個函數里面:
原來的代碼,這個地方賦值一直會錯誤,導致recv函數一直到超時都拿不到數據，這個問題百思不得其解,然后就是想辦法繞過這個問題,改造吧,直接用timeout做參數去查詢有沒有數據:
- 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;
- }
這一步做完,就可以愉快地登錄云平臺實現數據收發了。
七.在云平臺上進行調試
到云平臺上點擊產品,然后選擇你的產品,再點擊在線調試,選擇你要調試的設備:
跳轉到在線調試頁面:
可以看到左邊有數據,右邊有命令下發,這時候我們設備還是離線的,把代碼燒寫到板子里,然后給系統上電,如果順利的話,是可以看到設備上線,并且有數據上傳,點擊命令下發,填入一個指令,在頁面右下角有個發送按鈕,可以把命令發送出去,然后板子上就能收到數據:
可以看到設備已經上線了,而我們的設備,也收到了平臺下發的指令:
到這里我們就實現了華為云Iot平臺的數據通信。
八.總結
到這里,我們XR806設備上云就完成了,華為云除了文檔有點糟心其實還可以的哈,其實物聯網沒有想象中的那么難哈,還在等什么,趕緊開動起來吧.
【編輯推薦】
