MQTT是消息隊(duì)列遙測(cè)傳輸?shù)目s寫(xiě),是一種基于發(fā)布/訂閱范式的消息協(xié)議,它廣泛地應(yīng)用在各種性能低下的網(wǎng)絡(luò)設(shè)備或者網(wǎng)絡(luò)情況糟糕情況下的消息傳輸。在Django上安裝M
安裝MQTT
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, sys
import django
# 第一個(gè)參數(shù)固定,第二個(gè)參數(shù)是工程名稱.settings
os.environ.setdefault('DJANGO_SETTING_MODULE', 'my_django.settings')
django.setup()
# 引入mqtt包
import paho.mqtt.client as mqtt
# 使用獨(dú)立線程運(yùn)行
from threading import Thread
from app名 import models
import time
import 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_functions mqtt_functions.mqtt_run()
到此這篇在Django中使用MQTT的方法就介紹到這了,更多Django學(xué)習(xí)內(nèi)容請(qǐng)搜索W3Cschool以前的文章或繼續(xù)瀏覽下面的相關(guān)文章。