简介这份资源面向工业自动化与物联网方向的开发者、运维人员及技术学习者聚焦将支持Modbus协议的工业设备接入物联网网关并通过MQTT完成消息发布订阅与数据转换。包内以JavaScript实现为核心配合配置文件、容器化脚本与说明文档覆盖串口通信、实时数据采集、设备配置管理及远程监控等典型场景适合具备一定编程基础、希望快速搭建Modbus转MQTT链路的读者参考。资源共32个文件包含15个js源码、4个md文档、3个yml与3个json配置、2个txt说明另有yaml、sh、pdf、dockerfile等压缩包约273KB结构紧凑便于按模块查阅。目前已有69人学习下载。通过源码与配置示例读者可理解Modbus设备接入、MQTT主题发布订阅及数据标准化转换的实现思路并借助Docker与运行脚本快速部署验证为工业物联网网关开发提供可复用的参考方案。1. 工业网关到底在转什么从 Modbus 寄存器到 MQTT 主题的一条数据链路车间里一台老 PLC 还在用 Modbus RTU 往外吐数据上位机却想用 MQTT 订阅现场有 485 传感器、有 Modbus TCP 的仪表、还有几台只认串口的设备你不可能给每台设备都写一套采集程序。工业自动化里这类需求非常典型底层是 Modbus 协议RTU over RS485、TCP over 以太网上层是 MQTT 消息队列中间需要一个物联网网关把串口通信、数据转换、设备配置管理、远程监控串起来。这个标题讲的就是这么一套开源、跨平台的网关方案把 Modbus 设备接入做实时数据采集再通过 MQTT 发布订阅把数据送到平台侧。适合做设备集成、边缘采集、SCADA 替代或自建监控的工程师也适合想用 STM32 或 Linux 盒子做网关原型的开发者。下面按“协议怎么通、数据怎么转、配置怎么管、坑在哪”一路拆开。2. Modbus 侧接入RTU 与 TCP 的采集链路怎么搭2.1 先分清 Modbus RTU、Modbus TCP 和串口参数Modbus 本身是主从问答式协议主站发请求从站回响应。落到物理层常见两种形态Modbus RTU 跑在 RS485/RS232 串口上靠波特率、数据位、停止位、校验位这组串口参数对齐Modbus TCP 跑在以太网上默认 502 端口报文里多了 MBAP 头。热词里常出现的 modbus rtu、modbus tcp、modbus 报文、modbus 校验码在线计算本质都是在确认同一件事请求帧的从站地址、功能码、寄存器地址、数量、CRC 校验要对得上。功能码决定你读的是什么。读线圈和离散输入用 01/02读保持寄存器和输入寄存器用 03/04写单个线圈/寄存器用 05/06写多个用 15/16。很多新手卡在“地址对不上”是因为设备手册写的是 1 基地址比如 40001而代码库通常用 0 基地址对应 0。这个偏移不统一读出来就是错位或异常码。串口参数必须和从站完全一致常见组合是 9600/8/N/1 或 19200/8/E/1。波特率不一致时现象是超时或乱码校验位不一致时可能偶尔能通但 CRC 频繁报错。RS485 半双工还要注意收发方向控制USB 转 485 模块一般自动切换但某些廉价模块需要手动 RTS 控制否则发出去收不回来。2.2 用 Python 跑通一次 Modbus RTU 采集最小验证不要一上来就写网关先用脚本把单台设备读通。下面用 pymodbus 读保持寄存器串口走 RTU。# modbus_rtu_probe.py from pymodbus.client import ModbusSerialClient import time # 串口参数必须与从站一致端口、波特率、数据位、校验、停止位 client ModbusSerialClient( port/dev/ttyUSB0, # Windows 下换成 COM3 baudrate9600, bytesize8, parityN, # 无校验偶校验写 E stopbits1, timeout1.0, # 单次请求超时现场建议 0.5~2s ) if not client.connect(): raise SystemExit(串口打开失败检查端口占用和权限) try: # slave1 是从站地址address0 是 0 基地址对应手册 40001 rr client.read_holding_registers(address0, count4, slave1) if rr.isError(): print(读取异常, rr) else: print(原始寄存器, rr.registers) # 常见 32 位浮点两个寄存器拼注意字序 import struct raw struct.pack(HH, rr.registers[0], rr.registers[1]) print(按大端解析 float, struct.unpack(f, raw)[0]) finally: client.close()逻辑说明先建立串口连接再发一次读保持寄存器请求。address和count决定读哪段、读几个。slave是从站地址多台 485 设备挂同一条总线时靠它区分。参数上timeout太短会误判掉线太长会拖慢轮询现场我一般先设 1 秒稳定后再压到 0.5 秒。解析部分要注意字序很多仪表是 CDAB 而不是 ABCD浮点数会翻车成完全离谱的值这时把HH换成HH后交换顺序再试。2.3 Modbus TCP 与多设备轮询的写法Modbus TCP 把串口参数换成 IP 和端口其余请求结构类似。多设备场景不要串行死等按从站分组轮询组内串行、组间可并发。# modbus_tcp_poll.py from pymodbus.client import ModbusTcpClient DEVICES [ {host: 192.168.1.10, slave: 1, addr: 0, count: 2}, {host: 192.168.1.11, slave: 2, addr: 10, count: 4}, ] for d in DEVICES: c ModbusTcpClient(d[host], port502, timeout1.0) if not c.connect(): print(d[host], 连接失败) continue rr c.read_holding_registers(addressd[addr], countd[count], slaved[slave]) print(d[host], OK if not rr.isError() else rr) c.close()参数说明port默认 502有些网关会改成 5020 之类以设备为准。slave在 TCP 里对应单元标识部分设备忽略它但保留能兼容串口转 TCP 的网关。轮询周期要大于单次超时乘以设备数否则请求会堆积。实时数据采集里寄存器变化不频繁的点可以降频关键点单独提频别一刀切。3. 数据转换与 MQTT 发布把寄存器变成可订阅的主题3.1 数据转换的三层字节、工程量、主题模型Modbus 给你的是 16 位寄存器业务要的是温度、转速、状态。数据转换分三层第一层字节解析处理大小端、字序、有无符号、32/64 位拼接第二层工程量换算套用系数和偏移比如实际值 原始值 * 0.1 0第三层主题建模决定 MQTT 主题怎么命名、payload 用什么格式。主题设计直接影响后面好不好用。常见做法是工厂/车间/设备/测点例如plant1/line2/plc1/temperature。payload 用 JSON字段名和测点对应方便平台侧直接入库。别把主题写成纯数字后期排查会非常痛苦。热词里的 mqtt 订阅与发布消息、mqtt 协议详解落到工程就是 QoS 和 retain 怎么选实时采集用 QoS 0 够快关键报警用 QoS 1 保达设备当前状态可以 retain让新订阅者立刻拿到最后值。3.2 用 paho-mqtt 把采集结果发出去下面把上一节的读取结果转成 JSON 并发布包含断线重连的基本处理。# gateway_publish.py import json, time, struct import paho.mqtt.client as mqtt from pymodbus.client import ModbusSerialClient BROKER 192.168.1.100 TOPIC plant1/line2/plc1/data def on_connect(client, userdata, flags, rc): print(MQTT 已连接rc , rc) mq mqtt.Client(client_idgw-01) mq.on_connect on_connect mq.connect(BROKER, 1883, 60) mq.loop_start() # 后台线程维持心跳和重连 mb ModbusSerialClient(port/dev/ttyUSB0, baudrate9600, bytesize8, parityN, stopbits1, timeout1.0) mb.connect() while True: rr mb.read_holding_registers(address0, count2, slave1) if not rr.isError(): raw struct.pack(HH, rr.registers[0], rr.registers[1]) temp struct.unpack(f, raw)[0] payload { ts: int(time.time() * 1000), device: plc1, temperature: round(temp, 2), } # QoS 0 追求吞吐关键点可改 1 mq.publish(TOPIC, json.dumps(payload), qos0) time.sleep(1) # 采集周期按现场调整逻辑说明loop_start()让网络循环在后台跑避免阻塞采集。client_id要唯一重复会导致互相踢下线。ts用毫秒时间戳平台侧好做时序对齐。qos0适合高频实时数据丢一两帧不影响趋势报警类另开主题用 QoS 1。参数上keepalive60是心跳间隔网络差可调大但别超过 broker 允许的两倍。采集周期和发布周期可以解耦比如 200ms 采、1s 发一次聚合值减少消息量。3.3 设备配置管理把硬编码换成配置文件设备一多把 IP、从站地址、寄存器映射写死在代码里就是灾难。常见做法是外置 YAML 或 JSON网关启动时加载支持热更新。配置里至少包含设备标识、协议类型、连接参数、测点列表地址、类型、系数、偏移、单位、主题后缀。# devices.yaml devices: - id: plc1 protocol: modbus_rtu port: /dev/ttyUSB0 baudrate: 9600 parity: N slave: 1 points: - name: temperature addr: 0 type: float32 word_order: big scale: 1.0 offset: 0 unit: C topic: temperature参数说明type决定解析方式word_order处理字序scale/offset做工程量换算topic拼到设备主题后面。热更新时先校验新配置再原子替换失败保留旧配置避免改错一个字段整个网关停摆。设备配置管理做得好后面加设备就是改配置而不是改代码。4. 避坑与排查现场最容易翻车的 5 个点4.1 读不到数据先查物理层还是协议层现象脚本报超时或异常码设备手册明明写着支持。原因多数是物理层问题——485 A/B 接反、终端电阻没接、波特率或校验不一致、串口被其他程序占用。解决先用 modbus poll、modbus 调试助手这类工具单独验证能通再上代码用示波器或串口助手看有没有回帧没有回帧就是物理层有回帧但 CRC 错就是参数或干扰。4.2 浮点数解析出来是天文数字现象温度读出 1.2e38 之类。原因字序或字节序不对ABCD、CDAB、BADC、DCBA 四种组合没试全。解决拿一个已知值反推比如设备显示 25.0逐个组合试找到能还原的那个配置里把word_order显式写清楚别靠默认值。4.3 MQTT 频繁掉线重连现象日志里反复连接、断开。原因client_id重复被踢、keepalive 太小、broker 侧限制、网络抖动。解决保证每个网关 client_id 唯一keepalive 设 60 秒左右开启自动重连并加退避别一秒重连十次把 broker 打挂检查 broker 的最大连接数和认证配置。4.4 轮询周期和超时打架现象设备越多越慢最后全部超时。原因串行轮询下单次超时乘以设备数超过轮询周期请求排队。解决算清楚最坏耗时周期留余量把慢设备和快设备分组必要时用多串口或多线程但同一条 485 总线不能并发否则冲突。4.5 配置改错导致网关起不来现象改完 YAML 重启网关直接退出。原因缩进错误、字段拼写错、寄存器地址越界。解决启动时做 schema 校验地址范围对照设备手册检查保留上一版配置加载失败自动回滚日志里打印具体哪个设备哪个字段出错别只报“配置错误”。5. 进阶让网关可验证、可扩展的几个具体技巧网关做完能跑只是第一步能不能长期稳定、能不能快速定位问题靠的是可验证性。我一般会加一个“影子模式”采集到的数据除了发 MQTT同时写一份到本地环形缓冲或 SQLite出问题时能回放对比确认是采集错还是平台侧解析错。这个习惯帮我省过很多扯皮时间。验证方法上分三层做。第一层用 modbus poll 或调试助手确认单设备可读第二层用 mosquitto_sub 订阅主题看 payload 结构和频率是否符合预期第三层做端到端对时设备显示值、网关日志值、平台入库值三者对齐偏差超过一个采集周期就要查。命令很简单# 订阅所有设备主题观察实时数据 mosquitto_sub -h 192.168.1.100 -t plant1/# -v参数说明-t支持通配符#匹配多层匹配单层-v带上主题名方便区分来源。调试阶段用这个比翻日志快得多。扩展方向上两个点最值得投入。一是协议适配层抽象把 Modbus RTU、Modbus TCP 甚至其他协议统一成“读点”接口上层数据转换和 MQTT 发布不变加协议只加适配器。二是断线缓存网络中断时把数据暂存本地恢复后补发避免实时数据采集出现空洞。缓存要有上限和淘汰策略别把磁盘写满。跨平台支持方面Linux 盒子、Windows 工控机、甚至 STM32 物联网网关原型都能跑区别在串口库和资源限制。STM32 上跑 FreeRTOS 时Modbus 和 MQTT 要分任务注意栈大小和优先级串口中断里别做重活。我自己的习惯是任何网关上线前先让它空跑 24 小时看内存和连接数是否平稳再接真实设备。这个笨办法比任何压测都管用。希望帮到你。本文还有配套的精品资源点击获取