Python環(huán)境下安裝MQTT也很簡(jiǎn)單，需要注意的就是不要輸錯(cuò)命令在Python3環(huán)境下安裝Python MQTT的命令是：

pip3 install paho-mqtt使用Python MQTT

編寫(xiě)Python MQTT腳本代碼如下：

# 為了能在外部腳本中調(diào)用Django ORM模型，必須配置腳本環(huán)境變量，將腳本注冊(cè)到Django的環(huán)境變量中import os, sysimport django# 第一個(gè)參數(shù)固定，第二個(gè)參數(shù)是工程名稱.settingsos.environ.setdefault(’DJANGO_SETTING_MODULE’, ’my_django.settings’)django.setup()# 引入mqtt包import paho.mqtt.client as mqtt# 使用獨(dú)立線程運(yùn)行from threading import Threadfrom app名 import modelsimport timeimport json# 建立mqtt連接def on_connect(client, userdata, flag, rc): print('Connect with the result code ' + str(rc)) client.subscribe(’test/#’, qos=2)# 接收、處理mqtt消息def on_message(client, userdata, msg): out = str(msg.payload.decode(’utf-8’)) print(msg.topic) print(out) out = json.loads(out) # 收到消息后執(zhí)行任務(wù) if msg.topic == ’test/newdata’:print(out)# mqtt客戶端啟動(dòng)函數(shù)def mqttfunction(): global client # 使用loop_start 可以避免阻塞Django進(jìn)程，使用loop_forever()可能會(huì)阻塞系統(tǒng)進(jìn)程 # client.loop_start() # client.loop_forever() 有掉線重連功能 client.loop_forever(retry_first_connection=True)client = mqtt.Client(client_id='test', clean_session=False)# 啟動(dòng)函數(shù)def mqtt_run(): client.on_connect = on_connect client.on_message = on_message # 綁定 MQTT 服務(wù)器地址 broker = ’192.168.1.88’ # MQTT服務(wù)器的端口號(hào) client.connect(broker, 1883, 62) client.username_pw_set(’user’, ’user’) client.reconnect_delay_set(min_delay=1, max_delay=2000) # 啟動(dòng) mqttthread = Thread(target=mqttfunction) mqttthread.start()# 啟動(dòng) MQTT# mqtt_run()if __name__ == '__main__': mqtt_run()在Django項(xiàng)目中啟動(dòng)腳本

在Django2.1下，只需要在 wsgi.py 中引入要執(zhí)行的腳本文件，然后執(zhí)行啟動(dòng)函數(shù)即可。如：

from 存放MQTT腳本的模塊 import 腳本名# 假如腳本名是：mqtt_functionsmqtt_functions.mqtt_run()

到此這篇關(guān)于在Django中使用MQTT的方法的文章就介紹到這了,更多相關(guān)Django使用MQTT內(nèi)容請(qǐng)搜索好吧啦網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持好吧啦網(wǎng)！