基于Moxa E1212与Modbus-TCP（jsmodbus）的多客户端实时状态同步实现方案咨询

我来给你几个适配这个场景的优化方案，既能解决实时同步需求，又能避免频繁轮询带来的资源浪费问题：

方案1：利用Moxa设备的主动事件上报（最优解） #

Moxa E1212本身支持状态变化主动上报的功能，完全可以替代轮询逻辑：

• 登录设备的Web管理后台，找到「Event」或「Alarm」配置模块，设置当Coil（比如LED对应的线圈）状态发生变化时，主动向你的服务器发送Modbus-TCP报文（可以配置上报的目标IP、端口和报文类型）。
• 服务器端用jsmodbus或原生TCP监听端口，接收设备的主动上报报文，解析出状态变化后，立刻通过WebSocket把新状态广播给所有连接的客户端。
  这个方案的优势是只有状态变化时才会产生通信，完全消除无效轮询的资源消耗，实时性也最高。

方案2：服务器统一处理控制请求+WebSocket广播（次优解） #

如果暂时没法配置设备主动上报，可以把所有客户端的控制请求收敛到服务器，由服务器统一操作设备并同步状态：

1. 所有客户端不再直接连接Moxa设备，而是通过WebSocket连接你的服务器。
2. 客户端发起控制请求（比如点亮LED）时，先将请求发送到服务器。
3. 服务器调用jsmodbus的writeCoil方法操作Moxa设备，操作成功后读取最新状态（或直接复用设置的参数），然后通过WebSocket广播给所有在线客户端。
4. 客户端只需监听WebSocket的广播消息，更新本地状态即可，无需自己轮询。

核心代码示例 #

// 服务器端（基于ws库实现WebSocket）
const WebSocket = require('ws');
const { ModbusTCPClient } = require('jsmodbus');

const wss = new WebSocket.Server({ port: 8080 });
// 初始化Modbus客户端
const modbusClient = new ModbusTCPClient('Moxa设备IP', 502);

// 处理客户端连接
wss.on('connection', (ws) => {
  // 接收客户端控制请求
  ws.on('message', async (msg) => {
    const { coilAddr, value } = JSON.parse(msg);
    try {
      // 执行Modbus写操作
      await modbusClient.writeCoil(coilAddr, value);
      // 读取最新状态确保准确性
      const resp = await modbusClient.readCoils(coilAddr, 1);
      const newState = resp.response.body.coils[0];
      
      // 广播状态更新给所有客户端
      wss.clients.forEach(client => {
        if (client.readyState === WebSocket.OPEN) {
          client.send(JSON.stringify({
            type: 'coilUpdate',
            address: coilAddr,
            state: newState
          }));
        }
      });
    } catch (err) {
      console.error('Modbus操作失败:', err);
      ws.send(JSON.stringify({ type: 'error', msg: '控制请求失败' }));
    }
  });
});

// 客户端示例代码
const ws = new WebSocket('ws://你的服务器IP:8080');
ws.onmessage = (event) => {
  const data = JSON.parse(event.data);
  if (data.type === 'coilUpdate') {
    // 更新本地UI，比如切换LED显示状态
    updateLED(data.address, data.state);
  }
};

// 发送控制请求的函数
function sendLEDControl(coilAddr, isOn) {
  ws.send(JSON.stringify({ coilAddr, value: isOn }));
}

方案3：优化轮询策略（降级方案） #

如果以上两个方案暂时无法落地，可以先优化现有轮询逻辑：

• 把客户端各自轮询改成服务器统一轮询，服务器每隔固定时间读取一次设备状态，然后通过WebSocket推送给所有客户端，避免多客户端重复向设备发送请求。
• 根据业务实时性要求拉长轮询间隔，比如从200ms调整为1-2秒，减少不必要的通信次数。

内容的提问来源于stack exchange，提问作者Ali Shefaee