溫馨提示×
您好，登錄后才能下訂單哦！
點擊 登錄注冊 即表示同意《億速云用戶服務條款》
您好，登錄后才能下訂單哦！
需要安裝的python庫
使用python編寫程序進行測試MQTT的發布和訂閱功能。首先要安裝:pip install paho-mqtt
測試發布（pub）
我的MQTT部署在阿里云的服務器上面，所以我在本機上編寫了python程序進行測試。
然后在shell里面重新打開一個終端，訂閱一個主題為“chat” mosquitto_sub -t chat
在本機上測試遠程的MQTT的發布功能就是把自己作為一個發送信息的人，當自己發送信息的時候，所有訂閱過該主題（topic）的對象都將收到自己發送的信息。
mqtt_client.py
# encoding: utf-8
import paho.mqtt.client as mqtt
HOST = "101.200.46.138"
PORT = 1883
def test():
client = mqtt.Client()
client.connect(HOST, PORT, 60)
client.publish("chat","hello liefyuan",2) # 發布一個主題為'chat',內容為‘hello liefyuan'的信息
client.loop_forever()
if __name__ == '__main__':
test()
發布/訂閱測試
# -*- coding: utf-8 -*-
import paho.mqtt.client as mqtt
MQTTHOST = "101.200.46.138"
MQTTPORT = 1883
mqttClient = mqtt.Client()
# 連接MQTT服務器
def on_mqtt_connect():
mqttClient.connect(MQTTHOST, MQTTPORT, 60)
mqttClient.loop_start()
# publish 消息
def on_publish(topic, payload, qos):
mqttClient.publish(topic, payload, qos)
# 消息處理函數
def on_message_come(lient, userdata, msg):
print(msg.topic + " " + ":" + str(msg.payload))
# subscribe 消息
def on_subscribe():
mqttClient.subscribe("/server", 1)
mqttClient.on_message = on_message_come # 消息到來處理函數
def main():
on_mqtt_connect()
on_publish("/test/server", "Hello Python!", 1)
on_subscribe()
while True:
pass
if __name__ == '__main__':
main()
注解函數：
client.connect(self, host, port, keepalive, bind_address) client.publish(self, topic, payload, qos, retain) client.subscribe(self, topic, qos)
測試訂閱（sub）
在本機上編寫程序測試訂閱功能，就是讓自己的程序作為一個接收者，同一個主題沒有發布（pub）信息的時候，就自己一直等候。
# encoding: utf-8
import paho.mqtt.client as mqtt
def on_connect(client, userdata, flags, rc):
print("Connected with result code "+str(rc))
client.subscribe("chat")
def on_message(client, userdata, msg):
print(msg.topic+" " + ":" + str(msg.payload))
client = mqtt.Client()
client.on_connect = on_connect
client.on_message = on_message
client.connect("www.liefyuan.top", 1883, 60)
client.loop_forever()
總結
以上所述是小編給大家介紹的使用python實現mqtt的發布和訂閱,希望對大家有所幫助，如果大家有任何疑問請給我留言，小編會及時回復大家的。在此也非常感謝大家對億速云網站的支持！
如果你覺得本文對你有幫助，歡迎轉載，煩請注明出處，謝謝！
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
