電子產(chǎn)業(yè)一站式賦能平臺

PCB聯(lián)盟網(wǎng)

搜索
查看: 742|回復: 0
收起左側(cè)

【HarmonyOS HiSpark Wi-Fi IoT 套件試用連載】MQTT(消息隊列遙測傳輸)

[復制鏈接]

2607

主題

2607

帖子

7472

積分

高級會員

Rank: 5Rank: 5

積分
7472
跳轉(zhuǎn)到指定樓層
樓主
發(fā)表于 2020-12-22 09:56:35 | 只看該作者 回帖獎勵 |倒序瀏覽 |閱讀模式
【HarmonyOS HiSpark Wi-Fi IoT 套件試用連載】MQTT(消息隊列遙測傳輸), MQTT 全稱為 Message Queuing Telemetry Transport(消息隊列遙測傳輸)是一種基于發(fā)布/訂閱范式的二進制“輕量級”消息協(xié)議,由IB公司發(fā)布。針對于網(wǎng)絡受限和嵌入式設備而設計的一種數(shù)據(jù)傳輸協(xié)議。MQTT最大優(yōu)點在于,可以以極少的代碼和有限的帶寬,為連接遠程設備提供實時可靠的消息服務。作為一種低開銷、低帶寬占用的即時通訊協(xié)議,使其在物聯(lián)網(wǎng)、小型設備、移動應用等方面有較廣泛的應用。





這里移植paho mqtt軟件包





導入頭文件

#include “l(fā)wip/ip_addr.h“

#include “l(fā)wip/netifapi.h“

#include “l(fā)wip/sockets.h“



修改函數(shù)transport_sendPacketBuffer

int transport_sendPacketBuffer(int sock, unsigned char* buf, int buflen){

int rc = 0;

rc = send(sock, buf, buflen, 0);

return rc;

}

修改close函數(shù)

int transport_close(int sock){

int rc;

rc = shutdown(sock, SHUT_WR);

rc = recv(sock, NULL, (size_t)0, 0);

rc = lwip_close(sock);

return rc;

}



mqtt主要文件mqtt.c文件內(nèi)容附件所示
回復

使用道具 舉報

發(fā)表回復

您需要登錄后才可以回帖 登錄 | 立即注冊

本版積分規(guī)則


聯(lián)系客服 關注微信 下載APP 返回頂部 返回列表