Onenet 物聯(lián)網(wǎng)Mqtt初探(python_模擬mqtt登陸與數(shù)據(jù)收發(fā))
2021-07-28 20:36 作者:學(xué)的很雜的一個(gè)人 | 我要投稿
請(qǐng)先去去看Onenet 物聯(lián)網(wǎng)Mqtt初探(MQTT.fx模擬登陸與數(shù)據(jù)收發(fā))文章,否則可能不明被我輸入的是什么消息。這里直接做Python代碼的mqtt連接:
?
安裝paho-mqtt MQTT 客戶端:
GitHub倉庫源碼及英文文檔:
https://pypi.org/project/paho-mqtt/#description
https://github.com/eclipse/paho.mqtt.python
?
控制臺(tái)輸入命令:pip3 install paho-mqtt

安裝成功。
?
打開jupyter lab,我習(xí)慣了這個(gè)ide,你也可以選你熟悉的ide
編寫代碼:
#根據(jù)例程修改了登錄部分
截圖

已連接,等待消息,去onenet控制臺(tái)看狀態(tài)

也顯示在線,好的,試試下發(fā)信息



收到了,這里沒做結(jié)果回復(fù)代碼,服務(wù)端會(huì)返回錯(cuò)誤數(shù)據(jù),后面應(yīng)用到再做添加。
#發(fā)送消息到服務(wù)端
client.publish("$sys/448854/my_pc1/dp/post/json", "{ 'id': 123,? 'dp': { 'data': [{ 'v':'123123asdffgg', }]}}", qos=0, retain=False)

?

服務(wù)端已收到。
#關(guān)于loop_forever()的用法見(中文,這哥們寫的比較明白):https://www.jianshu.com/p/0ed4e59b1e8f
?
Ok,至此簡(jiǎn)單收發(fā)已完成。
?
標(biāo)簽: