需要先下載外部包

堅守“ 做人真誠 · 做事靠譜 · 口碑至上 · 高效敬業(yè) ”的價值觀，專業(yè)網(wǎng)站建設(shè)服務(wù)10余年為成都餐廳設(shè)計小微創(chuàng)業(yè)公司專業(yè)提供企業(yè)網(wǎng)站建設(shè)營銷網(wǎng)站建設(shè)商城網(wǎng)站建設(shè)手機(jī)網(wǎng)站建設(shè)小程序網(wǎng)站建設(shè)網(wǎng)站改版，從內(nèi)容策劃、視覺設(shè)計、底層架構(gòu)、網(wǎng)頁布局、功能開發(fā)迭代于一體的高端網(wǎng)站建設(shè)服務(wù)。

pip install paho-mqtt

發(fā)布者

import paho.mqtt.client as mqtt

HOST = "192.168.44.31"
PORT = 1883

def Publish_Message():
    client = mqtt.Client()
    client.username_pw_set(username='admin', password='public')  # 用于添加了插件認(rèn)證方式后
    client.connect(HOST, PORT, 60)
    for x in range(10):
        Message = "hello" + str(x)
        client.publish("services", Message, 0)  # 發(fā)布一個主題為'services',內(nèi)容為‘hello x’的信息
    # time.sleep(10)
    client.loop_forever()  # 保持連接狀態(tài)

if __name__ == '__main__':
    Publish_Message()

發(fā)布者，主要內(nèi)容：publish("topic_name","utf8_message",Qos)

• Qos:0 --> 發(fā)送者只發(fā)送一次消息，不進(jìn)行重試，Broker不會返回確認(rèn)消息。Broker可能沒有接收到消息。（默認(rèn)）
• Qos:1 --> 發(fā)送者最少發(fā)送一次消息，確保消息達(dá)到Broker，Broker需要返回確認(rèn)消息PUBACK。Broker可能接收到重復(fù)消息。
• Qos:2 --> 使用兩階段確認(rèn)來保證消息的不丟失和不重復(fù)。Broker肯定會接收到消息，且只收到一次。

---

訂閱者

import paho.mqtt.client as mqtt

def on_connect(client, userdata, flags, rc):
    print("Connected with result code "+str(rc))  # rc表示返回來的狀態(tài)值
    client.subscribe("services")

def on_message(client, userdata, msg):
    print(msg.topic+" " + ":" + str(msg.payload))

if __name__ == "__main__":
    client = mqtt.Client()
    client.on_connect = on_connect
    client.on_message = on_message
    client.username_pw_set(username='admin', password='public')  # 用于添加了插件認(rèn)證方式后
    client.connect("192.168.44.31", 1883, 60)
    client.loop_forever()

訂閱者，信息的產(chǎn)出在msg.payload

rc值代表的含義：
0: Connection successful
1: Connection refused - incorrect protocol version
2: Connection refused - invalid client identifier
3: Connection refused - server unavailable
4: Connection refused - bad username or password
5: Connection refused - not authorised
6-255: Currently unused.

網(wǎng)頁名稱：python3對emqtt的簡單操作
分享網(wǎng)址：http://jinyejixie.com/article42/jopeec.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供移動網(wǎng)站建設(shè)、網(wǎng)站內(nèi)鏈、品牌網(wǎng)站制作、服務(wù)器托管、App開發(fā)、網(wǎng)站策劃

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時需注明來源： 創(chuàng)新互聯(lián)