在当前的数字化时代，实时数据交流和物联网(IoT)技术正快速增长，开发者们正在寻找更高效和更稳定的方法来处理数据流。在这方面，MQTT 和 Django 都已经成为了各自领域的领导者。在本文中，我们将介绍如何将这两个强大的工具集成在一起，以打造一个稳定、快速的实时通讯系统。

Django 简介及其特点

如何在 Django 项目中使用 MQTT-MQTT中文站

Django 是一个开放源代码的 Web 开发框架，由 Python 语言编写。它鼓励“不要重复自己”的设计哲学和“框架即插件”的结构，使得开发者能够快速、高效地构建高品质的 Web 应用程序。以下是 Django 的主要特点：

  • DRY原则 (Don't Repeat Yourself)：Django 遵循 DRY 原则，意味着系统应尽量避免重复的功能和信息。
  • 安全性：Django 自带了防范多种网络攻击的功能，如 CSRF、XSS、SQL注入等。
  • 可扩展性：它的“框架即插件”结构使得开发者可以轻松地添加功能和组件。
  • MVC 架构：Django 遵循模型-视图-控制器 (MVC) 设计模式，帮助开发者组织代码和逻辑。

MQTT 简介及其特点

MQTT (Message Queuing Telemetry Transport) 是一种基于发布/订阅模式的轻量级消息传递协议，特别适用于低带宽、不稳定的网络环境。以下是 MQTT 的主要特点：

  • 轻量级：MQTT 是为低带宽和低功耗的设备设计的，它的协议头非常小。
  • 质量服务等级：MQTT 提供三种消息交付级别：At most once、At least once、Exactly once，使得开发者可以根据需要选择合适的级别。
  • 持久性会话：MQTT 支持持久会话，即客户端可以选择保持其会话信息，从而避免频繁的重新连接。
  • Last Will 和 Testament (LWT) 消息：这是一个预定义的消息，只有在发布者失去连接时，才会被发布。

有了上述背景知识，我们现在可以探讨如何在 Django 项目中整合 MQTT，实现实时通信。

初始化项目

首先，我们将使用 Python 3.8 作为开发环境，你可以通过以下命令确认你的 Python 版本：

$ python3 --version
Python 3.8.2

接着，使用 Pip 安装所需的包：

pip3 install django paho-mqtt

然后，创建一个新的 Django 项目：

django-admin startproject mqtt_test

项目结构如下：

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

MQTT 的整合

我们将使用由 EMQ 提供的公共 MQTT 服务器，服务器信息如下：

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

首先，导入必要的库：

import paho.mqtt.client as mqtt

设置连接的回调函数。成功连接后，我们将订阅到 django/mqtt 主题：

def on_connect(mqtt_client, userdata, flags, rc):
    if rc == 0:
        print('Connected successfully')
        mqtt_client.subscribe('django/mqtt')
    else:
        print('Connection failed. Code:', rc)

设置接收消息的回调函数：

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

在 settings.py 中配置 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
)

为了演示，我们创建一个发布消息的接口：

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 中，将接口与 URL 进行绑定：

from django.urls import path
from . import views

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

最后，在 __init__.py 中启动 MQTT 客户端：

from . import mqtt
mqtt.client.loop_start()

运行项目

执行以下命令，启动 Django 项目：

python3 manage.py runserver

项目启动后，MQTT 客户端将连接服务器，并订阅 django/mqtt 主题。

至此，我们已成功在 Django 项目中整合了 MQTT。这为你提供了一个强大的实时消息功能，无论是 IoT 项目还是其他实时更新的应用，这种结合都会带来巨大的便利。

打赏微海报分享