在Django中如何使用MQTT的方法

這篇文章主要介紹了在Django中如何使用MQTT的方法，具有一定借鑒價值，感興趣的朋友可以參考下，希望大家閱讀完這篇文章之后大有收獲，下面讓小編帶著大家一起了解一下。

安裝MQTT

Python環境下安裝MQTT也很簡單，需要注意的就是不要輸錯命令
在Python3環境下安裝Python MQTT的命令是：

pip3 install paho-mqtt

使用Python MQTT

編寫Python MQTT腳本
代碼如下：

# 為了能在外部腳本中調用Django ORM模型，必須配置腳本環境變量，將腳本注冊到Django的環境變量中
import os, sys
import django
# 第一個參數固定，第二個參數是工程名稱.settings
os.environ.setdefault('DJANGO_SETTING_MODULE', 'my_django.settings')
django.setup()

# 引入mqtt包
import paho.mqtt.client as mqtt
# 使用獨立線程運行
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)

    # 收到消息后執行任務
    if msg.topic == 'test/newdata':
        print(out)

# mqtt客戶端啟動函數
def mqttfunction():
    global client
    # 使用loop_start 可以避免阻塞Django進程，使用loop_forever()可能會阻塞系統進程
    # client.loop_start()
    # client.loop_forever() 有掉線重連功能
    client.loop_forever(retry_first_connection=True)

client = mqtt.Client(client_id="test", clean_session=False)

# 啟動函數
def mqtt_run():
    client.on_connect = on_connect
    client.on_message = on_message
    # 綁定 MQTT 服務器地址
    broker = '192.168.1.88'
    # MQTT服務器的端口號
    client.connect(broker, 1883, 62)
    client.username_pw_set('user', 'user')
    client.reconnect_delay_set(min_delay=1, max_delay=2000)
    # 啟動
    mqttthread = Thread(target=mqttfunction)
    mqttthread.start()

# 啟動 MQTT
# mqtt_run()

if __name__ == "__main__":
    mqtt_run()

在Django項目中啟動腳本

在Django2.1下，只需要在 wsgi.py 中引入要執行的腳本文件，然后執行啟動函數即可。
如：

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

感謝你能夠認真閱讀完這篇文章，希望小編分享的“在Django中如何使用MQTT的方法”這篇文章對大家有幫助，同時也希望大家多多支持億速云，關注億速云行業資訊頻道，更多相關知識等著你來學習!