javascript - 从 Node.js 运行脚本，捕获标准输出，通过 Web 套接字发送

Question

我通过 node.js 调用 Ruby 脚本，该脚本通过 stdout 返回数据，我已设法让 Node 将一些数据发送到其 Web 套接字，但我缺少行并且不知道我不太了解我在做什么。从研究看来，我正在使用流，但我无法理解大部分文档，因为这都是非常新的，超出了我的理解:(

当通过 bash shell 运行时，我的 Ruby 脚本输出如下到 stdout；

{"element":"SENS02","data":{"type":"SEN","descr":"T100"}}
{"element":"SENS01","data":{"type":"SEN","descr":"    "}}
{"element":"LED1","data":{"type":"LED","state":"1"}}
{"element":"LED2","data":{"type":"LED","state":"0"}}

当在控制台上运行时，一切都很好 - 当我通过我的node.js脚本调用它时，我只得到每第二行，因此例如 Node 会输出；

{"element":"SENS02","data":{"type":"SEN","descr":"T100"}}
{"element":"LED1","data":{"type":"LED","state":"1"}}

我的node.js脚本部分如下；

var cp = require('child_process');
var tail = cp.spawn('test.rb');

// Get updates from ruby script //
tail.stdout.on('data', function(chunk) {
   var pumper = chunk.toString().slice(0,58);
   var closer = JSON.parse(pumper);
   socket.emit('MAP.room1', closer);
});

我偶尔也会遇到崩溃，并出现以下错误，如果有人可以提供帮助；

undefined:0

^ SyntaxError: Unexpected end of input at Object.parse (native)

我需要能够输出从 ruby​​ 脚本收到的每一行。任何回答的人请使用我自己的代码，如上所述，而不是随机的例子，因为当我试图理解什么与什么相关以及“这对我意味着什么”时，它只会让我非常困惑。我尝试查看 .pipe 但所有示例都让我感到困惑，我不明白如何使它们适应我自己的脚本。 ruby 的输出是 JS 对象，一次 1 行，我需要我的 Web 套接字一次发出完全相同的 1 个对象。

完成 console.log(chunk.toString()) 以获得可读输出它缓解了一些奇怪的事情 - 额外的换行或其他东西。

控制台的输出是；

{"element":"SENS02","data":{"type":"SEN","descr":"T100"}}
{"element":"SENS01","data":{"type":"SEN","descr":"    "}}

{"element":"LED1","data":{"type":"LED","state":"1"}}
{"element":"LED2","data":{"type":"LED","state":"0"}}

我该如何解决这个问题？这是否会导致我的其他“输入意外结束”错误？

如果我这样做var Pumper = chunk.slice(0,-1); console.log(pumper.toString()) 然后我得到如上所示的输出，没有奇数/额外/胭脂换行符。不过，我仍然不打算将其准确输出到网络套接字。

我可以从网络套接字中获取它，但它显示我仍然有\n？!？!

["{\"元素\":\"SENS02\",\"数据\":{\"类型\":\"SEN\",\"描述\":\"T100\"}}\n{\"元素\":\"SENS01\",\"数据\":{\"类型\":\"SEN\",\"描述\":\"\"}}"]}我需要将其恢复为单条平线，就像我在控制台上一样......

因此，按照下面的建议完成后，我现在使用此代码获得了所需的输出。我仍然收到 ): Unexpected end of input 记录在控制台中，这似乎来 self 从 Ruby 脚本中获得的额外换行符。运行脚本几天没有崩溃，似乎所有数据都完好无损地通过并解析到网络套接字。我仍然需要阅读并完全理解 for 正在做什么，但除此之外它似乎已经解决了我的问题。

tail.stdout.on('data', function(chunk) {
var closer = chunk.toString()

var sampArray = closer.split('\n');

 for (var i = 0; i < sampArray.length; i++) {
  try {
   var newObj = JSON.parse(sampArray[i]);
socket.emit('MAP.room1', newObj);
   } catch (err) {
console.log('): ' + err.message);
  }
 }
});

Answer 1

如果您打算对每个数据 block 使用JSON.parse()，那么您需要在换行符\n上预先解析每个 block 。

JSON.parse 无法将由换行符分隔的多个对象解析为同一字符串中的 2 个不同对象。

这些单独有效:

"{\"element\":\"SENS02\",\"data\":{\"type\":\"SEN\",\"descr\":\"T100\"}}"
"{\"element\":\"SENS02\",\"data\":{\"type\":\"SEN\",\"descr\":\"T100\"}}\n"
"{\"element\":\"SENS02\",\"data\":{\"type\":\"SEN\",\"descr\":\"T100\"}}\r\n"

这不是:

"{\"element\":\"SENS02\",\"data\":{\"type\":\"SEN\",\"descr\":\"T100\"}}\n{\"element\":\"SENS01\",\"data\":{\"type\":\"SEN\",\"descr\":\"    \"}}"

如果目的是解析整个数据结构，那么您需要将 ruby​​ 脚本的输出重新组织为类似于下面的内容。

{
    "elements": [
        {
            "name": "SENS02",
            "data": {
                "type": "SEN",
                "descr": "T100"
            }
        },
        {
            "name": "SENS01",
            "data": {
                "type": "SEN",
                "descr": "    "
            }
        },
        {
            "name": "LED1",
            "data": {
                "type": "LED",
                "state": "1"
            }
        },
        {
            "name": "LED2",
            "data": {
                "type": "LED",
                "state": "0"
            }
        }
    ]
}

如何解析输入(粗略示例)

var sample = "{\"element\":\"SENS02\",\"data\":{\"type\":\"SEN\",\"descr\":\"T100\"}}\n{\"element\":\"SENS01\",\"data\":{\"type\":\"SEN\",\"descr\":\"    \"}}\n{\"element\":\"LED1\",\"data\":{\"type\":\"LED\",\"state\":\"1\"}}\n{\"element\":\"LED2\",\"data\":{\"type\":\"LED\",\"state\":\"0\"}}";

var sampArray = sample.split('\n');

for (var i = 0; i < sampArray.length; i++) {
    try {
        var newObj = JSON.parse(sampArray[i]);
        // socket.emit(newObj);
    } catch (err) {
        console.log('): ' + err.message);
    }
}