Dieser Artikel führt Sie durch das Nodejs-Cluster-Modul in node und stellt die Verwendung des Nodejs-Cluster-Moduls vor. Ich hoffe, er wird Ihnen hilfreich sein!
Manchmal wird der Interviewer Sie fragen, wie Sie mehrere Prozesse in nodejs starten können. Das Cluster-Modul sollte Ihnen jetzt sofort in den Sinn kommen, um die Verwendung des Cluster-Moduls zu erkunden.
var cluster = require('cluster');
var os = require('os');
if (cluster.isMaster){
for (var i = 0, n = os.cpus().length; i < n; i += 1){
cluster.fork();
}
} else {
http.createServer(function(req, res) {
res.writeHead(200);
res.end("hello world\n");
}).listen(8000);
}var cluster = require('cluster');
if(cluster.isMaster) {
var numWorkers = require('os').cpus().length;
console.log('Master cluster setting up ' + numWorkers + ' workers...');
for(var i = 0; i < numWorkers; i++) {
cluster.fork();
}
cluster.on('online', function(worker) {
console.log('Worker ' + worker.process.pid + ' is online');
});
cluster.on('exit', function(worker, code, signal) {
console.log('Worker ' + worker.process.pid + ' died with code: ' + code + ', and signal: ' + signal);
console.log('Starting a new worker');
cluster.fork();
});
}Worker-Objekt
Das Worker-Objekt ist der Rückgabewert von cluster.fork() und stellt einen Worker-Prozess dar. Seine Eigenschaften und Methoden sind wie folgt. (1) worker.idworker.id gibt die eindeutige Prozessnummer des aktuellen Arbeiters zurück. Diese Zahl ist auch der Indexwert in „cluster.workers“, der auf den aktuellen Prozess verweist. (2) worker.processAlle Worker-Prozesse werden mit child_process.fork() generiert. Das von child_process.fork() zurückgegebene Objekt wird in worker.process gespeichert. Über dieses Attribut können Sie das Prozessobjekt abrufen, in dem sich der Worker befindet. (3) worker.send()Diese Methode wird im Hauptprozess verwendet, um Informationen an den untergeordneten Prozess zu senden.if (cluster.isMaster) {
var worker = cluster.fork();
worker.send('hi there');
} else if (cluster.isWorker) {
process.on('message', function(msg) {
process.send(msg);
});
}process.on('message', function(message) {
console.log(message);
});worker.send({
type: 'task 1',
from: 'master',
data: {
// the data that you want to transfer
}
});cluster.workers-Objekt
Dieses Objekt ist nur für den Hauptprozess verfügbar und enthält alle Worker-Prozesse. Der Schlüsselwert jedes Mitglieds ist ein Arbeitsprozessobjekt, und der Schlüsselname ist das Attribut worker.id des Arbeitsprozesses.function eachWorker(callback) {
for (var id in cluster.workers) {
callback(cluster.workers[id]);
}
}
eachWorker(function(worker) {
worker.send('big announcement to all workers');
});socket.on('data', function(id) {
var worker = cluster.workers[id];
});Cluster-Moduleigenschaften und -Methoden
isMaster, isWorker
isMaster-Eigenschaft gibt einen booleschen Wert zurück, der angibt, ob der aktuelle Prozess der Hauptprozess ist. Dieses Attribut wird durch Process.env.NODE_UNIQUE_ID bestimmt. Wenn Process.env.NODE_UNIQUE_ID nicht definiert ist, bedeutet dies, dass der Prozess der Hauptprozess ist. Das Attribut isWorker gibt einen booleschen Wert zurück, der angibt, ob der aktuelle Prozess ein Arbeitsprozess ist. Es ist genau der entgegengesetzte Wert des isMaster-Attributs.fork()
Die Fork-Methode wird zum Erstellen eines neuen Arbeitsprozesses verwendet und der Kontext wird in den Hauptprozess kopiert. Nur der Hauptprozess kann diese Methode aufrufen. Diese Methode gibt ein Worker-Objekt zurück.kill()
Die Kill-Methode wird verwendet, um den Arbeitsprozess zu beenden. Es kann einen Parameter akzeptieren, der ein Systemsignal darstellt. Wenn es sich derzeit um den Hauptprozess handelt, wird der Kontakt mit worker.process beendet und dann die Systemsignalmethode an den Worker-Prozess gesendet. Wenn es sich derzeit um einen Arbeitsprozess handelt, beendet er die Kommunikation mit dem Hauptprozess, beendet ihn dann und gibt 0 zurück. In früheren Versionen wurde diese Methode auch worker.destroy() genannt.Listening-Ereignis
Nachdem der Arbeitsprozess die Listening-Methode aufgerufen hat, wird das „Listening“-Ereignis an den Server des Prozesses und dann an den Hauptprozess übertragen. Die Rückruffunktion dieses Ereignisses akzeptiert zwei Parameter, einer ist das aktuelle Worker-Objekt und der andere ist das Adressobjekt, einschließlich URL, Port, Adresstyp (IPv4, IPv6, Unix-Socket, UDP) und anderer Informationen. Dies ist nützlich für Node-Anwendungen, die mehrere URLs bereitstellen.Knotendienst ohne Unterbrechung neu starten
重启服务需要关闭后再启动，利用cluster模块，可以做到先启动一个worker进程，再把原有的所有work进程关闭。这样就能实现不中断地重启Node服务。
首先，主进程向worker进程发出重启信号。
workers[wid].send({type: 'shutdown', from: 'master'});worker进程监听message事件，一旦发现内容是shutdown，就退出。
process.on('message', function(message) {
if(message.type === 'shutdown') {
process.exit(0);
}
});下面是一个关闭所有worker进程的函数。
function restartWorkers() {
var wid, workerIds = [];
for(wid in cluster.workers) {
workerIds.push(wid);
}
workerIds.forEach(function(wid) {
cluster.workers[wid].send({
text: 'shutdown',
from: 'master'
});
setTimeout(function() {
if(cluster.workers[wid]) {
cluster.workers[wid].kill('SIGKILL');
}
}, 5000);
});
};PM2模块
PM2模块是cluster模块的一个包装层。它的作用是尽量将cluster模块抽象掉，让用户像使用单进程一样，部署多进程Node应用。
// app.js
var http = require('http');
http.createServer(function(req, res) {
res.writeHead(200);
res.end("hello world");
}).listen(8080);用PM2从命令行启动这段代码
$ pm2 start app.js -i 4
上面代码的i参数告诉PM2，这段代码应该在cluster_mode启动，且新建worker进程的数量是4个。如果i参数的值是0，那么当前机器有几个CPU内核，PM2就会启动几个worker进程。
如果一个worker进程由于某种原因挂掉了，会立刻重启该worker进程。
# 重启所有worker进程 $ pm2 reload all
每个worker进程都有一个id，可以用下面的命令查看单个worker进程的详情。
$ pm2 show <worker id>
关闭worker进程的时候，可以部署下面的代码，让worker进程监听shutdown消息。一旦收到这个消息，进行完毕收尾清理工作再关闭
process.on('message', function(msg) {
if (msg === 'shutdown') {
close_all_connections();
delete_logs();
server.close();
process.exit(0);
}
});更多node相关知识，请访问：nodejs 教程！！
Das obige ist der detaillierte Inhalt vonLassen Sie uns über das Nodejs-Cluster-Modul sprechen und seine Verwendung vorstellen.. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!
