python mqtt 客戶端的實(shí)現(xiàn)代碼實(shí)例
更新時(shí)間：2019年09月25日 10:39:24 作者：瘋狂的小蘿卜頭
這篇文章主要介紹了python mqtt 客戶端代碼實(shí)例,文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下
這篇文章主要介紹了python mqtt 客戶端代碼實(shí)例,文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下
安裝paho-mqtt
pip install paho-mqtt -i http://pypi.douban.com/simple --trusted-host pypi.douban.com
python消息收發(fā)實(shí)現(xiàn)
import paho.mqtt.client as mqtt from multiprocessing import Process import camera_person_num MQTTHOST = "172.19.4.4" MQTTPORT = 1883 mqttClient = mqtt.Client()
# 連接MQTT服務(wù)器 def on_mqtt_connect(): mqttClient.connect(MQTTHOST, MQTTPORT, 60) mqttClient.loop_start()
# 消息處理函數(shù)
def on_message_come(lient, userdata, msg):
print(msg.topic + ":" + str(msg.payload.decode("utf-8")))
# 消息處理開啟多進(jìn)程
p = Process(target=talk, args=("/camera/person/num/result", msg.payload.decode("utf-8")))
p.start()
# subscribe 消息訂閱
def on_subscribe():
mqttClient.subscribe("test", 1) # 主題為"test"
mqttClient.on_message = on_message_come # 消息到來(lái)處理函數(shù)
# publish 消息發(fā)布
def on_publish(topic, msg, qos):
mqttClient.publish(topic, msg, qos);
# 多進(jìn)程中發(fā)布消息需要重新初始化mqttClient
def talk(topic, msg):
cameraPsersonNum = camera_person_num.CameraPsersonNum(msg)
t_max, t_mean = cameraPsersonNum.personNum()
mqttClient = mqtt.Client()
mqttClient.connect(MQTTHOST, MQTTPORT, 60)
mqttClient.loop_start()
mqttClient.publish(topic, '{"max":' + str(t_max) + ',"mean:"' + str(t_mean) + '}', 1)
def main():
on_mqtt_connect()
on_subscribe()
while True:
pass
if __name__ == '__main__':
main()
以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。
相關(guān)文章
cx_Freeze是一個(gè)流行的Python庫(kù),它可以將Python腳本及其依賴項(xiàng)打包成獨(dú)立的可執(zhí)行文件,支持多平臺(tái)（如Windows、Linux和macOS）,本文將結(jié)合實(shí)際案例,詳細(xì)介紹cx_Freeze的安裝、配置和使用方法,需要的朋友可以參考下2024-08-08
這篇文章主要介紹了python使用SQLAlchemy操作MySQL，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2020-01-01
Python實(shí)現(xiàn)隱馬爾可夫模型的前向后向算法的示例代碼
這篇文章主要介紹了Python實(shí)現(xiàn)隱馬爾可夫模型的前向后向算法,本文通過(guò)實(shí)例代碼給大家講解的非常詳細(xì)，具有一定的參考借鑒價(jià)值，需要的朋友可以參考下2019-12-12
Python+PyQt5開發(fā)一個(gè)Windows電腦啟動(dòng)項(xiàng)管理神器
這篇文章主要介紹了如何使用PyQt5開發(fā)一款顏值與功能并存的Windows啟動(dòng)項(xiàng)管理工具,不僅能查看/刪除現(xiàn)有啟動(dòng)項(xiàng),還能智能添加新啟動(dòng)項(xiàng),支持拖拽操作,下面就跟隨小編一起了解一下吧2025-05-05
python實(shí)現(xiàn)內(nèi)存監(jiān)控系統(tǒng)
這篇文章主要為大家詳細(xì)介紹了python實(shí)現(xiàn)內(nèi)存監(jiān)控系統(tǒng)，通過(guò)系統(tǒng)命令或操作系統(tǒng)文件獲取到內(nèi)存信息，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2018-06-06
這篇文章主要介紹了Python socket編程,以實(shí)例形式較為詳細(xì)的分析了Python中socket模塊的使用技巧,非常具有實(shí)用價(jià)值,需要的朋友可以參考下2015-05-05
這篇文章主要介紹了Flask框架各種常見(jiàn)裝飾器,結(jié)合實(shí)例形式簡(jiǎn)單分析了flask框架各種常見(jiàn)裝飾器的功能、用法及相關(guān)操作注意事項(xiàng),需要的朋友可以參考下2018-07-07
這篇文章主要介紹了pandas DataFrame的修改方法(值、列、索引)，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2019-08-08
python利用pytesseract 實(shí)現(xiàn)本地識(shí)別圖片文字
這篇文章主要介紹了python利用pytesseract 實(shí)現(xiàn)本地識(shí)別圖片文字，幫助大家更好的理解和使用python，感興趣的朋友可以了解下2020-12-12
Python實(shí)現(xiàn)Linux服務(wù)器自動(dòng)巡檢腳本
這篇文章主要為大家介紹了一個(gè)使用Python語(yǔ)言實(shí)現(xiàn)的Linux服務(wù)器自動(dòng)巡檢腳本,只需配置服務(wù)器ip、用戶名、密碼即可實(shí)現(xiàn)服務(wù)器自動(dòng)巡檢,巡檢日志以txt文件輸出,免去了挨個(gè)敲命令巡檢的麻煩2025-06-06