使用python實現mqtt的發(fā)布和訂閱
需要安裝的python庫
使用python編寫程序進行測試MQTT的發(fā)布和訂閱功能。首先要安裝:pip install paho-mqtt
測試發(fā)布(pub)
我的MQTT部署在阿里云的服務器上面,所以我在本機上編寫了python程序進行測試。
然后在shell里面重新打開一個終端,訂閱一個主題為“chat” mosquitto_sub -t chat
在本機上測試遠程的MQTT的發(fā)布功能就是把自己作為一個發(fā)送信息的人,當自己發(fā)送信息的時候,所有訂閱過該主題(topic)的對象都將收到自己發(fā)送的信息。
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) # 發(fā)布一個主題為'chat',內容為‘hello liefyuan'的信息 client.loop_forever() if __name__ == '__main__': test()
發(fā)布/訂閱測試
# -*- 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)
在本機上編寫程序測試訂閱功能,就是讓自己的程序作為一個接收者,同一個主題沒有發(fā)布(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的發(fā)布和訂閱,希望對大家有所幫助,如果大家有任何疑問請給我留言,小編會及時回復大家的。在此也非常感謝大家對腳本之家網站的支持!
如果你覺得本文對你有幫助,歡迎轉載,煩請注明出處,謝謝!
相關文章
在Python中用has_key()方法查找鍵是否存在的教程
這篇文章主要介紹了在Python中用has_key()方法查找鍵是否存在的教程,是Python入門學習中的基礎知識,需要的朋友可以參考下2015-05-05獲取python運行輸出的數據并解析存為dataFrame實例
這篇文章主要介紹了獲取python運行輸出的數據并解析存為dataFrame實例,具有很好的參考價值,希望對大家有所幫助。一起跟隨小編過來看看吧2020-07-07json-server?如何快速搭建REST?API?服務器
json-server 是一個非常流行的開源工具,用于快速搭建一個完整的 REST API 服務器,它使用 JSON 文件作為數據源,通過簡單的配置即可模擬復雜的服務器功能,這篇文章主要介紹了json-server如何快速搭建REST API服務器,需要的朋友可以參考下2017-10-10使用Flask-Cache緩存實現給Flask提速的方法詳解
這篇文章主要介紹了使用Flask-Cache緩存實現給Flask提速的方法,結合實例形式詳細分析了Flask-Cache的安裝、配置及緩存使用相關操作技巧,需要的朋友可以參考下2019-06-06