nodejs:マルチプロセッサを使う
5426 ワード
nodejsはシングルスレッドであり、Nodeは1つのプロセッサだけで動作するという意味です.しかし、多くのサーバーが複数の核を持っています.幸い、nodejsはclusterモジュールを提供しています.タスクをサブプロセスに割り当てることができます.各サブプロセスには他の子プロセスとのsocket接続などの特殊能力があります.clusterを使用する場合、メインプロセスは各特定のトランザクションに参加しません.メインプロセスはすべてのサブプロセスを管理しますが、サブプロセスとI/O操作が相互作用する場合、直接プロセス操作であり、メインプロセスを通過する必要はありません.
簡単な例:
socketを共有する以外に、clusterを利用してもっと多くのことをすることができます.プロcessモジュールの場合、このモジュールは一連の属性を提供します.その中で一番効果的なのは、サブルーチンの健康状態を確認することができます.上記の例では、サブルーチンが死亡した時、メインプロセスはconsolone.log()で死亡プロセスを出力します.
簡単な例:
var cluster = require('cluster');
var http = require('http');
var numCPUs = require('os').cpus().length;
if(cluster.isMaster)
{
//
for(var i=0; i)
{
cluster.fork();
}
cluster.on('death', function(worker)
{
console.log('worker' + worker.pid + 'died');
});
}
else
{
// http
http.Server(function(req, res)
{
res.writeHead(200);
res.end("Hello world
");
}).listen(8000);
} socketを共有する以外に、clusterを利用してもっと多くのことをすることができます.プロcessモジュールの場合、このモジュールは一連の属性を提供します.その中で一番効果的なのは、サブルーチンの健康状態を確認することができます.上記の例では、サブルーチンが死亡した時、メインプロセスはconsolone.log()で死亡プロセスを出力します.
cluster.on('death', function(worker)
{
console.log('worker' + worker.pid + 'died');
cluster.fork();
}); var cluster = require('cluster');
var http = require('http');
var numCPUs = require('os').cpus().length;
var rssWarn = (12*1024*1024),
heapWarn = (12*1024*1024);
if(cluster.isMaster)
{
//
for(var i=0; i)
{
var worker = cluster.fork();
worker.on('message', function(m)
{
if(m.memory)
{
if(m.memory.rss > rssWarn)
{
console.log('Worker' + m.process + 'using too much momory.');
}
}
})
}
cluster.on('death', function(worker)
{
console.log('worker' + worker.pid + 'died');
cluster.fork();
});
}
else
{
// http
http.Server(function(req, res)
{
res.writeHead(200);
res.end("Hello world
");
}).listen(8000);
//
setInterval(function report()
{
process.send({memory: process.memoryUsage(), process: process.pid});
})
}