关于物联网:如何在-Django-项目中使用-MQTT

MQTT 是一种基于公布 / 订阅模式的轻量级物联网音讯传输协定，能够用极少的代码和带宽为联网设施提供实时牢靠的音讯服务，它广泛应用于物联网、挪动互联网、智能硬件、车联网、电力能源等行业。

Django 是一个开源的 Web 框架，是目前较为风行的 Python Web 框架之一。本文次要介绍如何在 Django 我的项目中实现 MQTT 客户端与 MQTT 服务器的连贯、订阅、勾销订阅、收发音讯等性能。

本文将应用 paho-mqtt 客户端库编写一个简略 MQTT 客户端，paho-mqtt 是目前 Python 中应用较为宽泛的 MQTT 客户端库，它在 Python 2.7 及 3.x 上为客户端提供了对 MQTT v5.0、v3.1.1 和 v3.1 的反对。

我的项目初始化

本我的项目应用 Python 3.8 进行开发测试，读者可用如下命令确认 Python 的版本。

$ python3 --version
Python 3.8.2

应用 Pip 装置 Django 和 paho-mqtt。

pip3 install django
pip3 install paho-mqtt

创立 Django 我的项目。

django-admin startproject mqtt-test

创立实现后目录构造如下。

├── manage.py
└── mqtt_test
    ├── __init__.py
    ├── asgi.py
    ├── settings.py
    ├── urls.py
    ├── views.py
    └── wsgi.py

paho-mqtt 应用

本文将应用 EMQ 提供的收费公共 MQTT 服务器，该服务基于 MQTT 云服务 – EMQX Cloud 创立。服务器接入信息如下：

• Broker: broker.emqx.io
• TCP Port: 1883
• Websocket Port: 8083

导入 paho-mqtt

import paho.mqtt.client as mqtt

编写连贯回调函数

能够在该回调函数中对 MQTT 连贯胜利或失败的状况进行解决，本示例将在连贯胜利后订阅 django/mqtt 主题。

def on_connect(mqtt_client, userdata, flags, rc):
    if rc == 0:
        print('Connected successfully')
        mqtt_client.subscribe('django/mqtt')  # 订阅主题
    else:
        print('Bad connection. Code:', rc)

编写音讯回调函数

该函数将打印 django/mqtt 主题接管到的音讯。

def on_message(mqtt_client, userdata, msg):
    print(f'Received message on topic: {msg.topic} with payload: {msg.payload}')

减少 Django 配置项

在 settings.py 中减少 MQTT 服务器的配置项。读者如果对如下配置项及本文中提到的 MQTT 相干概念有疑难，可查看博客 MQTT 协定疾速体验。

本示例应用匿名认证，所以用户名与明码设置为空。

MQTT_SERVER = 'broker.emqx.io'
MQTT_PORT = 1883
MQTT_KEEPALIVE = 60
MQTT_USER = ''MQTT_PASSWORD =''

配置 MQTT 客户端

client = mqtt.Client()
client.on_connect = on_connect
client.on_message = on_message
client.username_pw_set(settings.MQTT_USER, settings.MQTT_PASSWORD)
client.connect(
    host=settings.MQTT_SERVER,
    port=settings.MQTT_PORT,
    keepalive=settings.MQTT_KEEPALIVE
)

创立公布音讯接口

咱们创立一个简略的 POST 接口实现 MQTT 音讯公布。

在理论利用中该接口可能须要进行一些更简单的业务逻辑解决。

在 views.py 中减少如下代码。

import json
from django.http import JsonResponse
from mqtt_test.mqtt import client as mqtt_client


def publish_message(request):
    request_data = json.loads(request.body)
    rc, mid = mqtt_client.publish(request_data['topic'], request_data['msg'])
    return JsonResponse({'code': rc})

在 urls.py 中减少如下代码。

from django.urls import path
from . import views

urlpatterns = [path('publish', views.publish_message, name='publish'),
]

启动 MQTT 客户端

在 __init__.py 中减少如下代码。

from . import mqtt
mqtt.client.loop_start()

至此咱们已实现了所有代码的编写，查看残缺代码。

最初，执行如下命令运行 Django 我的项目。

python3 manage.py runserver

当 Django 利用启动后，MQTT 客户端将会连贯到 MQTT 服务器，并且订阅主题 django/mqtt。

测试

接下来咱们应用开源的跨平台 MQTT 客户端 – MQTT X 进行连贯、订阅、公布测试。

测试音讯接管

1. 在 MQTT X 中创立 MQTT 连贯，输出连贯名称，其余参数放弃默认，并点击右上角的 Connect 按钮连贯至服务器。
2. 在 MQTT X 底部的音讯公布框里向 django/mqtt 主题公布音讯 Hello from MQTT X。
3. 在 Django 运行窗口中将能看到 MQTT X 发送的音讯。

测试音讯公布接口

1. 在 MQTT X 中订阅 django/mqtt 主题。

2. 应用 Postman 调用 /publish 接口：发送音讯 Hello from Django 至 django/mqtt 主题。

3. 在 MQTT X 中将能看到 Django 发送过去的音讯。

   总结

至此，咱们应用 paho-mqtt 实现了 MQTT 客户端的开发，实现了在 Django 利用中应用 MQTT 进行通信。在理论利用中，咱们能够依据业务需要对 MQTT 客户端进行扩大，实现更简单的业务逻辑。接下来，读者可查看 EMQ 提供的 MQTT 入门与进阶系列文章理解 MQTT 协定个性，摸索 MQTT 的更多高级利用，开始 MQTT 利用及服务开发。

版权申明：本文为 EMQ 原创，转载请注明出处。

原文链接：[https://www.emqx.com/zh/blog/…](