Come passare la funzione/callback al processo figlio in Node.js?

Question

Diciamo che ho un parent.js contenente un metodo chiamato parent

var childProcess = require('child_process'); 

var options = { 
    someData: {a:1, b:2, c:3}, 
    asyncFn: function (data, callback) { /*do other async stuff here*/ } 
}; 

function Parent(options, callback) { 
    var child = childProcess.fork('./child'); 
    child.send({ 
     method: method, 
     options: options 
    }); 
    child.on('message', function(data){ 
     callback(data,err, data,result); 
     child.kill(); 
    }); 
} 

Nel frattempo in child.js

process.on('message', function(data){ 
    var method = data.method; 
    var options = data.options; 
    var someData = options.someData; 
    var asyncFn = options.asyncFn; // asyncFn is undefined at here 
    asyncFn(someData, function(err, result){ 
     process.send({ 
      err: err, 
      result: result 
     }); 
    }); 
}); 

mi chiedevo se le funzioni di passaggio al processo figlio non è consentito in Node.js.

Perché lo asyncFn diventa undefined dopo essere stato inviato allo child?

E 'relativo a JSON.stringify?

Answer 1

JSON non supporta le funzioni di serializzazione (almeno fuori dalla scatola). È possibile convertire prima la funzione nella sua rappresentazione di stringa (tramite asyncFn.toString()) e quindi ricreare nuovamente la funzione nel processo figlio. Il problema però è che perdi la portata e il contesto con questo processo, quindi la tua funzione deve essere autonoma.

completo esempio:

parent.js:

var childProcess = require('child_process'); 

var options = { 
    someData: {a:1, b:2, c:3}, 
    asyncFn: function (data, callback) { /*do other async stuff here*/ } 
}; 
options.asyncFn = options.asyncFn.toString(); 

function Parent(options, callback) { 
    var child = childProcess.fork('./child'); 
    child.send({ 
    method: method, 
    options: options 
    }); 
    child.on('message', function(data){ 
    callback(data,err, data,result); 
    child.kill(); 
    }); 
} 

child.js:

process.on('message', function(data){ 
    var method = data.method; 
    var options = data.options; 
    var someData = options.someData; 
    var asyncFn = new Function('return ' + options.asyncFn)(); 
    asyncFn(someData, function(err, result){ 
    process.send({ 
     err: err, 
     result: result 
    }); 
    }); 
});