Einführung in die Implementierungsprinzipien von RPC (Remote Procedure Call) in node.js_node.js

Ich bin gerade mit RPC (Remote Procedure Call) in Kontakt gekommen, einer Methode, mit der ein Programm lokal auf einem Remote-Computer aufgerufen werden kann. Ich habe eine einfache NodeJS-Implementierung gesehen, die sich sehr gut zum Erlernen der RPC-Prinzipien eignet: nodejs light_rpc

Anwendungsbeispiel:

Code kopieren Der Code lautet wie folgt:

//Server
var light_rpc = require('./index.js');
var port = 5556;
var rpc = new light_rpc({
kombinieren: Funktion(a, b, Rückruf){
         Rückruf(a b);
},
​ multiplizieren: function(t, cb){
         cb(t*2);
}
}).listen(port);

Beispielkunde:

Code kopieren Der Code lautet wie folgt:

//Kunde
rpc.connect(5556, 'localhost', function(remote, conn){
Remote.combine(1, 2, function(res){
If(res != 3){
console.log('ERROR', res);
}
});
});

Besprechen Sie kurz den gesamten Prozess:

1. Der Server startet das Programm, lauscht auf den Port, implementiert die vom Client aufgerufenen Funktionen (z. B. Kombinieren und Multiplizieren im obigen Beispiel) und speichert sie in einem Objekt.
2. Der Client startet das Programm, stellt eine Verbindung zum Server her und sendet nach Abschluss der Verbindung den Beschreibungsbefehl, mit dem er den Server auffordert, den Funktionsnamen zurückzugeben, den er zum Aufrufen bereitstellen kann.

Code kopieren Der Code lautet wie folgt:

Connection.on('connect', function(){
Connection.write(command(descrCmd));
});

3. Der Server empfängt den Beschreibungsbefehl, verpackt seinen aufrufbaren Funktionsnamen und sendet ihn aus („combine“, „multiply“)
4. Der Client empfängt den vom Server gesendeten Funktionsnamen, registriert ihn in seinem eigenen Objekt und verpackt eine Methode für jeden Funktionsnamen, sodass er beim lokalen Aufruf dieser Funktionen tatsächlich eine Anfrage an den Server sendet:

Code kopieren Der Code lautet wie folgt:

for(var p in cmd.data){
remoteObj[p] = getRemoteCallFunction(p, self.callbacks, Connection);
//Die Implementierung von getRemoteCallFunction ist unten dargestellt
}

5. Der Client ruft die serverseitige Funktion auf:

1) Generieren Sie eine eindeutige ID für die eingehende Rückruffunktion, genannt callbackId, und zeichnen Sie sie in einem Objekt des Clients auf.
2) Packen Sie die folgenden Daten und senden Sie sie an den Server: Name der aufrufenden Funktion, Liste der serialisierten JSON-Parameter, CallbackId

Code kopieren Der Code lautet wie folgt:

Funktion getRemoteCallFunction(cmdName, Rückrufe, Verbindung){
Rückgabefunktion(){
var id = uuid.generate();
If(typeof arguments[arguments.length-1] == 'function'){
​​callbacks[id] = arguments[arguments.length-1];
}
var args = parseArgumentsToArray.call(this, arguments);
var newCmd = command(cmdName, {id: id, args: args});
Connection.write(newCmd);
}
}

6. Der Server empfängt die oben genannten Informationen, analysiert die Daten, deserialisiert die Parameterliste und ruft die Funktion entsprechend dem Funktionsnamen und den Parametern auf.

Code kopieren Der Code lautet wie folgt:

var args = cmd.data.args;
args.push(getSendCommandBackFunction(c, cmd.data.id));
self.wrapper[cmd.command].apply({}, args);

7. Nachdem die Funktion abgeschlossen ist, serialisieren Sie das Ergebnis und senden Sie es zusammen mit der zuvor empfangenen CallbackId an den Client zurück

Code kopieren Der Code lautet wie folgt:

Funktion getSendCommandBackFunction(connection, cmdId){
Rückgabefunktion(){
var innerArgs = parseArgumentsToArray.call({}, arguments);
var resultCommand = command(resultCmd, {id: cmdId, args: innerArgs});
Connection.write(resultCommand);
};
}

8. Der Client empfängt das Ergebnis der Funktionsoperation und die Callback-ID, ruft die Callback-Funktion basierend auf der Callback-ID ab und übergibt das Operationsergebnis zur Ausführung an die Callback-Funktion.

9. Der gesamte Vorgang ist abgeschlossen. Weitere Informationen finden Sie im Quellcode: https://github.com/romulka/nodejs-light_rpc

Ein paar Punkte, die Sie beachten sollten:

1. Der Client und der Server bleiben während des gesamten Vorgangs verbunden. Die Verbindung wird nach dem Senden und Empfangen getrennt. Daher kann der Abschluss einer Datenübertragung nicht beurteilt werden. Um den Abschluss des Datenempfangs zu beurteilen, folgen die vom Client und Server gesendeten Daten einem einfachen Protokoll: Fügen Sie die Länge des Datenpakets und das Trennzeichen vor den Daten hinzu. Das Trennzeichen ist beispielsweise n: [Paketlänge Daten], sodass nach dem Empfang der Daten zunächst die Länge des Datenpakets ermittelt und dann kontinuierlich beurteilt wird, ob die empfangenen akkumulierten Datenpakete dieser Länge entsprechen oder diese überschreiten. Wenn ja, ist eine Datenübertragung abgeschlossen, und Sie können Beginnen Sie mit dem Parsen und Extrahieren der Daten.

2. Dieser RPC ist einfach, da er den Funktionstyp in den Parametern nicht berücksichtigt. Wenn der Parameter beispielsweise ein Objekt ist und sich unter diesem Objekt Funktionsmitglieder befinden, wird die Funktion während der JSON-Serialisierung ignoriert Funktion kann nicht serverseitig ausgeführt werden.

Um dieses Problem zu lösen, ist eine komplexe Verarbeitung erforderlich:

1. Durchlaufen Sie jeden Parameter, der an das Remote-Ende gesendet werden soll, gründlich, extrahieren Sie die Funktionsmitglieder, generieren Sie eine eindeutige ID für diese Funktion, fügen Sie sie in ein lokales Objekt ein, ersetzen Sie dieses Funktionsmitglied durch diese ID-Zeichenfolge und identifizieren Sie es Member ist eigentlich eine Funktion. Auf diese Weise kann das Objekt serialisiert und versendet werden.
2. Der Server empfängt den Aufruf, wenn er die Funktion im Parameterobjekt verwenden möchte. Er stellt fest, dass es sich um eine Funktion handelt, die vom Client verarbeitet wurde, und sendet die ID an den Client zurück Dieselbe Methode, um eine eigene Rückruffunktion festzulegen. Übergeben Sie die ID an den Client und warten Sie auf den Rückruf vom Client.
3. Der Client empfängt die Funktions-ID, findet die Funktionsentität, ruft sie auf und sendet sie nach Abschluss gemäß der vom Server angegebenen Rückruf-ID an den Server zurück
4. Der Server empfängt das Ergebnis, findet die Rückruffunktion, setzt die Ausführung fort und schließt den Vorgang ab.

Die Aufzeichnungsmethode von Funktionen kann auf andere Weise vervollständigt werden. Die allgemeine Idee besteht darin, die Funktion durch etwas zu ersetzen, das serialisiert werden kann, und die Funktion so aufzuzeichnen, dass sie lokal gefunden werden kann, wenn sie von der Remote-Seite aufgerufen wird. Sie können sich auf die Implementierung von dnode beziehen.