确保 NodeJS spawn stdout.on 仅在换行符上激活

Question

我正在使用 spawn 功能通过 NodeJS 运行一个外部程序，如下所示：

var app = require('express')();
var http = require('http').Server(app);
var io = require('socket.io')(http);


app.get('/', function(req, res){
  res.sendFile(__dirname + '/index.html');

  var spawn = require('child_process').spawn;
  var java = spawn('java', ['-jar', 'misc.jar']);
  java.stdout.on('data', function(data) {
      console.log(data.toString());
      io.emit('chat message', data.toString())
  });

});

预期的标准输出应该是这样的（换行符就位）：

>java -jar misc.jar
0000
0
0001
1
...

但是当我通过 NodeJS/Socket.io 运行它时，我得到：

listening on *:3000
000
0
0

000
1
1
...

我想确保对java.stdout.on('data', function(data){... 的调用仅在数据为换行符或退出子进程时发生。

当将data 推入java.stdout.on('data', function(data) {... 调用时，Socket.io/NodeJS 似乎还有其他一些模式。

我怎样才能确保这一点？

更新： 好的，现在我似乎有了以下代码的换行符：

  var lineBuffer = "";
  java.stdout.on('data', function(data) {  
      lineBuffer += data.toString();
      var lines = lineBuffer.split("\n");

      if (lines.length > 1) {
          var line = lines[0];
          console.log(line);
          io.emit('chat message', line);
          lineBuffer = lines[1];
      }
  });

但是，我看到了一个新问题。 console.log(line) 显示的文本与 emit(line) 命令不同：

listening on *:3000
0000
0
0001
1
...

对比（注意它甚至不是从 0001 开始的）

0002
2 0003
3 0004
4 0005
5 0006
6 0007
7
0008
8 0009 

这是来自io.emit(...) 命令。所以console.log(...) 显示了正确的数据，但socket.io.emit 不是！

Answer 1

您的 java.stdout 是 Node.js 中的 Readable Stream。可读流'data' 事件只是在数据进入时返回数据块，而不管换行符在哪里。

如果您只想在有换行符时发出消息，则必须自己实现该逻辑。试试这个：

var app = require('express')();
var http = require('http').Server(app);
var io = require('socket.io')(http);

app.get('/', function(req, res) {

    res.sendFile(__dirname + '/index.html');

    var spawn = require('child_process').spawn;
    var java = spawn('java', ['-jar', 'misc.jar']);

    var lineBuffer = "";

    java.stdout.on('data', function(data) {

        lineBuffer += data.toString();

        var lines = lineBuffer.split("\n");

        for (var i = 0; i < lines.length - 1; i++) {

            var line = lines[i];

            console.log(line);
            io.emit('chat message', line);
        }

        lineBuffer = lines[lines.length - 1];
    });

    java.stdout.on('end', function() {

        console.log(lineBuffer);
        io.emit('chat message', lineBuffer);
    });
});