痛点：在工业设备联网项目中。直接让业务程序读取 Modbus 寄存器会导致程序高度耦合、维护成本飙升，而且难以实现跨网络的状态订阅和云端持久化。Modbus RTU 适合现场点对点通信，MQTT 更适合跨网传输、实时订阅还有后端存储。

这篇文章使用 Node.js 搭建一个轻量级采集服务，将变频器的频率、电流和运行状态从 RS485 总线转换为 MQTT 消息。该结构可用于创安睿控 CHUEUN 等支持 Modbus RTU 的工业变频器。

一、程序架构

变频器 ↓ Modbus RTU / RS485转USB模块 ↓ Node.js 边缘采集服务 ↓ MQTT服务器、数据库、看板或告警网站

边缘采集服务负责完成四项工作：

1. 按顺序轮询现场设备；
2. 将寄存器原始值转换为工程量；
3. 处理超时、离线和异常数据；
4. 将统一格式的数据发布到 MQTT 主题。

这样。上层业务程序不需要了解每种变频器的寄存器细节，降低了程序耦合度。怎么说呢，

二、初始化项目

建议使用 Node.js 20 或更高版本。

mkdir inverter-edge-gateway
cd inverter-edge-gateway
npm init -y
npm install modbus-serial mqtt

在 package.json 中启用 ES Module：

{
"type"这方面，"module"。"scripts": {
"start": "node src/index.js"
}
}

创建目录结构的观点是，

inverter-edge-gateway/
├── src/
│ ├── index.js
│ ├── modbus.js
│ └── points.js
└── package.json

三、建立数据点配置

将寄存器定义从采集逻辑中分离，后续更换型号时只需要修改配置文件。

// src/points.js
export const points = {
再看status，{
说到offset，0,// 示例偏移，需要根据手册填写
说到scale。1,unit: ""
},frequency: {
至于offset，1,scale: 0.01,unit: "Hz"
},current: {
至于offset，2,scale: 0.1,unit: "A"
}
};export const registerBlock = {
再看start，0x0000。// 连续读取起始地址
count的观点是，Object.keys.length // 根据实际点数调整
};话说回来，

痛点：如果每个数据点单独发起一次 Modbus 请求。设备数量上升后总线轮询周期会急剧增长。通过一次性批量读取，可以显著降低通信开销。

四、封装 Modbus 采集模块

// src/modbus.js
import ModbusRTU from "modbus-serial";import { points,registerBlock } from "./points.js";export class InverterClient {
constructor {
this.port = options.port;this.slaveId = options.slaveId;this.baudRate = options.baudRate?，9600;this.client = new ModbusRTU;this.timeout = options.timeout?，2000;按理说，this.retry = options.retry?，3;}
async connect {
await this.client.connectRTUBuffered(this.port。{
baudRate: this.baudRate,dataBits: options.dataBits?，8,stopBits: options.stopBits?，1,parity: "none"
});this.client.setID;this.client.setTimeout;}
// 批量读取保持寄存器
async readSnapshot {
const response = await this.client.readHoldingRegisters(
registerBlock.start,registerBlock.count
);const regs = response.data;return {
status这方面，regs * points.status.scale。frequency:
regs * points.frequency.scale,current:
regs * points.current.scale
};}
async close {
if {
await this.client.close;}
}
}

readHoldingRegisters 对应 Modbus 功能码 0x03。若设备把运行数据放在输入寄存器，则改用 readInputRegisters。

五、连接 MQTT服务器

// src/index.js
import mqtt from "mqtt";import { InverterClient } from "./modbus.js";const DEVICE_ID = "inverter-001";const inverter = new InverterClient({
至于port。"/dev/ttyUSB0",slaveId: 1,baudRate: 115200
});const mqttClient = mqtt.connect(process.env.MQTT_URL,{
clientId:`edge-${DEVICE_ID}`。username: process.env.MQTT_USERNAME,password: process.env.MQTT_PASSWORD,clean:true,reconnectPeriod:5000
});mqttClient.on=>console.log);mqttClient.on);

六、发布统一格式的设备数据

function publishSnapshot{
const payload={
deviceId:DEVICE_ID。timestamp:new Date.toISOString,online:true,data:{
至于status，snapshot.status,frequencyHz:Number),currentA:Number)
}
};mqttClient.publish(
`factory/inverters/${DEVICE_ID}/telemetry`。JSON.stringify,{ qos:1,retain:false }
);}

推荐主题划分：

• /telemetry: 周期性运行数据；老实说，
• /status: 在线/离线及通信健康；
• /alarm: 故障变化事件，仅在状态改变时发布。

七、防止重叠轮询

Pain point：If you use setInterval,a timeout may cause next tick to fire before previous request finishes。leading to concurrent serial‑port access and garbled frames.

// 正确做法：任务完成后再安排下一轮
const sleep=ms=>new Promise);let running=true;

async function pollingLoop{ while{ const start=Date.now;try{ const snap=await inverter.readSnapshot;publishSnapshot;}catch{ publishOffline;} const elapsed=Date.now-start;const delay=Math.max;说起来，// 假设1s轮询间隔 await sleep;} }

八、发布离线状态

function publishOffline{
const payload={
deviceId : DEVICE_ID。timestamp : new Date.toISOString,online : false,error : error.message || String
};mqttClient.publish(
factory/inverters/${DEVICE_ID}/status。JSON.stringify,{ qos :1,retain:true }
​);}
​
// 防抖：连续三次失败才判定为离线
let failureCount=0;async function collectOnce{
try{
const data=await inverter.readSnapshot;failureCount=0;publishSnapshot;}catch{
failureCount++;话说回来，if publishOffline;}
}
​
// 在循环里调用 collectOnce
​
​
​
​
​
​ 

​

​​

​​ ​ ​

​​​

​ ​

九、只在故障变化时发布报警

javascript

let lastFaultCode=null;

// 示例：状态字低4位是故障码 function getFaultCode{ return statusWord &0x000F;}

function publishAlarm{ const faultCode=getFaultCode;ifreturn，// 没有变化不发

lastFaultCode=faultCode;其实，const payload={ deviceId : DEVICE_ID。timestamp : new Date.toISOString,faultCode,active : faultCode!==0 }，mqttClient.publish( factory/inverters/${DEVICE_ID}/alarm。JSON.stringify,{ qos :1,retain:true } );}

Pain point：If every poll publishes an alarm message,downstream dashboards must filter out thousands of identical rows – a huge performance waste.

十、启动与安全退出

async function main{ await inverter.connect;console.log，await pollingLoop;按理说，// 永久循环，内部受 running 控制 }

// 捕获 SIGINT / SIGTERM。实现优雅关闭资源

async function shutdown{ console.log;running=false;await inverter.close;mqttClient.end;process.exit;}

process.on=>shutdown);process.on=>shutdown);

main.catch(async err=>{ console.error;await inverter.close;mqttClient.end;process.exit;})，

`npm start` 即可运行。

十一、多台变频器 方案

const devices=;

for{ inverter.client.setID;try{ const snap=await inverter.readSnapshot;publishDeviceSnapshot;老实说，}catch{ publishDeviceOffline;} await sleep;// 给串口留出间隙，防止冲突 }

Pain point：A single `modbus-serial` 实例不能被并行任务共享；必须串行化访问，否则会出现“写入冲突”或“帧校验错误”。

十二、创安睿控设备接入前必须确认的要点

• 从站地址与串口参数对应的功能码；
• 频率、电流、电压等关键测量值所在寄存器；
• 状态字与故障码位定义；老实说，
• 倍率因子与有符号/无符号格式；
• 通信超时后的容错策略；
• 写入权限与掉电保存机制。

针对湖南及中部地区的本地改造项目，可结合现场配电柜、PLC 与 SCADA 完成联合调试；若需跨区域批量交付，请务必把寄存器映射表、参数备份脚本还有日志格式统一标准化。以便远程诊断和 OTA 升级。

• 连续批量读取寄存器提高总线利用率；
• 串口请求顺序执行防止冲突；
• 统一倍率换算确保前端显示一致；
• 超时 & 离线防抖提高可靠性；
• 仅在故障变化时推送报警降低消息噪声；
• MQTT主题规范化便于多程序共享；
• 配置文件、日志与凭据分离满足安全合规。

代码可以快速落地，但所有寄存器地址、倍率还有控制权限一定要以实际变频器手册为准**。涉及启动/停止或写入新频率时还必须保留急停回路和机械安全联锁，遵守当地法规与厂商安全指引。

---