av一区二区在线观看_亚洲男人的天堂网站_日韩亚洲视频_在线成人免费_欧美日韩精品免费观看视频_久草视

您的位置:首頁技術(shù)文章
文章詳情頁

在 Python 中使用 MQTT的方法

瀏覽:6日期:2022-07-13 15:10:14

Python 是一種廣泛使用的解釋型、高級編程、通用型編程語言。Python 的設(shè)計(jì)哲學(xué)強(qiáng)調(diào)代碼的可讀性和簡潔的語法(尤其是使用空格縮進(jìn)劃分代碼塊,而非使用大括號或者關(guān)鍵詞)。Python 讓開發(fā)者能夠用更少的代碼表達(dá)想法,不管是小型還是大型程序,該語言都試圖讓程序的結(jié)構(gòu)清晰明了。

MQTT 是一種基于發(fā)布/訂閱模式的 輕量級物聯(lián)網(wǎng)消息傳輸協(xié)議 ,可以用極少的代碼和帶寬為聯(lián)網(wǎng)設(shè)備提供實(shí)時可靠的消息服務(wù),它廣泛應(yīng)用于物聯(lián)網(wǎng)、移動互聯(lián)網(wǎng)、智能硬件、車聯(lián)網(wǎng)、電力能源等行業(yè)。

本文主要介紹如何在 Python 項(xiàng)目中使用 paho-mqtt 客戶端庫 ,實(shí)現(xiàn)客戶端與 MQTT 服務(wù)器的連接、訂閱、取消訂閱、收發(fā)消息等功能。

項(xiàng)目初始化

本項(xiàng)目使用 Python 3.6 進(jìn)行開發(fā)測試,讀者可用如下命令確認(rèn) Python 的版本。

➜ ~ python3 --version Python 3.6.7選擇 MQTT 客戶端庫

paho-mqtt 是目前 Python 中使用較多的 MQTT 客戶端庫,它在 Python 2.7 或 3.x 上為客戶端類提供了對 MQTT v3.1 和 v3.1.1 的支持。它還提供了一些幫助程序功能,使將消息發(fā)布到 MQTT 服務(wù)器變得非常簡單。

Pip 安裝 Paho MQTT 客戶端

Pip 是 Python 包管理工具,該工具提供了對 Python 包的查找、下載、安裝、卸載的功能。

pip3 install -i https://pypi.doubanio.com/simple paho-mqttPython MQTT 使用連接 MQTT 服務(wù)器

本文將使用 EMQ X 提供的 免費(fèi)公共 MQTT 服務(wù)器 ,該服務(wù)基于 EMQ X 的 MQTT 物聯(lián)網(wǎng)云平臺 創(chuàng)建。服務(wù)器接入信息如下:

Broker: broker.emqx.io TCP Port: 1883 Websocket Port: 8083 導(dǎo)入 Paho MQTT客戶端

from paho.mqtt import client as mqtt_client設(shè)置 MQTT Broker 連接參數(shù)

設(shè)置 MQTT Broker 連接地址,端口以及 topic,同時我們調(diào)用 Python random.randint 函數(shù)隨機(jī)生成 MQTT 客戶端 id。

broker = ’broker.emqx.io’port = 1883topic = '/python/mqtt'client_id = f’python-mqtt-{random.randint(0, 1000)}’編寫 MQTT 連接函數(shù)

編寫連接回調(diào)函數(shù) on_connect ,該函數(shù)將在客戶端連接后被調(diào)用,在該函數(shù)中可以依據(jù) rc 來判斷客戶端是否連接成功。通常同時我們將創(chuàng)建一個 MQTT 客戶端,該客戶端將連接到 broker.emqx.io 。

def connect_mqtt(): def on_connect(client, userdata, flags, rc): if rc == 0: print('Connected to MQTT Broker!') else: print('Failed to connect, return code %dn', rc) # Set Connecting Client ID client = mqtt_client.Client(client_id) client.on_connect = on_connect client.connect(broker, port) return client發(fā)布消息

首先定義一個 while 循環(huán)語句,在循環(huán)中我們將設(shè)置每秒調(diào)用 MQTT 客戶端 publish 函數(shù)向 /python/mqtt 主題發(fā)送消息。

def publish(client): msg_count = 0 while True: time.sleep(1) msg = f'messages: {msg_count}' result = client.publish(topic, msg) # result: [0, 1] status = result[0] if status == 0: print(f'Send `{msg}` to topic `{topic}`') else: print(f'Failed to send message to topic {topic}') msg_count += 1訂閱消息

編寫消息回調(diào)函數(shù) on_message ,該函數(shù)將在客戶端從 MQTT Broker 收到消息后被調(diào)用,在該函數(shù)中我們將打印出訂閱的 topic 名稱以及接收到的消息內(nèi)容。

def subscribe(client: mqtt_client): def on_message(client, userdata, msg): print(f'Received `{msg.payload.decode()}` from `{msg.topic}` topic') client.subscribe(topic) client.on_message = on_message完整代碼消息發(fā)布代碼

# python 3.6import randomimport timefrom paho.mqtt import client as mqtt_clientbroker = ’broker.emqx.io’port = 1883topic = '/python/mqtt'# generate client ID with pub prefix randomlyclient_id = f’python-mqtt-{random.randint(0, 1000)}’def connect_mqtt(): def on_connect(client, userdata, flags, rc): if rc == 0: print('Connected to MQTT Broker!') else: print('Failed to connect, return code %dn', rc) client = mqtt_client.Client(client_id) client.on_connect = on_connect client.connect(broker, port) return clientdef publish(client): msg_count = 0 while True: time.sleep(1) msg = f'messages: {msg_count}' result = client.publish(topic, msg) # result: [0, 1] status = result[0] if status == 0: print(f'Send `{msg}` to topic `{topic}`') else: print(f'Failed to send message to topic {topic}') msg_count += 1def run(): client = connect_mqtt() client.loop_start() publish(client)if __name__ == ’__main__’: run()消息訂閱代碼

# python 3.6import randomimport timefrom paho.mqtt import client as mqtt_clientbroker = ’broker.emqx.io’port = 1883topic = '/python/mqtt'# generate client ID with pub prefix randomlyclient_id = f’python-mqtt-{random.randint(0, 1000)}’def connect_mqtt(): def on_connect(client, userdata, flags, rc): if rc == 0: print('Connected to MQTT Broker!') else: print('Failed to connect, return code %dn', rc) client = mqtt_client.Client(client_id) client.on_connect = on_connect client.connect(broker, port) return clientdef publish(client): msg_count = 0 while True: time.sleep(1) msg = f'messages: {msg_count}' result = client.publish(topic, msg) # result: [0, 1] status = result[0] if status == 0: print(f'Send `{msg}` to topic `{topic}`') else: print(f'Failed to send message to topic {topic}') msg_count += 1def run(): client = connect_mqtt() client.loop_start() publish(client)if __name__ == ’__main__’: run()消息訂閱代碼# python3.6import randomfrom paho.mqtt import client as mqtt_clientbroker = ’broker.emqx.io’port = 1883topic = '/python/mqtt'# generate client ID with pub prefix randomlyclient_id = f’python-mqtt-{random.randint(0, 100)}’def connect_mqtt() -> mqtt_client: def on_connect(client, userdata, flags, rc): if rc == 0: print('Connected to MQTT Broker!') else: print('Failed to connect, return code %dn', rc) client = mqtt_client.Client(client_id) client.on_connect = on_connect client.connect(broker, port) return clientdef subscribe(client: mqtt_client): def on_message(client, userdata, msg): print(f'Received `{msg.payload.decode()}` from `{msg.topic}` topic') client.subscribe(topic) client.on_message = on_messagedef run(): client = connect_mqtt() subscribe(client) client.loop_forever()if __name__ == ’__main__’: run()測試消息發(fā)布

運(yùn)行 MQTT 消息發(fā)布代碼,我們將看到客戶端連接成功,并且成功將消息發(fā)布。

python3 pub.py

在 Python 中使用 MQTT的方法

消息訂閱

運(yùn)行 MQTT 消息訂閱代碼,我們將看到客戶端連接成功,并且成功接收到發(fā)布的消息。

python3 sub.py

在 Python 中使用 MQTT的方法

總結(jié)

至此,我們完成了使用 paho-mqtt 客戶端連接到 公共 MQTT 服務(wù)器 ,并實(shí)現(xiàn)了測試客戶端與 MQTT 服務(wù)器的連接、消息發(fā)布和訂閱。

與 C ++ 或 Java 之類的高級語言不同,Python 比較適合設(shè)備側(cè)的業(yè)務(wù)邏輯實(shí)現(xiàn),使用 Python 您可以減少代碼上的邏輯復(fù)雜度,降低與設(shè)備的交互成本。我們相信在物聯(lián)網(wǎng)領(lǐng)域 Python 將會有更廣泛的應(yīng)用。

接下來我們將會陸續(xù)發(fā)布更多關(guān)于物聯(lián)網(wǎng)開發(fā)及 Python 的相關(guān)文章,敬請關(guān)注。

以上就是在 Python 中使用 MQTT的方法的詳細(xì)內(nèi)容,更多關(guān)于Python 中使用 MQTT的資料請關(guān)注好吧啦網(wǎng)其它相關(guān)文章!

標(biāo)簽: Python 編程
相關(guān)文章:
主站蜘蛛池模板: 国产精品激情小视频 | 欧美一区二区三区在线观看视频 | 成人在线免费电影 | 瑟瑟激情 | 久久男女视频 | 久久久久av | 国产精品视频久久久久久 | 在线欧美视频 | 久久激情网 | 亚洲欧美日韩精品久久亚洲区 | 小h片免费观看久久久久 | 精品国产免费一区二区三区五区 | 激情欧美日韩一区二区 | 国产男女猛烈无遮掩视频免费网站 | 国产视频第一页 | 成人久久久久久久久 | 精品国产欧美一区二区三区成人 | 中文字幕在线看人 | 一区二区三区国产精品 | 成人欧美一区二区三区黑人孕妇 | 久久国产精品免费一区二区三区 | 一区二区三区国产好 | 嫩草黄色影院 | 久久婷婷麻豆国产91天堂 | xxxxx黄色片| 成人精品鲁一区一区二区 | 免费黄色大片 | 成人国产一区二区三区精品麻豆 | 国产精品久久久久久久久久不蜜臀 | 亚洲天天干 | 国产精品揄拍一区二区久久国内亚洲精 | 男女免费在线观看视频 | 91精品国产综合久久久久 | 国产一区二区精品在线 | 中文字幕日韩欧美一区二区三区 | 欧美性成人 | 精品久久久久久 | 日韩视频在线观看中文字幕 | 一区| 亚洲成a人片 | 久久久免费观看视频 |