node.js中RPC(遠(yuǎn)程過程調(diào)用)的實(shí)現(xiàn)原理介紹
剛接觸到RPC（遠(yuǎn)程過程調(diào)用），就是可以在本地調(diào)用遠(yuǎn)程機(jī)子上的程序的方法，看到一個(gè)簡單的nodejs實(shí)現(xiàn)，用來學(xué)習(xí)RPC的原理很不錯(cuò)：nodejs light_rpc
使用示例：
//服務(wù)端
var light_rpc = require('./index.js');
var port = 5556;
var rpc = new light_rpc({
combine: function(a, b, callback){
callback(a + b);
},
multiply: function(t, cb){
cb(t*2);
}
}).listen(port);
Sample client:
//客戶端
rpc.connect(5556, 'localhost', function(remote, conn){
remote.combine(1, 2, function(res){
if(res != 3){
console.log('ERROR', res);
}
});
});
簡單說說整個(gè)過程：
1.server端啟動(dòng)程序，偵聽端口，實(shí)現(xiàn)提供給client調(diào)用的函數(shù)（如上述例子的combine和multiply），保存在一個(gè)對(duì)象里。
2.client端啟動(dòng)程序，連接服務(wù)端，連接完成后發(fā)送describe命令，要求server返回它能提供調(diào)用的函數(shù)名。
connection.on('connect', function(){
connection.write(command(descrCmd));
});
3.server端接收到describe命令，把自己可供調(diào)用的函數(shù)名包裝好發(fā)送出去(“combine”, “multiply”)
4.client端接收到server發(fā)送的函數(shù)名，注冊(cè)到自己的對(duì)象里，給每個(gè)函數(shù)名包裝一個(gè)方法，使本地調(diào)用這些函數(shù)時(shí)實(shí)際上是向server端發(fā)送請(qǐng)求:
for(var p in cmd.data){
remoteObj[p] = getRemoteCallFunction(p, self.callbacks, connection);
//getRemoteCallFunction的實(shí)現(xiàn)見下面
}
5.client端調(diào)用server端的函數(shù)：
1) 給傳入的callback函數(shù)生成一個(gè)唯一ID，稱為callbackId，記錄到client的一個(gè)對(duì)象里。
2) 包裝好以下數(shù)據(jù)發(fā)送給server端：調(diào)用函數(shù)名，JSON序列化后的參數(shù)列表，callbackId
function getRemoteCallFunction(cmdName, callbacks, connection){
return function(){
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.server端接收到上述信息，解析數(shù)據(jù)，對(duì)參數(shù)列表反序列化，根據(jù)函數(shù)名和參數(shù)調(diào)用函數(shù)。
var args = cmd.data.args;
args.push(getSendCommandBackFunction(c, cmd.data.id));
self.wrapper[cmd.command].apply({}, args);
7.函數(shù)運(yùn)行完成后，把結(jié)果序列化，連同之前收到的callbackId發(fā)送回client端
function getSendCommandBackFunction(connection, cmdId){
return function(){
var innerArgs = parseArgumentsToArray.call({}, arguments);
var resultCommand = command(resultCmd, {id: cmdId, args: innerArgs});
connection.write(resultCommand);
};
}
8.client端接收到函數(shù)運(yùn)行結(jié)果和callbackId，根據(jù)callbackId取出回調(diào)函數(shù)，把運(yùn)行結(jié)果傳入回調(diào)函數(shù)中執(zhí)行。
9.整個(gè)過程完成，詳見源碼：https://github.com/romulka/nodejs-light_rpc
幾個(gè)注意的點(diǎn)：
1.整個(gè)過程中client和server一直保持連接，不像http協(xié)議發(fā)送和接收完就斷開鏈接，所以不能以斷開鏈接判斷一次數(shù)據(jù)的傳送完成。為了判斷數(shù)據(jù)接收完成，client和server發(fā)送的數(shù)據(jù)遵循一個(gè)簡單的協(xié)議：在數(shù)據(jù)前加上數(shù)據(jù)包的長度和分隔符，如定分隔符為\n：[數(shù)據(jù)包長度\n數(shù)據(jù)]，這樣在收到數(shù)據(jù)后首先取出數(shù)據(jù)包的長度，再不斷判斷累計(jì)已接收到的數(shù)據(jù)包是否等于或超過這個(gè)長度，若是則一次數(shù)據(jù)傳送完成，可以開始解析提取數(shù)據(jù)。
2.這個(gè)RPC簡單在于沒有考慮參數(shù)里有函數(shù)類型的情況，例如有參數(shù)是一個(gè)object，這個(gè)object下有函數(shù)成員，JSON序列化時(shí)會(huì)把函數(shù)忽略，在server端是執(zhí)行不了這個(gè)函數(shù)的。
為了解決這個(gè)問題，需要進(jìn)行復(fù)雜的處理：
1.深度遍歷每個(gè)要發(fā)送給遠(yuǎn)端的參數(shù)，把函數(shù)成員抽出來，給這個(gè)函數(shù)生成唯一id，放到本地一個(gè)對(duì)象里，把這個(gè)函數(shù)成員替換成這個(gè)id字符串，并標(biāo)識(shí)這個(gè)成員實(shí)際上是一個(gè)函數(shù)。這樣這個(gè)對(duì)象就可以序列化發(fā)送出去了。
2.server接收到調(diào)用，當(dāng)要使用參數(shù)object里的函數(shù)時(shí)，判斷到這是一個(gè)經(jīng)過client處理過的函數(shù)，有一個(gè)id，把這個(gè)id發(fā)送回client端，并用同樣的方法把自身的回調(diào)函數(shù)id傳給client，等待client端的回調(diào)。
3.client端接收到這個(gè)函數(shù)id，找到這個(gè)函數(shù)實(shí)體，調(diào)用，完成后根據(jù)server端給的回調(diào)id發(fā)送回給server端
4.server端收到結(jié)果，找到回調(diào)函數(shù)，繼續(xù)執(zhí)行，完成。
函數(shù)的記錄方法可以以其他方式完成，大體思路就是把函數(shù)替換成可序列化的東西，記錄函數(shù)以便remote端調(diào)用時(shí)能在本地找到這個(gè)函數(shù)?？梢詤⒖糳node的實(shí)現(xiàn)。
相關(guān)文章
解決Mac安裝thrift因bison報(bào)錯(cuò)的問題
今天小編就為大家分享一篇解決Mac安裝thrift因bison報(bào)錯(cuò)的問題，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。一起跟隨小編過來看看吧2018-05-05
這篇文章主要為大家介紹了Node.js讀取文件教程示例詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪2023-11-11
Node.js如何實(shí)現(xiàn)注冊(cè)郵箱激活功能 (常見)
今天了解了node如何實(shí)現(xiàn)郵箱激活功能，這個(gè)功能非常常見，當(dāng)我們注冊(cè)一個(gè)賬號(hào)時(shí)，肯定會(huì)有這步，下面看下如何實(shí)現(xiàn)這個(gè)功能2017-07-07
這篇文章主要介紹了node.js中的console.info方法使用說明,本文介紹了console.info的方法說明、語法、接收參數(shù)、使用實(shí)例和實(shí)現(xiàn)源碼,需要的朋友可以參考下2014-12-12
node.js讀取Excel數(shù)據(jù)（下載圖片）的方法示例
這篇文章主要給大家介紹了關(guān)于node.js讀取Excel數(shù)據(jù)（下載圖片）的相關(guān)資料，文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家學(xué)習(xí)或者使用node.js具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2018-08-08
這篇文章主要為大家介紹了阿里云OSS實(shí)踐文件直傳基于服務(wù)端實(shí)現(xiàn)示例，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪2022-06-06
本文嘗試結(jié)合Marc Fasel的指導(dǎo)思想和筆者的實(shí)踐經(jīng)驗(yàn)來介紹一些NodeJS的異步編程風(fēng)格，希望對(duì)NodeJS的初學(xué)者有所啟發(fā)。2015-10-10
詳解如何優(yōu)雅在webpack項(xiàng)目實(shí)現(xiàn)mock服務(wù)器
這篇文章主要為大家介紹了詳解如何優(yōu)雅在webpack項(xiàng)目實(shí)現(xiàn)mock服務(wù)器，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪2023-02-02
這篇文章主要介紹了Node.js中的Async和Await函數(shù)的相關(guān)知識(shí)，非常不錯(cuò)，具有參考借鑒價(jià)值,需要的朋友可以參考下2018-02-02
這篇文章主要介紹了Nodejs 復(fù)制文件/文件夾的方法,需要的朋友可以參考下2017-08-08