在Django中使用MQTT的方法
短信预约 -IT技能 免费直播动态提醒
安装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的方法的文章就介绍到这了,更多相关Django使用MQTT内容请搜索编程网以前的文章或继续浏览下面的相关文章希望大家以后多多支持编程网！
免责声明：
① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的，并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据，供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。
② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341
