Pengenalan kepada prinsip pelaksanaan RPC (panggilan prosedur jauh) dalam node.js_node.js

Saya baru sahaja bersentuhan dengan RPC (panggilan prosedur jauh), iaitu kaedah yang boleh memanggil program pada mesin jauh secara setempat. Saya melihat pelaksanaan nodejs yang mudah, yang sangat baik untuk mempelajari prinsip RPC: nodejs light_rpc

Contoh penggunaan:

Salin kod Kod adalah seperti berikut:

//Pelayan
var light_rpc = memerlukan('./index.js');
port var = 5556;
var rpc = light_rpc baharu({
gabungkan: fungsi(a, b, panggil balik){
         panggil balik(a b);
},
​ darab: fungsi(t, cb){
         cb(t*2);
}
}).dengar(port);

Contoh pelanggan:

Salin kod Kod adalah seperti berikut:

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

Bercakap secara ringkas tentang keseluruhan proses:

1. Pelayan memulakan program, mendengar port, melaksanakan fungsi yang dipanggil oleh klien (seperti menggabungkan dan mendarab dalam contoh di atas), dan menyimpannya dalam objek.
2. Pelanggan memulakan program, menyambung ke pelayan, dan menghantar arahan huraikan selepas sambungan selesai, meminta pelayan mengembalikan nama fungsi yang boleh disediakan untuk panggilan.

Salin kod Kod adalah seperti berikut:

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

3. Pelayan menerima arahan huraikan, membungkus nama fungsinya yang boleh dipanggil dan menghantarnya keluar ("gabungkan", "darab")
4. Pelanggan menerima nama fungsi yang dihantar oleh pelayan, mendaftarkannya dalam objeknya sendiri dan membungkus kaedah untuk setiap nama fungsi, supaya apabila memanggil fungsi ini secara setempat, ia sebenarnya menghantar permintaan kepada pelayan:

Salin kod Kod adalah seperti berikut:

untuk(var p dalam cmd.data){
remoteObj[p] = getRemoteCallFunction(p, self.callbacks, sambungan);
//Pelaksanaan getRemoteCallFunction ditunjukkan di bawah
}

5. Pelanggan memanggil fungsi bahagian pelayan:

1) Hasilkan ID unik untuk fungsi panggil balik masuk, dipanggil callbackId dan rekodkannya dalam objek klien.
2) Bungkus data berikut dan hantarkannya ke pelayan: nama fungsi panggilan, senarai parameter bersiri JSON, Id panggilan balik

Salin kod Kod adalah seperti berikut:

fungsi getRemoteCallFunction(cmdName, panggilan balik, sambungan){
kembalikan fungsi(){
var id = uuid.generate();
If(typeof arguments[arguments.length-1] == 'function'){
​​panggilan balik[id] = argumen[arguments.length-1];
}
var args = parseArgumentsToArray.call(this, arguments);
var newCmd = command(cmdName, {id: id, args: args});
Connection.write(newCmd);
}
}

6. Pelayan menerima maklumat di atas, menghuraikan data, menyahsiri senarai parameter dan memanggil fungsi mengikut nama fungsi dan parameter.

Salin kod Kod adalah seperti berikut:

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

7 Selepas fungsi selesai, sirikan hasilnya dan hantar semula kepada klien bersama-sama dengan Id panggilan balik yang diterima sebelum ini

Salin kod Kod adalah seperti berikut:

fungsi getSendCommandBackFunction(sambungan, cmdId){
kembalikan fungsi(){
var innerArgs = parseArgumentsToArray.call({}, arguments);
var resultCommand = command(resultCmd, {id: cmdId, args: innerArgs});
Connection.write(resultCommand);
};
}

8. Pelanggan menerima hasil operasi fungsi dan Id panggilan balik, mengeluarkan fungsi panggil balik berdasarkan Id panggilan balik, dan menghantar hasil operasi ke dalam fungsi panggil balik untuk pelaksanaan.

9. Keseluruhan proses telah selesai, sila lihat kod sumber untuk butiran: https://github.com/romulka/nodejs-light_rpc

Beberapa perkara yang perlu diberi perhatian:

1. Klien dan pelayan kekal bersambung semasa keseluruhan proses Tidak seperti protokol http, sambungan diputuskan selepas menghantar dan menerima. Untuk menilai penyiapan penerimaan data, data yang dihantar oleh klien dan pelayan mengikut protokol mudah: tambahkan panjang paket data dan pembatas sebelum data Contohnya, pembatas ialah n: [panjang paket data], supaya selepas menerima data, mula-mula keluarkan panjang paket data, dan kemudian teruskan menilai sama ada paket data terkumpul yang diterima adalah sama atau melebihi panjang ini Jika ya, satu penghantaran data selesai, dan anda boleh mula menghuraikan dan mengekstrak data.

2. RPC ini mudah kerana ia tidak mengambil kira jenis fungsi dalam parameter Contohnya, jika parameter ialah objek dan terdapat ahli fungsi di bawah objek ini, fungsi itu akan diabaikan semasa penyirian JSON, dan ini. fungsi tidak boleh dilaksanakan pada bahagian pelayan.

Untuk menyelesaikan masalah ini, pemprosesan yang kompleks diperlukan:

1. Merentasi setiap parameter yang akan dihantar ke hujung jauh, mengekstrak ahli fungsi, menjana ID unik untuk fungsi ini, memasukkannya ke dalam objek tempatan, menggantikan ahli fungsi ini dengan rentetan id ini dan mengenal pastinya. ahli sebenarnya adalah fungsi. Dengan cara ini, objek boleh disiri dan dihantar keluar.
2. Pelayan menerima panggilan Apabila ia ingin menggunakan fungsi dalam objek parameter, ia menentukan bahawa ini adalah fungsi yang telah diproses oleh klien dan ia menghantar id kembali kepada klien dan menggunakan kaedah yang sama untuk menetapkan fungsi panggil balik sendiri Hantar id kepada klien dan tunggu panggilan balik daripada klien.
3. Pelanggan menerima id fungsi, mencari entiti fungsi, memanggilnya dan selepas selesai, menghantarnya semula ke pelayan mengikut id panggil balik yang diberikan oleh pelayan
4. Pelayan menerima keputusan, mencari fungsi panggil balik, meneruskan pelaksanaan dan melengkapkan.

Kaedah rakaman fungsi boleh diselesaikan dengan cara lain Idea umum adalah untuk menggantikan fungsi dengan sesuatu yang boleh bersiri, dan merekodkan fungsi supaya fungsi itu boleh ditemui secara tempatan apabila dipanggil oleh bahagian jauh. Anda boleh merujuk kepada pelaksanaan dnode.