node.js等待可变长度数组类型的事件

Question

所以我正在编写一个小型应用程序，它将串行端口公开给web服务。

允许客户端打开端口，服务器跟踪打开的端口。

我是javascript的新手，所以也请指出你在我的代码中看到的任何其他错误！

无论如何，我有websocket在客户端和服务器之间传递消息。

有一个ser_con事件，它指示服务器打开与串行端口的新连接。这也将串行端口对象附加到数组中，以便以后可以引用它。

var ser = []
...
socket.on('ser_con', function(d) {
  console.log('connect event')
  sp = new SerialPort.SerialPort(d.name, {
    baudrate: d.baudrate,
    databits: d.databits,
    stopbits: d.stopbits,
    parity: d.parity,
    buffersize: d.buffersize,
    parser: SerialPort.parsers.raw
  },false);
  sp.open(function (err) {
    if (err) {
      console.log('Error connecting to port: ' + d.name + ', error: ' + err);
      socket.emit('ser_err', 'Error connecting to port: ' + d.name + ', error: ' + err);
    } else {
      console.log('connected to serial port ' + d.name);
      data = {
        name: d.name,
        b:'connected to serial port ' + d.name + 'n'
      }
      socket.emit('data', data);
      ser.push({'name':d.name,'sp':sp})
    }
  })
});

因此，一旦连接成功，我会将端口的名称和serialport对象的实例附加到ser数组中。

我遇到的问题是如何监听所有串行端口实例上的事件

我试过这样做，但它不起作用，我想这是不允许的，因为for循环本身不是一个事件。我不知道如何解决这个问题，尽管。。。

for (var i=0; i < ser.length; i++){
  ser[i].sp.on('data', function(d) {
    console.log('recieved data on port ' + ser[i].name)
    data = {
      name: ser[i].name,
      b: d
    }
    socket.emit('data', data);
  });
}

任何帮助都将不胜感激。

Answer 1

您在回调中使用for迭代器变量。这是一个常见的javascript错误。要解决此问题：

for (var j=0; j < ser.length; j++){
  (function(i){
    ser[i].sp.on('data', function(d) {
        console.log('recieved data on port ' + ser[i].name)
        data = {
          name: ser[i].name,
          b: d
        }
        socket.emit('data', data);
      });
  }(j))  
}

我不知道你在代码的哪个地方运行这个for循环。但是，如果处理不当，可能会将多个回调绑定到同一个串行端口对象。我建议在打开端口后绑定事件：

...
sp.open(function (err) {
    if (err) {
      console.log('Error connecting to port: ' + d.name + ', error: ' + err);
      socket.emit('ser_err', 'Error connecting to port: ' + d.name + ', error: ' + err);
    } else {
      console.log('connected to serial port ' + d.name);
      data = {
        name: d.name,
        b:'connected to serial port ' + d.name + 'n'
      }
      socket.emit('data', data);
      ser.push({'name':d.name,'sp':sp})
      //listen 'data' event here
      //you have access to both 'd' and 'socket' variable here
      sp.on('data', function(data) {
        console.log('recieved data on port ' + d.name)
        data = {
          name: d.name,
          b: data
        }
        socket.emit('data', data);
      });
    }
})