node-red-contrib-mitsubishi 1.4.0

三菱 MC Protocol 3E/4E 采集节点 — 纯TCP长连接池, 零依赖, 支持Q/L/iQ-R/iQ-F/FX5U

npm install node-red-contrib-mitsubishi

node-red-contrib-mitsubishi

三菱 MC Protocol 3E/4E 以太网采集节点。一个节点读 N 个点位，零外部依赖，纯 TCP 长连接池实现，已修复 INT32/UINT32、X/Y 八进制、连接池并发等生产级问题。

截图

为什么选这个节点？

特性

• 独立可用 — 纯 Node.js net + Buffer，不依赖任何第三方库或后端服务
• 长连接池 — TCP 连接持久复用，键含帧/网络/站号，避免不同配置冲突
• 请求队列串行化 — 多节点共享同一 PLC 时自动排队，防止读写交错
• 并发建连保护 — 同一 PLC 同时只建立一个 TCP 连接
• TCP Keepalive — 30 秒探测保活，防止空闲连接被交换机/防火墙断开
• 断线自动重建 — 连接断开、超时或干净关闭时自动检测并重建
• 重连退避 — 连接失败时指数退避，避免重连风暴
• 队列超时 — 排队请求超过超时时间自动失败，不无限等待
• deviceId 归一化 — 输出始终为数字，兼容下游 edge_commStatus 索引
• 表格编辑器 — 一个节点配置 N 个点位，自动按寄存器类型和地址聚类，合并为批量读取
• 6 种数据类型 — INT16 / UINT16 / INT32 / UINT32 / FLOAT32 / BOOL
• 8 种软元件 — D / W / R / X / Y / M / L / B，位元件（X/Y/M/L/B）自动逐位拆包
• 斜率偏移变换 — engValue = rawValue × slope + offset，节点直接输出工程值
• 动态 IP 覆盖 — msg.payload.plcIp 可覆盖 config 固定 IP，一个节点采多台 PLC
• 4E serialNo 完整支持 — 每帧自增，响应校验，防止串包
• 批量保护 — 单次读取字数超 960 自动拆包，防 PLC 报 0xC059
• 错误诊断 — 19 个 MC 错误码映射为中文/英文可读信息
• 模拟模式 — RED.settings.mcSimulationMode = true 不连 PLC 即可测试
• 零依赖 — 仅使用 Node.js 内置 net + Buffer
• 防重入保护 — safeSend 确保每次触发只输出一条消息

安装

cd ~/.node-red
npm install node-red-contrib-mitsubishi

重启 Node-RED，左侧节点栏 edgelink 分类下出现 MC 读取 节点。配置节点在 config 侧边栏：

支持的 PLC

使用方法

1. 添加 PLC 连接配置

拖入 PLC 连接配置 节点，双击配置：

2. 配置点位表格

拖入 MC 读取 节点，关联 PLC 配置，在表格中添加点位：

斜率/偏移公式：engValue = rawValue × slope + offset

例如 PLC 存温度原始值 2530（实际 253.0℃），设斜率 = 0.1，偏移 = 0，输出 engValue = 253.0

3. 触发采集

inject 节点 → MC 读取节点，部署后点击 inject 按钮即可采集。

4. 动态点位（高级）

上游节点传入 msg.tags 会覆盖表格配置，适配 EdgeLink 采集管线：

msg.tags = [
  { id: "温度", regType: "D", addr: 100, dataType: "INT16", slope: 0.1, offset: 0 },
  { id: "压力", regType: "D", addr: 200, dataType: "FLOAT32" }
];

输出格式

正常采集

msg.payload = {
  success: true,
  deviceId: "PLC-1",          // 适配 edgelink-pg-store 动态分表
  data: {
    "温度": {
      rawValue: 2530,         // PLC 原始 int16
      engValue: 253.0,        // 解码后 × 斜率 + 偏移
      quality: 0,             // 0=正常 2=异常
      ts: "2026-06-30T08:00:00.000Z",
      regType: "D"            // 寄存器类型
    },
    "压力": {
      rawValue: 4123,
      engValue: 41.23,
      quality: 0,
      ts: "2026-06-30T08:00:00.000Z",
      regType: "D"
    },
    "开关": {
      rawValue: 1,
      engValue: 1,
      quality: 0,
      ts: "2026-06-30T08:00:00.000Z",
      regType: "X"
    }
  },
  error: null,
  driverType: "driver-mc-protocol",
  plcIp: "192.168.1.10",
  plcPort: 5007,
  roundTimeMs: 12
}

PLC 读取失败

msg.payload = {
  success: false,
  deviceId: "PLC-1",
  data: {},
  error: "[PLC 0xC052] Address out of range",
  driverType: "driver-mc-protocol",
  plcIp: "192.168.1.10",
  plcPort: 5007,
  roundTimeMs: 3012
}

网络故障

msg.payload = {
  success: false,
  deviceId: "PLC-1",
  data: {},
  error: "[NETWORK] TCP closed (no data)",
  ...
}

架构

┌──────────┐     ┌──────────────────────────────────────┐     ┌──────────┐
│ inject / │     │     mitsubishi-read v1.4.0            │     │ 三菱 PLC │
│ 动态tags │────→│                                       │────→│          │
└──────────┘     │  1. 校验 + 清洗点位（X/Y 八进制）    │     │ Q / L /  │
                 │  2. 去重 + 聚类分组                   │     │ iQ-R /   │
                 │  3. 长连接池 ──→ 逐组 3E/4E 帧请求   │     │ FX5U     │
                 │  4. 解码 + 斜率变换                   │     └──────────┘
                 │  5. 输出 {raw,eng,quality,ts}         │
                 └──────────────────────────────────────┘

 连接池: CONN_POOL["host:port:frame:network:station"] → { socket, inUse, queue[] }
 生命周期: getConnection(复用/排队/新建) → 采集 → releaseConnection(交付下个等待者)
 空闲回收: 每 5 分钟清理 > 10 分钟未用的空闲连接
 断线恢复: socket close/end/destroyed 检测 → destroyConnection → getConnection 重建

与 node-red-contrib-mcprotocol 对比

选择建议：需要写入/UDP/1E帧/老A系列PLC → mcprotocol。高频多PLC TCP采集 → 本节点。

模拟模式

在 Node-RED settings.js 中添加：

mcSimulationMode: true

重启后所有 MC 读取 节点不连 PLC，直接返回随机仿真数据。用于离线开发、CI 测试、Demo 演示。

与 EdgeLink 生态集成

┌──────────────────┐     ┌──────────────────────┐     ┌──────────────────┐
│ node-red-contrib │     │ node-red-contrib     │     │ PostgreSQL /     │
│ -mitsubishi      │────→│ -edgelink-pg         │────→│ TimescaleDB      │
│ (本节点)         │     │ (PG 批量写入)        │     │                  │
└──────────────────┘     └──────────────────────┘     └──────────────────┘

本节点输出的 deviceId、regType、rawValue、engValue、quality、ts 字段可由 edgelink-pg-store 自动识别为 MC 驱动格式，零配置写入数据库。

测试

npm install
npm test

测试覆盖：

• 3E/4E 帧构造字节级正确性
• INT32/UINT32/FLOAT32 高低字解码
• X/Y 八进制地址解析与格式化
• parseMCResponse 对正常响应、MC 错误码、序列号不匹配的处理
• 节点模拟模式与 deviceId 解析

FAQ

Q: 连接如何管理？
采用长连接池架构（v1.4.0）。TCP 连接建立后保持复用，跨轮采集不再重复握手。连接池 key 包含 host:port:frame:network:station，不同帧格式/网络号/站号的 PLC 不会复用同一条连接。同一 PLC 的多个采集节点通过请求队列串行化，防止并发读写交错。连接空闲 > 10 分钟自动回收，断开自动检测重建。生产环境推荐长连接池模式。

Q: 能同时读多个 PLC 吗？
可以。每个 PLC 连接配置 配置一个 PLC，或在运行时通过 msg.payload.plcIp / msg.payload.protocolParams 动态覆盖。连接池按 host:port:frame:network:station 隔离，不同 PLC 独立管理各自的 TCP 连接。同一 PLC 多节点场景通过队列串行化保证安全。

Q: 点位地址能写成 "D100" 格式吗？
可以。地址字段兼容 "D100" 格式（自动提取数字部分），也支持纯数字 100。

注意：X / Y 为三菱八进制地址，输入 X10 表示物理点 X10（八进制），内部会自动转换为十进制处理，输出 ID 也保持八进制显示。M / L / B 仍为十进制。

Q: switch 元素一次最多读多少个点位？
字元件单次最多 960 字，位元件单次最多 15360 点。超出自动拆组，无需手动干预。

Q: 支持 FX3U 吗？
带以太网模块（FX3U-ENET）支持 3E 帧。不带以太网模块的 FX3U 不支持（需要 1E 帧或串口）。

许可证

MIT · 可自由商用、修改、再发布