node.js - Node+express如何启用多线程?

 狗血饭团联_367 发布于 2022-11-02 17:04

我自己的写法是创建一个主进程master.js,带子进程worker.js,但是现在遇到一个问题就是,子进程遇到错误崩溃时会让主进程直接崩溃,原因是worker.js中的process.send({act: 'suicide'});行报错,错误代码:

TypeError: process.send is not a function

下方是源码:

//master.js

var express = require('express');
var port = process.env.PORT || 18080;
var app = express();

app.listen(port);

var fork = require('child_process').fork;
var cpus = require('os').cpus();

var workers = {};
var createWorker = function () {
    var worker = fork('./worker.js');
    // 退出时重新启动新的进程
    worker.on('exit', function () {
        console.log('Worker ' + worker.pid + ' exited.');
        delete workers[worker.pid];
        createWorker();
    });
    // 句柄转发
    worker.send('server', express);
    workers[worker.pid] = worker;
    console.log('Create worker. pid: ' + worker.pid);
};

for (var i = 0; i < cpus.length; i++) {
    createWorker();
}

// 进程自己退出时,让所有工作进程退出
process.on('exit', function () {
    for (var pid in workers) {
        workers[pid].kill();
    }
});
//worker.js

var worker;
process.on('message', function (m, tcp) {
    if (m === 'express') {
        worker = tcp;
        worker.on('connection', function (socket) {
            express.emit('connection', socket);
        });
    }
});

process.on('uncaughtException', function (err) {
    process.send({act: 'suicide'});
    // 停止接收新的连接
    worker.close(function () {
        // 所有已有连接断开后,退出进程
        process.exit(1);
    });
    // 5秒后退出进程
    setTimeout(function () {
        process.exit(1);
    }, 5000);
});

var createWorker = function () {
    var worker = fork(__dirname + '/worker.js');
    // 启动新的进程
    worker.on('message', function (message) {
        if (message.act === 'suicide') {
            createWorker();
        }
    });
    worker.on('exit', function () {
        console.log('Worker ' + worker.pid + ' exited.');
        delete workers[worker.pid];
    });
    worker.send('server', express);
    workers[worker.pid] = worker;
    console.log('Create worker. pid: ' + worker.pid);
};
3 个回答
  • 用pm2既可

    2022-11-12 01:44 回答
  • 多线程用的是cluster吧?

    2022-11-12 01:44 回答
  • 我这边已经找到方法了,感谢borgchen指示,解决方法是:

    // app.js
    
    var cluster = require('cluster');
    var http = require('http');
    var numCPUs = require('os').cpus().length;
    
    if (cluster.isMaster) {
        // Fork workers
        for (var i = 0; i < numCPUs; i++) {
            cluster.fork();
        }
    
        cluster.on('exit', function(worker, code, signal) {
            console.log('worker ' + worker.process.pid + ' restart');
            setTimeout(function() {cluster.fork();},2000);
        });
    } else {
        // 这里放入口文件的东西并且直接使用express监听端口
        var express = require('express');
        var port = process.env.PORT || 18080;
        var app = express();
        app.listen(port);
    }

    这里不需要runmaster.jsworker.js,只需要runapp.js即可

    2022-11-12 01:44 回答
撰写答案
今天,你开发时遇到什么问题呢?
立即提问
热门标签
PHP1.CN | 中国最专业的PHP中文社区 | PNG素材下载 | DevBox开发工具箱 | json解析格式化 |PHP资讯 | PHP教程 | 数据库技术 | 服务器技术 | 前端开发技术 | PHP框架 | 开发工具 | 在线工具
Copyright © 1998 - 2020 PHP1.CN. All Rights Reserved 京公网安备 11010802041100号 | 京ICP备19059560号-4 | PHP1.CN 第一PHP社区 版权所有