在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()