6

在我的快速服务器中,我需要将一些功能作为子进程运行,否则它们会占用服务器并且其他人将无法访问它。他们已经在使用异步模块,但除非它们作为子进程运行,否则它们仍然会占用服务器。

一个问题是将 req 和 res 参数传递给它们。

如何才能做到这一点?

4

1 回答 1

15

使用child_process.fork,您可以向子进程发送消息。

编辑:我错误地建议将reqres作为消息参数传递给子进程。这是不可能的,因为所有进出子进程的消息都转换为 JSON。相反,您可以在服务器中保留某种队列。以下仅作为示例,您可能需要更强大的东西:

child.js:

process.on('message', function(message) {
    // Process data

    process.send({id: message.id, data: 'some result'});
});

server.js:

var child_process = require('child_process');
var child = child_process.fork(__dirname + '/child.js');
var taskId = 0;
var tasks = {};

function addTask(data, callback) {
    var id = taskId++;

    child.send({id: id, data: data});

    tasks[id] = callback;
};

child.on('message', function(message) {
    // Look up the callback bound to this id and invoke it with the result
    tasks[message.id](message.data);
});

app.post('/foo', function(req, res) {
    addTask('some data', function(result) {
        res.send(result);
    });
});

它涉及更多,但它应该工作。您可能会很快脱离这样的系统,并且可以通过适当的队列更好地服务。

于 2012-06-03T13:15:03.950 回答