django使用MQTT的方法是什么？如何安装MQTT？
发布时间：2022-03-15 16:35:22 所属栏目：语言 来源：互联网
导读：我们知道Django是由Python写成的，一个开放源代码的Web应用框架。本文主要给大家介绍django使用MQTT的方法，那么什么是MQTT？MQTT也叫做消息队列遥测传输协议，其最大优点在于，可以以极少的代码和有限的带宽，为连接远程设备提供实时可靠的消息服务。简单了
|
我们知道Django是由Python写成的，一个开放源代码的Web应用框架。本文主要给大家介绍django使用MQTT的方法，那么什么是MQTT？MQTT也叫做消息队列遥测传输协议，其最大优点在于，可以以极少的代码和有限的带宽，为连接远程设备提供实时可靠的消息服务。简单了解完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() （编辑：济源站长网） 【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容! |
