Node.js
クラスタモジュール
サーチ…
構文
- const cluster = require( "cluster")
- cluster.fork()
- cluster.isMaster
- cluster.isWorker
- cluster.schedulingPolicy
- cluster.setupMaster(設定)
- cluster.settings
- cluster.worker //ワーカー
- cluster.workers //マスターに
備考
cluster.fork()
は、現行のスクリプトを最初から実行し始める子プロセスを生成することに注意してください。これは、 Cの fork()
システムコールとは異なり、現在のプロセスをクローンし、子プロセス。
こんにちは世界
これはあなたのcluster.js
です:
const cluster = require('cluster');
const http = require('http');
const numCPUs = require('os').cpus().length;
if (cluster.isMaster) {
// Fork workers.
for (let i = 0; i < numCPUs; i++) {
cluster.fork();
}
cluster.on('exit', (worker, code, signal) => {
console.log(`worker ${worker.process.pid} died`);
});
} else {
// Workers can share any TCP connection
// In this case it is an HTTP server
require('./server.js')();
}
これがメインのserver.js
です:
const http = require('http');
function startServer() {
const server = http.createServer((req, res) => {
res.writeHead(200);
res.end('Hello Http');
});
server.listen(3000);
}
if(!module.parent) {
// Start server if file is run directly
startServer();
} else {
// Export server, if file is referenced via cluster
module.exports = startServer;
}
この例では、基本Webサーバーをホストしていますが、組み込みのクラスタモジュールを使用して作業者(子プロセス)をスピンアップします 。 forkerプロセスの数は、利用可能なCPUコアの数に依存します。これにより、Node.jsの単一のインスタンスが単一のスレッドで実行されるため、Node.jsアプリケーションでマルチコアCPUを利用することができます。アプリケーションは、すべてのプロセスでポート8000を共有します。負荷は、既定でRound-Robinメソッドを使用してワーカー間で自動的に分散されます。
クラスタの例
Node.js
単一のインスタンスは、単一のスレッドで実行されます。マルチコアシステムを利用するには、Node.jsプロセスのクラスタでアプリケーションを起動して負荷を処理します。
cluster
モジュールを使用すると、すべてのサーバーポートを共有する子プロセスを簡単に作成できます。
次の例では、複数のコアにわたる負荷を処理するメインプロセスでワーカーの子プロセスを作成します。
例
const cluster = require('cluster');
const http = require('http');
const numCPUs = require('os').cpus().length; //number of CPUS
if (cluster.isMaster) {
// Fork workers.
for (var i = 0; i < numCPUs; i++) {
cluster.fork(); //creating child process
}
//on exit of cluster
cluster.on('exit', (worker, code, signal) => {
if (signal) {
console.log(`worker was killed by signal: ${signal}`);
} else if (code !== 0) {
console.log(`worker exited with error code: ${code}`);
} else {
console.log('worker success!');
}
});
} else {
// Workers can share any TCP connection
// In this case it is an HTTP server
http.createServer((req, res) => {
res.writeHead(200);
res.end('hello world\n');
}).listen(3000);
}
Modified text is an extract of the original Stack Overflow Documentation
ライセンスを受けた CC BY-SA 3.0
所属していない Stack Overflow