Nodejs minimalistisches Einführungs-Tutorial (3): Process_node.js

Obwohl Node über mehrere Threads verfügt, ist JavaScript, das auf Version 8 ausgeführt wird, Single-Threaded. Das Modul child_process des Knotens wird zum Erstellen untergeordneter Prozesse verwendet, und wir können die CPU durch untergeordnete Prozesse vollständig nutzen. Beispiel:

Code kopieren Der Code lautet wie folgt:

var fork = require('child_process').fork;
// Ermittelt die Anzahl der CPUs der aktuellen Maschine
var cpus = require('os').cpus();
for (var i = 0; i < cpus.length; i ) {
// Neuen Prozess generieren
Fork('./worker.js');
}

Hier sind einige Methoden zur Prozesserstellung, einschließlich Fork:

1.spawn(Befehl, [Argumente], [Optionen]), startet einen neuen Prozess zum Ausführen des Befehlsbefehls, args ist der Befehlszeilenparameter
2.exec(Befehl, [Optionen], Rückruf), startet einen neuen Prozess, um den Befehl auszuführen. Der Rückruf wird verwendet, um Standardeingabe, Standardausgabe und Fehlerinformationen zu erhalten, wenn der Prozess endet
3.execFile(file, [args], [options], [callback]), startet einen neuen Prozess, um die ausführbare Datei auszuführen. Rückruf wird verwendet, um Standardeingabe, Standardausgabe und Fehlerinformationen zu erhalten, wenn der Prozess endet
4.fork(modulePath, [args], [options]), startet einen neuen Prozess zum Ausführen eines JavaScript-Dateimoduls und erstellt zu diesem Zeitpunkt einen untergeordneten Knotenprozess

Knotenübergreifende Kommunikation

Übergeordneter Prozess

Code kopieren Der Code lautet wie folgt:

// parent.js
var fork = require('child_process').fork;
// fork gibt das untergeordnete Prozessobjekt n
zurück var n = fork('./child.js');
// Ereignismeldung verarbeiten
n.on('message', function(m) {
// Vom untergeordneten Prozess gesendete Nachricht empfangen
console.log('got message: ' m);
});

//Nachricht an untergeordneten Prozess senden
n.send({hello: 'world'});

Untergeordneter Prozess

Code kopieren Der Code lautet wie folgt:

// child.js
// Ereignismeldung verarbeiten
process.on('message', function(m) {
console.log('got message: ' m);
});

// Es gibt eine Sendemethode im Prozess, die zum Senden von Nachrichten an den übergeordneten Prozess
verwendet wird Process.send({foo: 'bar'});

Es ist zu beachten, dass die Sendemethode hier synchron ist, daher wird nicht empfohlen, große Datenmengen zu senden (Sie können stattdessen Pipe verwenden, Einzelheiten finden Sie unter: http://nodejs.org/api/ alle. html#child_process_child_process_spawn_command_args_options).
In besonderen Fällen, wenn der cmd-Attributwert in der Nachricht das Präfix NODE_ enthält (zum Beispiel: {cmd: 'NODE_foo'} message), wird diese Nachricht nicht an das Nachrichtenereignis (sondern an das internalMessage-Ereignis) gesendet und sie werden intern von Node verwendet.

Der Prototyp der

send-Methode ist:

Code kopieren Der Code lautet wie folgt:

send(message, [sendHandle])

Hier kann sendHandle(handle) zum Senden verwendet werden:

1.net.Native, nativer C-TCP-Socket oder -Pipe
2.net.Server, TCP-Server
3.net.Socket, TCP-Socket
4.dgram.Native, nativer C-UDP-Socket
5.dgram.Socket, UDP-Socket

Wenn send sendHandle sendet, sendet es tatsächlich keine JavaScript-Objekte direkt, sondern sendet einen Dateideskriptor (der schließlich als JSON-Zeichenfolge gesendet wird). Andere Prozesse können diesen Dateideskriptor verwenden, um das entsprechende Objekt wiederherzustellen.

Schauen Sie sich nun ein Beispiel an:

Übergeordneter Prozess

Code kopieren Der Code lautet wie folgt:

// parent.js
var fork = require('child_process').fork;

var n = fork('./child.js');

var server = require('net').createServer();
server.listen(7000, function() {
//TCP-Server an untergeordneten Prozess senden
n.send('server', server);
}).on('connection', function() {
console.log('connection - parent');
});

Untergeordneter Prozess

Code kopieren Der Code lautet wie folgt:

process.on('message', function(m, h) {
If (m === 'server') {
          h.on('connection', function() {
console.log('connection - child');
});
}
});

Greifen Sie über Port 7000 auf dieses Programm zu. Die Ausgabe kann „Verbindung – übergeordnetes Element“ oder „Verbindung – untergeordnetes Element“ lauten. Hier überwachen der untergeordnete Prozess und der übergeordnete Prozess gleichzeitig Port 7000. Im Allgemeinen verursachen mehrere Prozesse, die denselben Port überwachen, eine EADDRINUSE-Ausnahme. In diesem Fall verwenden zwei verschiedene Prozesse denselben Dateideskriptor, und die unterste Ebene von Node legt beim Abhören des Ports die Option SO_REUSEADDR fest ermöglicht die Wiederverwendung dieses Sockets in verschiedenen Prozessen. Wenn mehrere Prozesse denselben Port abhören, kann der Dateideskriptor nur von einem Prozess gleichzeitig verwendet werden, und die Verwendung von Sockets durch diese Prozesse ist präventiv.

Clustermodul

Das Cluster-Modul wurde in Node v0.8 hinzugefügt. Mit dem Cluster-Modul können Sie ganz einfach eine Gruppe von Prozessen erstellen, die denselben Port auf einer physischen Maschine überwachen. Beispiel:

Code kopieren Der Code lautet wie folgt:

var cluster = require('cluster');
var http = require('http');
var numCPUs = require('os').cpus().length;

// Überprüfen Sie, ob der Prozess der Masterprozess ist
if (cluster.isMaster) {
für (var i = 0; i < numCPUs; i)
// Einen neuen Worker-Prozess generieren (nur der Master-Prozess kann aufgerufen werden)
        cluster.fork();

cluster.on('exit', function(worker, code, signal) {
console.log('worker ' worker.process.pid ' died');
});
} sonst {
http.createServer(function(req, res) {
           res.writeHead(200);
          res.end('hello worldn');
}).listen(8000);
}

Wir rufen die Listen-Methode im Worker-Prozess auf und die Listening-Anfrage wird an den Master-Prozess weitergeleitet. Wenn der Master-Prozess bereits über einen Listening-Server verfügt, der die Anforderungen des Worker-Prozesses erfüllt, wird das Handle dieses Servers an den Worker übergeben. Wenn er nicht vorhanden ist, erstellt der Master-Prozess einen und übergibt das Handle dann an den Arbeitsprozess.

Detailliertere Dokumentation zum Cluster: http://www.nodejs.org/api/cluster.html