我们知道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()

        关于django使用MQTT的方法就分享到这，希望以上内容可以对大家有一定的帮助，可以学到更多知识。如果还想要了解更多django使用MQTT技巧，大家可以关注其他相关文章。

文本转载自脚本之家

免责声明：本站发布的内容（图片、视频和文字）以原创、转载和分享为主，文章观点不代表本网站立场，如果涉及侵权请联系站长邮箱：mmqy2019@163.com进行举报，并提供相关证据，查实之后，将立刻删除涉嫌侵权内容。

猜你喜欢

• yield在协程中的用法是怎样，Python协程实践有哪些

  这篇文章主要分享的是Python协程实践，协程简单来说就是一个更加轻量级的线程，并且不由操作系统内核管理，完全由程序所控制，下文相关介绍需要的朋友可以参考一下

• Python列表的创建和销毁的实现及操作是什么

  这篇文章主要介绍了Python列表创建与销毁及缓存池机制，文章基于python展开对列表创建与销毁内容的展开，具有一定的参考价值，需要的小伙伴可以参考一下

• opencv矩形轮廓顶点定位问题怎么解决

  这篇文章主要为大家介绍了python计算机视觉opencv矩形轮廓顶点位置确定，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪

• socket模块的主要功能是什么，怎么应用

  Socket的英文原义是“孔”或“插座”。作为BSD UNIX的进程通信机制，通常也称作"套接字"，用于描述IP地址和端口，是一个通信链的句柄，可

• 用OpenCV实现对颜值打分的功能的方法是什么

  这篇文章主要介绍了通过OpenCV MediaPipe实现摄像头实时检测颜值打分功能，文中的示例代码讲解详细，对我们学习Python有一定的帮助，感兴趣的可以了解一下