RPC是遠(yuǎn)程過程調(diào)用的簡稱，是分布式系統(tǒng)中不同節(jié)點(diǎn)間流行的通信方式。互聯(lián)網(wǎng)時(shí)代，RPC已經(jīng)和IPC一樣成為一個(gè)不可或缺的基礎(chǔ)構(gòu)件。 Go語言的標(biāo)準(zhǔn)庫也提供了一個(gè)簡單的RPC實(shí)現(xiàn)，包名為net/rpc。下面是使用該包的基本框架：

在Server端需要完成兩件事

明確服務(wù)名稱和接口方法：方法只能有兩個(gè)可序列化的參數(shù)，第二個(gè)參數(shù)是指針類型，并返回error類型，同時(shí)必須是公開的方法

注冊RPC服務(wù)并綁定到某一端口進(jìn)行監(jiān)聽

//構(gòu)造一個(gè)類型，添加Hello方法
type?HelloService?struct{}
//注意Go語言的RPC規(guī)則
func?(p?*HelloService)?Hello(request?string,?reply?*string)?error?{
?*reply?=?"hello:"?+?request
?return?nil
}
func?main()?{
?rpc.RegisterName("HelloService",?new(HelloService))?//注冊結(jié)構(gòu)體類型為RPC服務(wù)
?//這里建立TCP連接用于RPC服務(wù)，也支持HTTP協(xié)議的RPC
?listener,?err?:=?net.Listen("tcp",?":1234")
?if?err?!=?nil?{
??log.Fatal("Listen?TCP?error:",?err)
?}

?conn,?err?:=?listener.Accept()
?if?err?!=?nil?{
??log.Fatal("Accept?error:",?err)
?}

?rpc.ServeConn(conn)
}

在client需要完成一件事：訪問端口連接并調(diào)用接口方法

func?main()?{
?//嘗試與server端建立TCP連接
?client,?err?:=?rpc.Dial("tcp",?"localhost:1234")
?if?err?!=?nil?{
??log.Fatal("Dial?RPC?error:",?err)
?}

?var?reply?string
?//調(diào)用遠(yuǎn)程方法并傳入?yún)?shù)
?err?=?client.Call("HelloService.Hello",?"barret",?&reply)
?if?err?!=?nil?{
??log.Fatal("call?RPC?function?error:",?err)
?}

?fmt.Println(reply)
}

需要注意的是：標(biāo)準(zhǔn)庫的RPC默認(rèn)采用Go語言特有的gob編碼，因此從其它語言調(diào)用Go語言實(shí)現(xiàn)的RPC服務(wù)將比較困難。雖然可以通過額外的工作支持跨語言，但是其實(shí)沒必要，我們可以使用ProtoBuf和gRPC等框架支持跨語言。

編輯：黃飛

?