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

在Server端需要完成兩件事

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

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

//構(gòu)造一個(gè)類型，添加Hello方法
type?HelloService?struct{}
//注意Go語(yǔ)言的RPC規(guī)則
func?(p?*HelloService)?Hello(request?string,?reply?*string)?error?{
?*reply?=?"hello:"?+?request
?return?nil
}
func?main()?{
?rpc.RegisterName("HelloService",?new(HelloService))?//注冊(cè)結(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需要完成一件事：訪問(wèn)端口連接并調(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)庫(kù)的RPC默認(rèn)采用Go語(yǔ)言特有的gob編碼，因此從其它語(yǔ)言調(diào)用Go語(yǔ)言實(shí)現(xiàn)的RPC服務(wù)將比較困難。雖然可以通過(guò)額外的工作支持跨語(yǔ)言，但是其實(shí)沒(méi)必要，我們可以使用ProtoBuf和gRPC等框架支持跨語(yǔ)言。

編輯：黃飛

?