javascript - Child_process 抛出错误 : write EPIPE

Question

我只是练习一些关于 child_process @the link 的 node js 代码我的 Node 版本是 Windows 7 上的 V5.2.0。

// master.js
var cp=require("child_process");

var np=cp.fork("./console.js");               // line B

// block C
np.stdout.on("data",function(data){
   console.log("child process output:"+data);
});

np.stderr.on("data", function(err){
    console.log("child process output error:"+err);
});

np.on("close", function () {
    console.log("child process exit");
});

// end of block C



np.send({Hello:"world"});
np.on("message",function(msg){
    console.log("parent process got a msg:",msg);
});




// console.js

#!/usr/bin/env node

var aa=1;
console.log("The aa is :"+aa);


process.on("message", function (m) {
    console.log("child process got message:",m);
});

process.send({foo:"bar"});

1) 我运行上面的代码，我得到了错误:write EPIPE。我用谷歌搜索，但没有找到任何有用的答案。我刚接触nodejs，我按照官方文档做了一点修改，然后示例代码就失败了。我发现如果把C block 的代码注释掉，示例代码就可以了。所以我想知道为什么代码会抛出错误，如果 np.stdout/np.stderr 监听“数据”？

$ The aa is :1
events.js:142
      throw er; // Unhandled 'error' event
      ^

Error: write EPIPE
    at exports._errnoException (util.js:856:11)
    at process.target._send (internal/child_process.js:607:18)
    at process.target.send (internal/child_process.js:508:19)
    at Object.<anonymous> (D:\Practice\..\console.js:
11:9)
    at Module._compile (module.js:399:26)
    at Object.Module._extensions..js (module.js:406:10)
    at Module.load (module.js:345:32)
    at Function.Module._load (module.js:302:12)
    at Function.Module.runMain (module.js:431:10)
    at startup (node.js:141:18)

2)修改master.js代码，运行如下代码:

var cp=require("child_process");

var np=cp.spawn("node", ["./console.js"]);

np.send({Hello:"world"});
np.on("message",function(msg){
    console.log("parent process got a msg:",msg);
});

它抛出一个错误:

np.send({Hello:"world"});
   ^

TypeError: np.send is not a function

我重新访问了 node js official doc ，我没有发现 spawn() 和 fork() 有很大不同。所以我想知道为什么 np.send 不是函数？

有没有官方文档没有提到的地方？

Answer 1

1/关于np.send未找到方法

child_process.send 方法在子进程被 fork 或管道设置为 IPC 时可用

fork

When using child_process.fork() you can write to the child using child.send(message[, sendHandle][, callback]) and messages are received by a 'message' event on the child.

中国电信

'ipc' - Create an IPC channel for passing messages/file descriptors between parent and child. A ChildProcess may have at most one IPC stdio file descriptor. Setting this option enables the ChildProcess.send() method. If the child writes JSON messages to this file descriptor, then this will trigger ChildProcess.on('message'). If the child is an Node.js program, then the presence of an IPC channel will enable process.send() and process.on('message').

var child = spawn('cat', ['index.js', {stdio: 'ipc'});

2/关于EPIPE

EPIPE means you're writing to a pipe or socket when the other end has terminated the connection.

这就是说，我发现您的观察很可疑，因为如果您不打开管道，则不会填充子项的 stdout && stderr && stdin 对象。因此它通常会引发错误，例如 TypeError: Cannot read property 'on' of null。

然后我仔细检查了文档，发现 fork 非常特别，我注意到它们没有提供任何 stdio 选项。但是，据说它启用了 send 方法。我的理解是 fork 方法不会打开任何管道，只有 send 方法，on('message') 机制可用。

此代码有效，console.js 保持不变

// master.js
var cp=require("child_process");

var np = cp.fork("./console.js");

np.on("close", function () {
    console.log("child process exit");
});


np.send({Hello:"world"});
np.on("message",function(msg){
    console.log("parent process got a msg:",msg);
});

做一些类似的事情，但是使用 spawn，我们应该利用 stdin 来写，stdout 或 stderr 来听，

// master.js
var cp=require("child_process");

var np = cp.spawn(process.argv[0], ["./console.js"], {stdio: 'pipe'});

np.stdout.on("data",function(data){
   console.log("child process output:"+data);
});

np.stderr.on("data", function(err){
    console.log("child process output error:"+err);
});

np.on("close", function () {
    console.log("child process exit");
});

np.stdin.end(JSON.stringify({Hello:"world"}))

控制台.js

#!/usr/bin/env node

var aa=1;
console.log("The aa is :"+aa);


process.stdin.on("data", function (m) {
    console.log("child process got message:", m.toString());
});

process.stdout.write(JSON.stringify({foo:"bar"}))
// process.send({foo:"bar"});

就是这样。对于您提供的具体错误，我无法给您准确的答复。

希望对您有所帮助。