RPC（Remote Procedure Call），主要是幫助我們屏蔽網(wǎng)絡(luò)編程細(xì)節(jié) ，是我們更專注于業(yè)務(wù)邏輯，實(shí)現(xiàn)調(diào)用遠(yuǎn)程方法就像調(diào)用本地方法一樣。

RPC通信過程

由服務(wù)提供者給出業(yè)務(wù)接口聲明，在調(diào)用方的程序里面，RPC 框架根據(jù)調(diào)用的服務(wù)接口提前生成動態(tài)代理實(shí)現(xiàn)類，并通過依賴注入等技術(shù)注入到聲明了該接口的相關(guān)業(yè)務(wù)邏輯里面。該代理實(shí)現(xiàn)類會攔截所有的方法調(diào)用，在提供的方法處理邏輯里面完成一整套的遠(yuǎn)程調(diào)用，并把遠(yuǎn)程調(diào)用結(jié)果返回給調(diào)用方，這樣調(diào)用方在調(diào)用遠(yuǎn)程方法的時候就獲得了像調(diào)用本地接口一樣的體驗(yàn)。

RPC設(shè)計組成

以下是對RPC的四種角色的解釋和說明：

客戶端(Client)： 服務(wù)調(diào)用發(fā)起方，也稱為服務(wù)消費(fèi)者。

客戶端存根(Client Stub)： 該程序運(yùn)行在客戶端所在的計算機(jī)機(jī)器上，主要用來存儲要調(diào)用的服務(wù)器的地址，另外，該程序還負(fù)責(zé)將客戶端請求遠(yuǎn)端服務(wù)器程序的數(shù)據(jù)信息打包成數(shù)據(jù)包，通過網(wǎng)絡(luò)發(fā)送給服務(wù)端Stub程序；其次，還要接收服務(wù)端Stub程序發(fā)送的調(diào)用結(jié)果數(shù)據(jù)包，并解析返回給客戶端。

服務(wù)端(Server)： 遠(yuǎn)端的計算機(jī)機(jī)器上運(yùn)行的程序，其中有客戶端要調(diào)用的方法。

服務(wù)端存根(Server Stub)： 接收客戶Stub程序通過網(wǎng)絡(luò)發(fā)送的請求消息數(shù)據(jù)包，并調(diào)用服務(wù)端中真正的程序功能方法，完成功能調(diào)用；其次，將服務(wù)端執(zhí)行調(diào)用的結(jié)果進(jìn)行數(shù)據(jù)處理打包發(fā)送給客戶端Stub程序。

RPC原理和調(diào)用步驟

實(shí)際上，如果我們想要在網(wǎng)絡(luò)中的任意兩臺計算機(jī)上實(shí)現(xiàn)遠(yuǎn)程調(diào)用過程，要解決很多問題，比如：

• 兩臺物理機(jī)器在網(wǎng)絡(luò)中要建立穩(wěn)定可靠的通信連接。
• 兩臺服務(wù)器的通信協(xié)議的定義問題，即兩臺服務(wù)器上的程序如何識別對方的請求和返回結(jié)果。也就是說兩臺計算機(jī)必須都能夠識別對方發(fā)來的信息，并且能夠識別出其中的請求含義和返回含義，然后才能進(jìn)行處理。這其實(shí)就是通信協(xié)議所要完成的工作。

我們來看看RPC具體是如何解決這些問題的，RPC具體的調(diào)用步驟圖如下：

在上述圖中，通過1-10的步驟圖解的形式，說明了RPC每一步的調(diào)用過程。具體描述為：

1、客戶端想要發(fā)起一個遠(yuǎn)程過程調(diào)用，首先通過調(diào)用本地客戶端Stub程序的方式調(diào)用想要使用的功能方法名；

2、客戶端Stub程序接收到了客戶端的功能調(diào)用請求，將客戶端請求調(diào)用的方法名，攜帶的參數(shù)等信息做序列化操作，并打包成數(shù)據(jù)包。

3、客戶端Stub查找到遠(yuǎn)程服務(wù)器程序的IP地址，調(diào)用Socket通信協(xié)議，通過網(wǎng)絡(luò)發(fā)送給服務(wù)端。

4、服務(wù)端Stub程序接收到客戶端發(fā)送的數(shù)據(jù)包信息，并通過約定好的協(xié)議將數(shù)據(jù)進(jìn)行反序列化，得到請求的方法名和請求參數(shù)等信息。

5、服務(wù)端Stub程序準(zhǔn)備相關(guān)數(shù)據(jù)，調(diào)用本地Server對應(yīng)的功能方法進(jìn)行，并傳入相應(yīng)的參數(shù)，進(jìn)行業(yè)務(wù)處理。

6、服務(wù)端程序根據(jù)已有業(yè)務(wù)邏輯執(zhí)行調(diào)用過程，待業(yè)務(wù)執(zhí)行結(jié)束，將執(zhí)行結(jié)果返回給服務(wù)端Stub程序。

7、服務(wù)端Stub程序?qū)⒊绦蛘{(diào)用結(jié)果按照約定的協(xié)議進(jìn)行序列化， 并通過網(wǎng)絡(luò)發(fā)送回客戶端Stub程序。

8、客戶端Stub程序接收到服務(wù)端Stub發(fā)送的返回數(shù)據(jù)，對數(shù)據(jù)進(jìn)行反序列化操作， 并將調(diào)用返回的數(shù)據(jù)傳遞給客戶端請求發(fā)起者。

9、客戶端請求發(fā)起者得到調(diào)用結(jié)果，整個RPC調(diào)用過程結(jié)束。

簡單的使用

在對RPC進(jìn)行簡單介紹之后，我們先看一個簡單的RPC服務(wù)注冊和調(diào)用的demo，

服務(wù)端代碼如下：

package main
import (
	"fmt"
	"log"
	"net"
	"net/rpc"
)
type HelloService struct{}
func (p *HelloService) Hello(request string, reply *string) error {
	*reply = "hello:" + request
	log.Println("got req", request)
	return nil
}
func main() {
	// 創(chuàng)建TCP服務(wù)器
	listener, err := net.Listen("tcp", ":8888")
	if err != nil {
		fmt.Println("Listen error:", err)
		return
	}
	// 創(chuàng)建RPC服務(wù)
	rpcServer := rpc.NewServer()
	// 注冊RPC服務(wù)(可以注冊多個)
	rpcServer.RegisterName("HelloService", new(HelloService))
	// 開始接收RPC請求
	rpcServer.Accept(listener)
}

客戶端代碼如下:

package main
import (
   "fmt"
   "log"
   "net/rpc"
)
func main() {
    //訪問rpc服務(wù)端
   client, err := rpc.Dial("tcp", "localhost:8888")
   if err != nil {
      log.Fatal("dialing:", err)
   }
   var reply string 
    //調(diào)用rpc服務(wù)的指定方法
   err = client.Call("HelloService.Hello", "RPC", &reply)
   if err != nil {
      log.Fatal(err)
   }
   fmt.Println(reply)
}

啟動server.go 之后啟動client.go ，RPC調(diào)用成功，控制臺分別打印：

// server
got req RPC
// client
hello:RPC

以上就是Golang RPC的原理與簡單調(diào)用詳解的詳細(xì)內(nèi)容，更多關(guān)于Golang RPC的資料請關(guān)注腳本之家其它相關(guān)文章！

最新評論