Tag: 集群计算

当节点进程被终止时,终止所有的child_process

如何确保所有child_process在父进程被终止时被终止。 我有像下面这样的东西。 即使当节点进程被杀死,我看到FFMPEG继续运行,out.avi生成。 如何在节点进程退出后停止运行FFMPEG。 var args = "ffmpeg -i in.avi out.avi" child_process.exec(args , function(err, stdout,stderr){}); child_process.exec(args , function(err, stdout,stderr){});

在node.js中,如何声明一个可由主进程初始化并由工作进程访问的共享variables?

我想要以下 在启动过程中,主进程从文件加载一个大表并将其保存到共享variables中。 该表有9列和1200万行,432MB的大小。 工作进程运行HTTP服务器,接受对大表的实时查询。 这是我的代码,显然没有达到我的目标。 var my_shared_var; var cluster = require('cluster'); var numCPUs = require('os').cpus().length; if (cluster.isMaster) { // Load a large table from file and save it into my_shared_var, // hoping the worker processes can access to this shared variable, // so that the worker processes do not need to reload the table from […]

NodeJS |集群:如何将数据从主数据发送到所有或单个子/员工?

我从节点工作(股票)脚本 var cluster = require('cluster'); var http = require('http'); var numReqs = 0; if (cluster.isMaster) { // Fork workers. for (var i = 0; i < 2; i++) { var worker = cluster.fork(); worker.on('message', function(msg) { if (msg.cmd && msg.cmd == 'notifyRequest') { numReqs++; } }); } setInterval(function() { console.log("numReqs =", numReqs); }, 1000); } […]

我如何使用简单的Express应用程序使用Node.js群集?

– 我构build了一个简单的应用程序,它从一个Redis数据库中提取数据(50个项目),并在本地主机上抛出。 我做了一个ApacheBench(c = 100,n = 50000),我在双核T2080 @ 1.73GHz(我的6哟笔记本电脑)上获得了150次请求/秒,但是使用过程非常令人失望,图所示: 只有一个核心使用,这是按照devise在节点,但我想我几乎可以加倍我的请求/秒〜300,甚至更多,如果我可以使用Node.js群集。 我摆弄了很多,但我一直无法弄清楚如何把这里给出的代码与我的应用程序一起使用,如下所示: var express = require( 'express' ), app = express.createServer(), redis = require( 'redis' ).createClient(); app.configure( function() { app.set( 'view options', { layout: false } ); app.set( 'view engine', 'jade' ); app.set( 'views', __dirname + '/views' ); app.use( express.bodyParser() ); } ); function log( what […]