RPC結(jié)構(gòu)是怎樣的

RPC 是什么？

RPC 的全稱是 Remote Procedure Call 是一種進(jìn)程間通信方式。它允許程序調(diào)用另一個(gè)地址空間（通常是共享網(wǎng)絡(luò)的另一臺(tái)機(jī)器上）的過程或函數(shù)，而不用程序員顯式編碼這個(gè)遠(yuǎn)程調(diào)用的細(xì)節(jié)。即程序員無論是調(diào)用本地的還是遠(yuǎn)程的，本質(zhì)上編寫的調(diào)用代碼基本相同。

rpc結(jié)構(gòu)

RPC 這個(gè)概念術(shù)語在上世紀(jì) 80 年代由 Bruce Jay Nelson 提出，參考他的論文Implementing Remote Procedure Calls。

Nelson 的論文中指出實(shí)現(xiàn) RPC 的程序包括 5 個(gè)部分：

• User
• User-stub
• RPCRuntime
• Server-stub
• Server

這 5 個(gè)部分的關(guān)系如下圖所示

 

這里 user 就是 client 端，當(dāng) user 想發(fā)起一個(gè)遠(yuǎn)程調(diào)用時(shí)，它實(shí)際是通過本地調(diào)用 user-stub。user-stub 負(fù)責(zé)將調(diào)用的接口、方法和參數(shù)通過約定的協(xié)議規(guī)范進(jìn)行編碼并通過本地的 RPCRuntime 實(shí)例傳輸?shù)竭h(yuǎn)端的實(shí)例。遠(yuǎn)端 RPCRuntime 實(shí)例收到請(qǐng)求后交給 server-stub 進(jìn)行解碼后發(fā)起本地端調(diào)用，調(diào)用結(jié)果再返回給 user 端。

RPC 調(diào)用分類

RPC 調(diào)用分以下兩種：

• 同步調(diào)用：客戶方等待調(diào)用執(zhí)行完成并返回結(jié)果。
• 異步調(diào)用：客戶方調(diào)用后不用等待執(zhí)行結(jié)果返回，但依然可以通過回調(diào)通知等方式獲取返回結(jié)果。若客戶方不關(guān)心調(diào)用返回結(jié)果，則變成單向異步調(diào)用，單向調(diào)用不用返回結(jié)果。

異步和同步的區(qū)分在于是否等待服務(wù)端執(zhí)行完成并返回結(jié)果。

RPC 結(jié)構(gòu)拆解

rpc的詳細(xì)組件如下：

 

RPC 服務(wù)方通過 RpcServer 去導(dǎo)出（export）遠(yuǎn)程接口方法，而客戶方通過 RpcClient 去引入（import）遠(yuǎn)程接口方法?？蛻舴较裾{(diào)用本地方法一樣去調(diào)用遠(yuǎn)程接口方法，RPC 框架提供接口的代理實(shí)現(xiàn)，實(shí)際的調(diào)用將委托給代理RpcProxy 。代理封裝調(diào)用信息并將調(diào)用轉(zhuǎn)交給RpcInvoker 去實(shí)際執(zhí)行。在客戶端的RpcInvoker 通過連接器RpcConnector 去維持與服務(wù)端的通道RpcChannel，并使用RpcProtocol 執(zhí)行協(xié)議編碼（encode）并將編碼后的請(qǐng)求消息通過通道發(fā)送給服務(wù)方。

RPC 服務(wù)端接收器 RpcAcceptor 接收客戶端的調(diào)用請(qǐng)求，同樣使用RpcProtocol 執(zhí)行協(xié)議解碼（decode）。解碼后的調(diào)用信息傳遞給RpcProcessor 去控制處理調(diào)用過程，最后再委托調(diào)用給RpcInvoker 去實(shí)際執(zhí)行并返回調(diào)用結(jié)果。

RPC 組件職責(zé)

各個(gè)組件的職責(zé)如下：

• RpcServer：負(fù)責(zé)導(dǎo)出（export）遠(yuǎn)程接口
• RpcClient：負(fù)責(zé)導(dǎo)入（import）遠(yuǎn)程接口的代理實(shí)現(xiàn)
• RpcProxy：遠(yuǎn)程接口的代理實(shí)現(xiàn)
• RpcInvoker：客戶方實(shí)現(xiàn)：負(fù)責(zé)編碼調(diào)用信息和發(fā)送調(diào)用請(qǐng)求到服務(wù)方并等待調(diào)用結(jié)果返回；服務(wù)方實(shí)現(xiàn)：負(fù)責(zé)調(diào)用服務(wù)端接口的具體實(shí)現(xiàn)并返回調(diào)用結(jié)果
• RpcProtocol：負(fù)責(zé)協(xié)議編/解碼
• RpcConnector：負(fù)責(zé)維持客戶方和服務(wù)方的連接通道和發(fā)送數(shù)據(jù)到服務(wù)方
• RpcAcceptor：負(fù)責(zé)接收客戶方請(qǐng)求并返回請(qǐng)求結(jié)果
• RpcProcessor：負(fù)責(zé)在服務(wù)方控制調(diào)用過程，包括管理調(diào)用線程池、超時(shí)時(shí)間等
• RpcChannel：數(shù)據(jù)傳輸通道