OpenHarmony輕松連接華為云物聯(lián)網(wǎng)平臺(tái)
想了解更多內(nèi)容，請(qǐng)?jiān)L問(wèn)：
51CTO和華為官方合作共建的鴻蒙技術(shù)社區(qū)
一.開(kāi)始
偶然的機(jī)會(huì)在網(wǎng)上看到了鴻蒙開(kāi)發(fā)板X(qián)R806的試用活動(dòng),作為一個(gè)"老鴻蒙"豈能放棄這個(gè)機(jī)會(huì),報(bào)名之后不出意料地得到了使用名額.
收到開(kāi)發(fā)板之后在想做一個(gè)什么樣的demo呢,正好最近在參加鴻蒙開(kāi)發(fā)成長(zhǎng)計(jì)劃活動(dòng),擔(dān)任導(dǎo)師,需要對(duì)接到華為云,就正好上個(gè)華為云吧.
二.從華為云官方倉(cāng)庫(kù)拉取連接平臺(tái)所用的sdk
閱讀華為云官方的開(kāi)發(fā)手冊(cè),下載sdk一氣呵成,值得吐槽的一點(diǎn)是官方的sdk竟然去年開(kāi)始就沒(méi)更新了,也不知道能不能用,先用上吧.
sdk下載地址:https://support.huaweicloud.com/sdkreference-iothub/iot_10_1002.html 在這個(gè)頁(yè)面的下面:
點(diǎn)擊鏈接跳轉(zhuǎn)到github,直接整個(gè)zip包下載.再次吐槽的一點(diǎn)作為自家的王牌,鴻蒙系統(tǒng)沒(méi)有只言片語(yǔ),甚至是連個(gè)官方demo都沒(méi)有,我想說(shuō)這幫人都在干啥呢.
把sdk下載過(guò)來(lái),放到thirdparty目錄下:
三.使用sdk編寫(xiě)代碼
上面說(shuō)了官方連個(gè)demo都沒(méi)有,那我們又如何開(kāi)始呢,好在不急,我們可以借鑒別人的經(jīng)驗(yàn),小熊派已經(jīng)做好了,參考小熊派的說(shuō)明文檔:
https://gitee.com/bearpi/bearpi-hm_nano/tree/master/applications/BearPi/BearPi-HM_Nano/sample/D6_iot_cloud_oc
這個(gè)文檔講的還算詳細(xì)的,直接有代碼,可以copy過(guò)來(lái),有幾個(gè)需要注意的地方,小熊派官方代碼里的url地址需要到平臺(tái)上找最新的:
那么這個(gè)地址又是如何得來(lái)的呢,需要我們先在華為云上創(chuàng)建好產(chǎn)品,至于怎么創(chuàng)建產(chǎn)品我這里也就不贅述了,創(chuàng)建好產(chǎn)品之后,點(diǎn)擊首頁(yè),會(huì)有個(gè)接入地址的鏈接:
點(diǎn)擊這個(gè)鏈接,可以看到各種協(xié)議的url地址和端口:
我們使用的是mqtt協(xié)議,也就是不加密的,所以選這個(gè).
還有一個(gè)是創(chuàng)建產(chǎn)品后需要添加設(shè)備,添加設(shè)備選用秘鑰方式,也就是創(chuàng)建設(shè)備的時(shí)候填入的secret,這里完事之后需要記得你填寫(xiě)的secret,然后會(huì)得到你的設(shè)備id,利用設(shè)備id轉(zhuǎn)換出設(shè)備信息三元組,具體文檔在小熊派的倉(cāng)庫(kù)里面也寫(xiě)了:
這里再貼一遍:
https://iot-tool.obs-website.cn-north-4.myhuaweicloud.com/
接著就可以利用小熊派的demo來(lái)接入sdk了.
四.代碼修改及編譯
我們?cè)贐UILD.gn里面這么寫(xiě):
- 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庫(kù),其實(shí)1.x版本的鴻蒙系統(tǒng)還不夠精簡(jiǎn),需要做一些裁減,最基礎(chǔ)的庫(kù)會(huì)有很多綁定,主要的修改點(diǎn)在這兒:
以上兩個(gè)打箭頭的地方我們注釋掉,因?yàn)槲覀儾挥孟到y(tǒng)的,如果不注釋調(diào)會(huì)有沖突.
然后小熊派帶了一個(gè)LITEOS版本的mqtt適配,我們從小熊派那里拷貝過(guò)來(lái).
然后需要做一些修改,具體哪些修改已經(jīng)不記得了,主要就是幾個(gè)系統(tǒng)文件,
把這些統(tǒng)統(tǒng)做完,能夠編譯通過(guò)了已經(jīng)成功一大半了.
五.板子連接無(wú)線(xiàn)網(wǎng)
板子連接無(wú)線(xiàn)網(wǎng)直接拿XR806官方的demo進(jìn)行修改,主要用的就是那個(gè)連接wifi的例子,然后可以先運(yùn)行這個(gè)試一下能不能連到wifi,但是官方的例子沒(méi)有自動(dòng)獲取ip的代碼,所以我們又從小熊派的倉(cāng)庫(kù)中拷貝拿ip的代碼,但是要稍作修改,如下:
- static void MainThread(void *arg)
- { wifi_connect();
- dhcp_start(g_lwip_netif);
- printf("begain to dhcp");
- OS_Sleep(5);
- iot_thread_start(NULL);
- }
這之后就啟動(dòng)iot的線(xiàn)程,實(shí)現(xiàn)平臺(tái)的登錄.
六.踩坑
本來(lái)代碼到這已經(jīng)完了,可以實(shí)現(xiàn)平臺(tái)的登錄了,但是數(shù)據(jù)一直沒(méi)法發(fā)上去,經(jīng)過(guò)一天的苦苦尋找,結(jié)果發(fā)現(xiàn)問(wèn)題出在linux_read這個(gè)函數(shù)里面:
原來(lái)的代碼,這個(gè)地方賦值一直會(huì)錯(cuò)誤,導(dǎo)致recv函數(shù)一直到超時(shí)都拿不到數(shù)據(jù)，這個(gè)問(wèn)題百思不得其解,然后就是想辦法繞過(guò)這個(gè)問(wèn)題,改造吧,直接用timeout做參數(shù)去查詢(xún)有沒(méi)有數(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;
- }
這一步做完,就可以愉快地登錄云平臺(tái)實(shí)現(xiàn)數(shù)據(jù)收發(fā)了。
七.在云平臺(tái)上進(jìn)行調(diào)試
到云平臺(tái)上點(diǎn)擊產(chǎn)品,然后選擇你的產(chǎn)品,再點(diǎn)擊在線(xiàn)調(diào)試,選擇你要調(diào)試的設(shè)備:
跳轉(zhuǎn)到在線(xiàn)調(diào)試頁(yè)面:
可以看到左邊有數(shù)據(jù),右邊有命令下發(fā),這時(shí)候我們?cè)O(shè)備還是離線(xiàn)的,把代碼燒寫(xiě)到板子里,然后給系統(tǒng)上電,如果順利的話(huà),是可以看到設(shè)備上線(xiàn),并且有數(shù)據(jù)上傳,點(diǎn)擊命令下發(fā),填入一個(gè)指令,在頁(yè)面右下角有個(gè)發(fā)送按鈕,可以把命令發(fā)送出去,然后板子上就能收到數(shù)據(jù):
可以看到設(shè)備已經(jīng)上線(xiàn)了,而我們的設(shè)備,也收到了平臺(tái)下發(fā)的指令:
到這里我們就實(shí)現(xiàn)了華為云Iot平臺(tái)的數(shù)據(jù)通信。
八.總結(jié)
到這里,我們XR806設(shè)備上云就完成了,華為云除了文檔有點(diǎn)糟心其實(shí)還可以的哈,其實(shí)物聯(lián)網(wǎng)沒(méi)有想象中的那么難哈,還在等什么,趕緊開(kāi)動(dòng)起來(lái)吧.
想了解更多內(nèi)容，請(qǐng)?jiān)L問(wèn)：
51CTO和華為官方合作共建的鴻蒙技術(shù)社區(qū)
【編輯推薦】
