物联网之MQTT

2024-09-02 23:52
文章标签 mqtt 联网

本文主要是介绍物联网之MQTT，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

一，MQTT 及其在物联网中的应用

MQTT（Message Queuing Telemetry Transport）是一种轻量级的消息传输协议，设计用于低带宽、延迟高、不稳定的网络环境，特别适合物联网（IoT）应用。它采用了发布/订阅（Pub/Sub）模型，以简化设备之间的消息交换，是物联网领域广泛采用的通信协议之一。

MQTT 的核心概念：

  1. Broker（消息代理）：MQTT Broker 是 MQTT 通信的核心，负责接收、存储并分发消息。所有客户端通过 Broker 进行通信，客户端之间不会直接相互通信。
  2. Publisher（发布者）：客户端可以作为发布者，向某个主题（Topic）发布消息。
  3. Subscriber（订阅者）：客户端可以订阅一个或多个主题，Broker 会将对应主题的消息推送给订阅者。
  4. Topic（主题）：消息通过主题组织，Publisher 发布消息时会指定主题，Subscriber 订阅相应主题来接收消息。
  5. QoS（服务质量）：MQTT 提供三种消息传递服务质量：
    QoS 0：消息最多传递一次，不保证消息会被成功接收。
    QoS 1：消息至少传递一次，保证消息至少会被接收到一次。
    QoS 2：消息传递一次且仅一次，保证消息不会重复或丢失。

MQTT 专为物联网(IoT)设备和低带宽、高延迟或不可靠的网络设计。它的主要特点包括:

  • 轻量级: 协议简单,消息开销小,适合资源受限的设备。
  • 发布/订阅模式: 允许一对多的消息分发和应用程序解耦。
  • 可靠性: 提供三种服务质量级别(QoS),确保消息传递。
  • 安全性: 支持TLS加密和用户名/密码认证。
  • 保留消息: 可以存储最后一条消息,新订阅者可立即获得最新状态。

由于其轻量级的特性，MQTT 广泛应用于物联网中，适用于以下场景：

  • 远程监控与管理：通过 MQTT 协议，物联网设备（如传感器、智能家居设备等）可以定期向服务器上传数据，实现远程监控。服务器也可以通过 MQTT 向设备发送控制命令，进行远程管理。
  • 实时数据传输：MQTT 支持低延迟的消息传输，适合需要实时数据更新的场景，如工业自动化、智能电网、车联网等。
  • 低功耗设备通信：由于 MQTT 协议的低带宽和低开销，适合电池供电的物联网设备，通过节省功耗延长设备的使用寿命。
  • 智能家居：MQTT 协议广泛应用于智能家居系统中，例如控制灯光、恒温器、安防设备等，用户可以通过手机或其他终端远程控制家中的设备。
  • 车联网（V2X）：在车联网中，MQTT 可以用于车辆与后台服务器之间的数据传输，如状态监控、远程控制、紧急事件处理等。

在典型的物联网架构中，MQTT 作为一种协议桥接了物联网设备与云平台之间的数据传输，架构通常包括以下主要部分：

  • 物联网设备（IoT Devices）：如传感器、智能家居设备等，设备通过 MQTT 协议将数据发布到 MQTT Broker，也可以订阅主题接收命令。
  • MQTT Broker：位于物联网系统的核心位置，负责管理客户端的连接和消息的传输。所有设备和服务器的通信都通过 Broker 进行，Broker 根据主题分发消息。
  • 云平台（Cloud Platform）：云平台通常订阅设备的数据主题，接收到设备上传的数据进行存储和处理。云平台也可以通过 Broker 向设备发布控制命令。
  • 用户终端（User Interface）：通过手机应用、网页等形式，用户可以远程查看设备状态和数据，并发送控制命令，控制物联网设备的运行。
         +--------------------+         +--------------------+|                    |         |                    ||  User Interface    |         |    Cloud Platform  ||      (Mobile)      |         |(Web App, Analytics)|+--------------------+         +--------------------+^                                ^|                                ||        Subscribe/Publish       ||                                |v                                v+----------------------------------------------+|               MQTT Broker                    ||    (Mosquitto, EMQX, HiveMQ, etc.)           |+----------------------------------------------+^                                ^|                                |Publish|                                |Subscribe|                                |v                                v+--------------------+              +--------------------+|  IoT Device 1       |              |  IoT Device 2       || (Sensors, Actuators)|              | (Sensors, Actuators)|+--------------------+              +--------------------+
  1. 物联网设备（如 IoT Device 1 和 IoT Device 2）通过 MQTT 协议连接到 Broker，并且分别发布数据或订阅控制命令的主题。
  2. MQTT Broker 是中心节点，负责接收物联网设备发布的消息，并将消息推送给订阅者（如云平台或用户终端）。
  3. 云平台 订阅设备的数据，并通过处理这些数据实现监控、分析或控制操作。云平台也可以通过发布控制命令，控制物联网设备的行为。
  4. 用户终端（如移动应用或 Web 界面）允许用户查看设备的状态和数据，并发送控制命令到云平台，云平台再通过 MQTT Broker 传递给相应的物联网设备。

二，在 Windows 10 中安装与测试 MQTT broker

  1. 下载 Mosquitto:
    - 访问 https://mosquitto.org/download/
    - 下载最新版本的 Windows 安装程序 (64-bit)

  2. 安装 Mosquitto:
    - 运行下载的安装程序
    - 按照安装向导的提示进行操作

  3. 添加 添加 Mosquitto 安装路径到系统路径。

  4. 配置 Mosquitto:
    - 打开记事本，以管理员身份运行
    - 打开安装路径的文件: mosquitto.conf
    - 添加或修改以下行:

     listener 1883 # MQTT默认端口allow_anonymous true # 允许匿名连接(仅用于测试)persistence true # 开启持久化,重启后保留消息persistence_location G:\mosquitto\data # 持久化文件存储路径

  5. 启动 Mosquitto 服务:

    • 打开命令提示符（以管理员身份运行）
    • 输入以下命令:
       net start mosquitto

  6. 设置 Mosquitto 为自动启动:
    - 打开 “Services” (服务)
    - 找到 “Mosquitto Broker” 服务
    - 右击并选择 “Properties”
    - 将 “Startup type” 设置为 “Automatic”
    - 点击 “Apply” 然后 “OK”

  7. 测试 Mosquitto:
    - 打开两个命令提示符窗口
    - 在第一个窗口中，输入订阅命令: mosquitto_sub -t test/topic
    - 在第二个窗口中，输入发布命令: mosquitto_pub -t test/topic -m “Hello MQTT”
    - 如果在第一个窗口中看到 “Hello MQTT”，则说明 Mosquitto 运行正常

  8. 安全配置(生产环境)——启用用户认证:
    - 添加用户: mosquitto_passwd -c G:\mosquitto\passwd username
    - 在配置文件中启用认证: password_file G:\mosquitto\password.txt

  9. 监控和日志
    - 查看Mosquitto日志文件: G:\mosquitto\log\mosquitto.log
    - 使用工具如Prometheus+Grafana对Mosquitto进行监控

三，物联网设备通过 MQTT 发布与订阅数据

（一）模拟

由于手边暂时没有设备，这里就用python写一个程序来模拟。

1，首先开一个命令行窗口启动 MQTT：

G:\mosquitto>mosquitto -v
1725282189: mosquitto version 2.0.18 starting
1725282189: Using default config.
1725282189: Starting in local only mode. Connections will only be possible from clients running on this machine.
1725282189: Create a configuration file which defines a listener to allow remote access.
1725282189: For more details see https://mosquitto.org/documentation/authentication-methods/
1725282189: Opening ipv4 listen socket on port 1883.
1725282189: Opening ipv6 listen socket on port 1883.
1725282189: mosquitto version 2.0.18 running
  • 此命令会启动 Mosquitto 并以详细模式输出日志。

2，编写模拟物联网设备的 Python 客户端。
用 paho-mqtt Python 库，它是一个流行的 MQTT 客户端库，可以方便地发布和订阅消息。

import json
import random
import timeimport paho.mqtt.client as mqtt# MQTT Broker 的地址和端口
broker_address = "localhost"  # 本地服务器
broker_port = 1883# 设备 ID
device_id = "device_001"
data_topic = f"devices/{device_id}/data"
control_topic = f"devices/{device_id}/control"# MQTT 客户端
client = mqtt.Client(mqtt.CallbackAPIVersion.VERSION1, device_id)# 连接回调函数
def on_connect(client, userdata, flags, rc):print(f"Connected with result code {rc}")# 连接成功后，订阅控制命令主题client.subscribe(control_topic)# 消息回调函数
def on_message(client, userdata, msg):print(f"Message received from {msg.topic}: {msg.payload.decode()}")# 连接 MQTT 服务器
client.on_connect = on_connect
client.on_message = on_message
client.connect(broker_address, broker_port, 60)# 启动 MQTT 客户端的网络循环
client.loop_start()# 模拟设备定期发送数据
try:while True:# 模拟传感器数据sensor_data = {"temperature": round(random.uniform(20.0, 30.0), 2),"humidity": round(random.uniform(30.0, 70.0), 2),"timestamp": time.strftime('%Y-%m-%d %H:%M:%S', time.localtime())}# 将数据发布到 data_topicclient.publish(data_topic, json.dumps(sensor_data))print(f"Published data: {sensor_data}")# 每隔 5 秒发送一次数据time.sleep(5)except KeyboardInterrupt:print("Simulation stopped.")# 停止 MQTT 客户端
client.loop_stop()
client.disconnect()
  • 运行 Python 脚本，模拟设备会定期向 devices/device_001/data 主题发布传感器数据

3，测试设备与 MQTT Broker 的通信。
开一个命令行窗口监听设备数据：

mosquitto_sub -h localhost -t "devices/device_001/data"

在这里插入图片描述
开一个命令行窗口发送控制命令：

mosquitto_pub -h localhost -t "devices/device_001/control" -m '{"command": "turn_on", "target": "fan"}'

在这里插入图片描述

（二）使用 ESP8266 + DHT11 + MicroPython

使用ESP8266外接一个DHT11温湿度传感器，用MicroPython编程，让ESP8266采集温湿度数据，并通过MQTT发送到部署在电脑上的MQTTbroker。

1，硬件：
- ESP8266 板子（如 NodeMCU 或 Wemos D1 Mini）
- DHT11 温湿度传感器

2，接线：
- DHT11 VCC → ESP8266 3.3V
- DHT11 GND → ESP8266 GND
- DHT11 数据引脚 → ESP8266 GPIO 引脚（如 GPIO 2/D4）

3，下载并将 MicroPython 固件刷入 ESP8266 板子上：

  • 安装 esptool.py：pip install esptool
  • 刷入固件：
    esptool.py --port /dev/ttyUSB0 erase_flash
esptool.py --port /dev/ttyUSB0 --baud 460800 write_flash --flash_size=detect 0 esp8266-<version>.bin

4，连接到 ESP8266：
通过串口工具（如 PuTTY 或 Thonny），连接到 ESP8266，使用 REPL 进行调试和执行 MicroPython 代码。

5，安装 MQTT 和 DHT11 驱动：
MicroPython 中已经有内置的 umqtt 和 dht 模块，用于 MQTT 通信和 DHT11 传感器数据采集。

6，编写 MicroPython 代码：

import network
import time
import dht
import machine
from umqtt.simple import MQTTClient# Wi-Fi 配置
SSID = 'your_ssid'
PASSWORD = 'your_password'# MQTT Broker 配置
MQTT_BROKER = '192.168.1.100'  # 电脑上的 MQTT Broker IP
MQTT_TOPIC = 'home/temperature'
CLIENT_ID = 'esp8266_dht11'# 连接 Wi-Fi
def connect_wifi(ssid, password):wlan = network.WLAN(network.STA_IF)wlan.active(True)if not wlan.isconnected():print('Connecting to network...')wlan.connect(ssid, password)while not wlan.isconnected():passprint('Network connected:', wlan.ifconfig())# 初始化 DHT11 传感器
dht_pin = machine.Pin(2)  # DHT11 数据引脚接到 GPIO2/D4
sensor = dht.DHT11(dht_pin)# 连接 Wi-Fi
connect_wifi(SSID, PASSWORD)# 连接 MQTT
client = MQTTClient(CLIENT_ID, MQTT_BROKER)
client.connect()try:while True:# 采集数据sensor.measure()temperature = sensor.temperature()humidity = sensor.humidity()# 创建消息msg = f'{{"temperature": {temperature}, "humidity": {humidity}}}'print('Publishing:', msg)# 发布到 MQTT 服务器：消息会发布到 home/temperature 主题上。client.publish(MQTT_TOPIC, msg)# 每隔10秒发送一次数据time.sleep(10)except KeyboardInterrupt:print("Stopping...")client.disconnect()
  • 连接到 Wi-Fi。
  • 使用 DHT11 传感器采集温湿度数据。
  • 将数据通过 MQTT 协议发送到本地的 MQTT Broker。

四，云平台通过 MQTT 订阅数据与发布命令

云平台要做的就是：

  • 接收 MQTT 消息：Django 应用需要订阅 MQTT Broker 的温度数据。
  • 分析数据并作出决策：当接收到的温度数据超过 50°C 时，发送命令打开风扇，否则关闭风扇。
  • 通过 MQTT 发送控制命令：使用 Django 应用中的 MQTT 客户端发送控制命令（如 fan/on 或 fan/off）到 MQTT Broker，控制风扇。

1，接收温度数据并分析。
创建一个管理命令（management command）来启动 MQTT 客户端并订阅主题。

# myapp/
#  management/
#    commands/
#      mqtt_subscriber.pyimport json
import paho.mqtt.client as mqtt
from django.core.management.base import BaseCommandMQTT_BROKER = 'localhost'  # MQTT Broker 地址
TEMPERATURE_TOPIC = 'home/temperature'  # 订阅的温度主题
FAN_CONTROL_TOPIC = 'home/fan/control'  # 风扇控制命令主题
CLIENT_ID = 'django_subscriber'# 温度阈值
TEMP_THRESHOLD = 50  # 摄氏度# 定义 MQTT 客户端回调函数
def on_connect(client, userdata, flags, rc):print(f"Connected with result code {rc}")client.subscribe(TEMPERATURE_TOPIC)def on_message(client, userdata, msg):print(f"Message received from {msg.topic}: {msg.payload.decode()}")try:# 解析消息并提取温度数据data = json.loads(msg.payload.decode())temperature = data.get('temperature')# 检查温度是否超过阈值，并发送控制命令if temperature is not None:if temperature > TEMP_THRESHOLD:print("Temperature is above 50°C. Turning on the fan.")client.publish(FAN_CONTROL_TOPIC, 'on')else:print("Temperature is below 50°C. Turning off the fan.")client.publish(FAN_CONTROL_TOPIC, 'off')else:print("No temperature data found.")except Exception as e:print(f"Error processing message: {e}")class Command(BaseCommand):help = 'Start MQTT subscriber and control fan based on temperature'def handle(self, *args, **kwargs):# 创建 MQTT 客户端并设置回调client = mqtt.Client(CLIENT_ID)client.on_connect = on_connectclient.on_message = on_message# 连接 MQTT Brokerclient.connect(MQTT_BROKER, 1883, 60)# 开始 MQTT 客户端的循环try:client.loop_forever()except KeyboardInterrupt:client.disconnect()print("MQTT client disconnected.")

在项目根目录下运行以下命令启动 MQTT 订阅服务：

python manage.py mqtt_subscriber

2，ESP8266 接收风扇控制命令并控制风扇。
在 ESP8266 上编写代码，订阅 home/fan/control 主题，并根据接收到的消息来控制电机（模拟风扇）。

import machine
import network
import time
from umqtt.simple import MQTTClient# Wi-Fi 配置
SSID = 'your_ssid'
PASSWORD = 'your_password'# MQTT 配置
MQTT_BROKER = '192.168.1.100'  # 电脑上的 MQTT Broker IP
FAN_CONTROL_TOPIC = 'home/fan/control'
CLIENT_ID = 'esp8266_fan_controller'# 定义 GPIO 引脚来控制电机（风扇）
fan_pin = machine.Pin(5, machine.Pin.OUT)  # GPIO5/D1# 连接 Wi-Fi
def connect_wifi(ssid, password):wlan = network.WLAN(network.STA_IF)wlan.active(True)if not wlan.isconnected():print('Connecting to network...')wlan.connect(ssid, password)while not wlan.isconnected():passprint('Network connected:', wlan.ifconfig())# MQTT 回调函数
def on_message(topic, msg):print(f"Message received on topic {topic}: {msg}")if msg == b'on':fan_pin.on()  # 打开风扇print("Fan turned on")elif msg == b'off':fan_pin.off()  # 关闭风扇print("Fan turned off")# 连接 Wi-Fi
connect_wifi(SSID, PASSWORD)# 连接 MQTT Broker 并订阅主题
client = MQTTClient(CLIENT_ID, MQTT_BROKER)
client.set_callback(on_message)
client.connect()
client.subscribe(FAN_CONTROL_TOPIC)try:while True:client.check_msg()  # 检查是否有新消息time.sleep(1)except KeyboardInterrupt:print("Disconnecting from broker.")client.disconnect()

这篇关于物联网之MQTT的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/1131434。

相关文章

物联网之流水LED灯、正常流水灯、反复流水灯、移动流水灯

物联网之流水LED灯、正常流水灯、反复流水灯、移动流水灯

MENU 硬件电路设计软件程序设计正常流水LED灯反复流水LED灯移动流水LED灯 硬件电路设计 材料名称数量直插式LED1kΩ电阻杜邦线(跳线)若干面包板1 每一个LED的正极与开发板一个GPIO引脚相连，并串联一个电阻，负极接GND。 当然也可以选择只使用一个电阻。 软件程序设计 正常流水LED灯 因为要用到多个GPIO引脚，所以最好把所有的GPI
阅读更多...
4G模块、WIFI模块、NBIOT模块通过AT指令连接华为云物联网服务器（MQTT协议）

4G模块、WIFI模块、NBIOT模块通过AT指令连接华为云物联网服务器（MQTT协议）

MQTT协议概述 MQTT（Message Queuing Telemetry Transport）是一种轻量级的消息传输协议，它被设计用来提供一对多的消息分发和应用之间的通讯，尤其适用于远程位置的设备和高延迟或低带宽的网络。MQTT协议基于客户端-服务器架构，客户端可以订阅任意数量的主题，并可以发布消息到这些主题。服务器（通常称为MQTT Broker）则负责接受来自客户端的连接请求，并转发消
阅读更多...
HTTP协议 HTTPS协议 MQTT协议介绍

HTTP协议 HTTPS协议 MQTT协议介绍

目录 一．HTTP协议 1. HTTP 协议介绍 基本介绍： 协议：  注意： 2. HTTP 协议的工作过程 基础术语： 客户端： 主动发起网络请求的一端 服务器： 被动接收网络请求的一端 请求： 客户端给服务器发送的数据 响应： 服务器给客户端返回的数据 HTTP 协议的重要特点： 一发一收，一问一答 注意： 网络编程中，除了一发一收之外，还有其它的模式 二．HTT
阅读更多...
【知识分享】MQTT实战-使用mosquitto客户端连接emqx服务器

【知识分享】MQTT实战-使用mosquitto客户端连接emqx服务器

一、简介     MQTT（Message Queuing Telemetry Transport）是一种轻量级的、基于发布/订阅模式的通信协议，旨在实现物联网设备之间的低带宽、高延迟的通信。MQTT协议设计简洁，使用TCP/IP协议进行通信，适用于各种网络环境，尤其适合在有限的网络带宽和不稳定的网络连接条件下进行通信。     MQTT的工作原理是基于发布/订阅模式的消息传递，它包括两个主要
阅读更多...
物联网——DMA+AD多通道

物联网——DMA+AD多通道

DMA简介 存储器映像 某些数据在运行时不会发生变化，则设置为常量，存在Flash存储器中，节省运行内存的空间 DMA结构图 DMA访问权限高于cpu 结构要素 软件触发源：存储器到存储器传输完成后，计数器清零 硬件触发源：ADC、定时器、串口 重写计数器时，需关闭DMA DMA请求 数据宽度与对齐 目标宽度小于传输带宽：高位补零，反之，舍弃高位 数据转运与D
阅读更多...
基于 RocketMQ 的云原生 MQTT 消息引擎设计

基于 RocketMQ 的云原生 MQTT 消息引擎设计

作者：沁君 概述 随着智能家居、工业互联网和车联网的迅猛发展，面向 IoT（物联网）设备类的消息通讯需求正在经历前所未有的增长。在这样的背景下，高效和可靠的消息传输标准成为了枢纽。MQTT 协议作为新一代物联网场景中得到广泛认可的协议，正逐渐成为行业标准。 本次我们将介绍搭建在 RocketMQ 基础上实现的 MQTT 核心设计，本文重点分析 RocketMQ 如何适应这些变化，通过优化存储
阅读更多...
智能交通系统如何利用大数据、云计算和物联网技术优化交通流量、减少拥堵｜智能交通系统｜大数据｜云计算｜物联网｜交通流量优化｜减少拥堵

智能交通系统如何利用大数据、云计算和物联网技术优化交通流量、减少拥堵｜智能交通系统｜大数据｜云计算｜物联网｜交通流量优化｜减少拥堵

目录 1. 智能交通系统的定义与构成 1.1 智能交通系统的组成 1.2 智能交通系统的目标 2. 大数据技术在智能交通中的应用 2.1 交通数据采集与分析 2.2 实时交通监控与预测 3. 云计算在智能交通中的作用 3.1 云平台的数据处理能力 3.2 云计算的弹性扩展 4. 物联网技术在智能交通中的应用 4.1 智能信号灯控制系统 4.2 智能停车系统 5. 智能交通
阅读更多...
MQTT协议中信息长度MSG len字段分析

MQTT协议中信息长度MSG len字段分析

截图自： 主要是说数据字节长度的计算： 每个字节由1个持续位和7个数据位组成：如果持续位为1，表示接下来的一个字节仍然表示长度的一部分 7个数据位表示的数据     0-127   共计128个数字 所以如上图的表格所示 1个字节，2个字节，3个字节，4个字节的数据范围 切记：MQTT长度的表示范围 最多使用4个字节  故这里存在着数据长度的限制  （不过真心牛掰！ 试试Q
阅读更多...
MQTT broker搭建并用SSL加密

MQTT broker搭建并用SSL加密

系统为centos，基于emqx搭建broker，流程参考官方。 安装好后，用ssl加密。 进入/etc/emqx/certs,可以看到 分别为 cacert.pem CA 文件cert.pem 服务端证书key.pem 服务端keyclient-cert.pem 客户端证书client-key.pem 客户端key 编辑emqx配置：vim /etc/emqx/emqx.conf,添加s
阅读更多...
物联网——模拟与数字转换器（ADC）

物联网——模拟与数字转换器（ADC）

ADC（常用于信号发生器，音频解码器） 逐次逼近型ADC 利用逐次逼近寄存器SAR，二分法逼近未知电压，直到外部输入电压与输出电压保持一致：例如0~225V每次去中间值作为判断电压，逐次二分 stm32的ADC模块 规则通道一次只能选一个数据寄存器，通常搭配DMA使用； 注入通道一次能选4个数据寄存器存相应数值 ADC基本结构 ADC引脚复用 双ADC模式（同步采样
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2