nodejs映射串口写入接收数据

Question

我目前正在使用node-serialport 模块进行串口通信。我将发送一个命令ATEC，它会回复ECHO。

但是，这个发送和接收数据的过程是异步的（我发送数据后，我不会在data事件中知道数据何时到达），示例代码如下：

//Register the data event from the serial port
port.on('data', (data) => {
    console.log(data);
});

//Send data using serialport
port.write('ATEC');

反正我可以这样写吗？

//When i send the command, I could receive the data
port.write('ATEC').then((data)=> {
    console.log(data);
});

这有可能实现吗？

在使用request客户端的http通信中，我们可以做类似的事情

request.get('http:\\google.com')
    .on('response', (res) => {
        console.log(res);
    });

我想使用 serialport 复制相同的行为

Answer 1

我在串行数据接收中包装了一个承诺

function sendSync(port, src) {
    return new Promise((resolve, reject) => {
        port.write(src);
        port.once('data', (data) => {
            resolve(data.toString());
        });

        port.once('error', (err) => {
            reject(err);
        });
    });
}

请注意，该事件使用once 而不是on 以防止事件堆叠（请查看下面的 cmets 以获取更多信息 - 感谢@DKebler 发现它）

然后，我可以如下同步编写代码

sendSync(port, 'AThello\n').then((data) => {
    //receive data
});

sendSync(port, 'ATecho\n').then((data) => {
    //receive data
});

或者我可以使用生成器，使用 co 包

 co(function* () {
        const echo = yield sendSync(port, 'echo\n');
        const hello = yield sendSync(port, 'hello 123\n');

        return [echo, hello]
    }).then((result) => {
        console.log(result)
    }).catch((err) => {
        console.error(err);
    })

Answer 2

在我正在进行的一个项目中，我们遇到了类似的问题。需要一个串行的同步发送/接收循环，而 serialport 包让这有点奇怪。

我们的解决方案是为串行端口“数据”事件提供某种功能/承诺/生成器/等（取决于您的架构）队列。每次你写东西的时候，把一个函数/promise/etc 放到队列中。

假设您只是将函数放入队列中。当“data”事件被触发时，它将当前聚合的接收缓冲区作为参数发送到队列的第一个元素中，它可以查看它是否包含它需要的所有数据，如果是，则对其进行处理，并且以某种方式将自己从队列中移除。

这允许您使用相同的基本机制来处理多种不同类型的架构（回调/承诺/协程/等）。

额外的好处：如果您完全控制协议的双方，您可以在这些字符串的末尾添加一个“\n”，然后使用串行端口的“readline”解析器，这样您就只能获取数据整个字符串上的事件。可能比不断检查输入有效性更容易一些。

更新：

现在代码已经完成并经过测试（请参阅http://github.com/metafetish/buttshock-js 中的 ET312 模块），我是这样做的：

function writeAndExpect(data, length) {
  return new Promise((resolve, reject) => {
    const buffer = new Buffer(length);
    this._port.write(data, (error) => {
      if (error) {
        reject(error);
        return;
      }
    });
    let offset = 0;
    let handler = (d) => {
      try {
        Uint8Array.from(d).forEach(byte => buffer.writeUInt8(byte, offset));
        offset += d.length;
      } catch (err) {
        reject(err);
        return;
      }
      if (offset === length) {
        resolve(buffer);
        this._port.removeListener("data", handler);
      };
    };
    this._port.on("data", handler);
  });
}

上面的函数接受一个 uint8s 列表，以及一个期望的数据量，返回一个 Promise。我们写入数据，然后将自己设置为“数据”事件处理程序。我们使用它来读取数据，直到获得预期的数据量，然后解决承诺，将自己移除为“数据”侦听器（这很重要，否则您将堆栈处理程序！），并且完成。

此代码非常符合我的需求，除了非常严格的具有已知参数的发送/接收对之外，它不会处理其他情况，但它可能会给你一个开始的想法。