Go語言之GRPC

• 2020 年 4 月 2 日
• 筆記

1.RPC的基本知識介紹：

RPC叫做遠程調用框架（Remote Procedure Call），遠程調用原理如下所示：

比如 A (client) 調用 B (server) 提供的remoteAdd方法：首先，A與B之間建立一個TCP連接；然後，A把需要調用的方法名（這裡是remoteAdd）以及方法參數（10， 20）序列化成位元組流發送出去；接著，B接受A發送過來的位元組流，然後反序列化得到目標方法名，方法參數，接著執行相應的方法調用（可能是localAdd）並把結果30返回；最後，A接受遠程調用結果,輸出30。RPC框架就是把我剛才說的這幾點些細節給封裝起來，給用戶暴露簡單友好的API使用。

RPC與Socket的區別：

RPC（遠程過程調用）採用客戶機/伺服器模式實現兩個進程之間相互通訊。socket是RPC經常採用的通訊手段之一，RPC是在Socket的基礎上實現的，它比socket需要更多的網路和系統資源。除了Socket，RPC還有其他的通訊方法，比如：http、作業系統自帶的管道等技術來實現對於遠程程式的調用。

RPC與REST的區別：

REST API 和 RPC 都是在 Server端 把一個個函數封裝成介面暴露出去，以供 Client端 調用，不過 REST API 是基於 HTTP協議的，REST致力於通過http協議中的POST/GET/PUT/DELETE等方法和一個可讀性強的URL來提供一個http請求。而 RPC 則可以不基於 HTTP協議。

因此，如果是後端兩種語言互相調用，用 RPC 可以獲得更好的性能（省去了 HTTP 報頭等一系列東西），應該也更容易配置。

REST API的介紹，可以參考：Go 語言之restful 基礎

2. Go Rpc 的實現例子介紹

對於Go語言來說RPC的實現主要有三種類型，Http Rpc, Tcp Rpc和Json Rpc三種架構。

1) Tcp RPC與Http RPC的比較：

上面這個程式碼和http的伺服器相比，不同在於:在此處我們採用了TCP協議，然後需要自己控制連接，當有客戶端連接上來後，我們需要把這個連接交給rpc來處理。

2) Json RPC與Tcp RPC比較：

JSON RPC是數據編碼採用了JSON，而不是gob編碼，其他和上面介紹的RPC概念一模一樣，json-rpc是基於TCP協議實現的，目前它還不支援HTTP方式。

2.1 Http Rpc

基於Http協議實現的Rpc架構，主要涉及到的API為， rpc.HandleHTTP() 、http.ListenAndServe(":1234", nil)、rpc.DialHTTP("tcp", "127.0.0.1"+":1234")，client.Call("HttpRpcServer.Print", &a, &outStr)

服務端程式碼：

package mainimport (        "fmt"        "strconv"        "net/http"        "net/rpc" )  type HttpRpcServer struct {        a int}// 入參的數量和返回值這些格式是固定的func (s *HttpRpcServer) Print( a *int, o *string) error {         fmt.Println("HttpRpcServer.Print:",*a)        *o = strconv.Itoa(*a)        return nil}  func main() {        fmt.Println("Main start...")        server := new(HttpRpcServer)        rpc.Register(server)        rpc.HandleHTTP()         err := http.ListenAndServe(":1234", nil) // httprpc對於伺服器的連接的控制管理，已經封裝好了        if err != nil {                fmt.Println(err.Error())        }}

客戶端：

package mainimport (        "fmt"        "log"        "net/rpc")  func main() {        client, err := rpc.DialHTTP("tcp", "127.0.0.1"+":1234")// 與伺服器建立連接        if err != nil {                log.Fatal("dialing:", err)        }        var a int = 10        var outStr string        fmt.Println("Client:send:",a)        // 通過字元串的命名格式來調用對應的API，這裡是調用了HttpRpcServer這個數據結構中的Print函數，a和outStr作為入參來處理，err作為Print函數的返回值。        err = client.Call("HttpRpcServer.Print", &a, &outStr)         if err != nil {                log.Fatal("arith error:", err)        }        fmt.Println("CLient revieve:",a,outStr)}

運行結果：

服務端：Main start...HttpRpcServer.Print: 10客戶端：Client:send: 10CLient revieve: 10 10

2.2 Tcp Rpc

Tcp Rpc主要涉及到的API介面

net.ResolveTCPAddr("tcp", ":1234")，net.ListenTCP("tcp", tcpAddr)，

listener.Accept()，rpc.ServeConn(conn)，rpc.Dial("tcp", "127.0.0.1"

+":1234")，client.Call("HttpRpcServer.Print", &a, &outStr)

服務端：

package mainimport (        "fmt"        "strconv"        "net"        "net/rpc")  type HttpRpcServer struct {        a int}  func (s *HttpRpcServer) Print( a *int, o *string) error {        fmt.Println("HttpRpcServer.Print:",*a)        *o = strconv.Itoa(*a)        return nil}  func main() {        fmt.Println("Main start...")        server := new(HttpRpcServer)        rpc.Register(server)        tcpAddr, err := net.ResolveTCPAddr("tcp", ":1234") // 這裡指定協議為tcp        if err != nil {                fmt.Println(err.Error())        }        listener, err := net.ListenTCP("tcp", tcpAddr) // 服務端分開監聽對應的連接        if err != nil {                fmt.Println(err.Error())        }        for {                // AcceptTCP接收下一個呼叫，並返回一個新的*TCPConn。                conn, err := listener.Accept()                if err != nil {                        continue                }                rpc.ServeConn(conn) // 這裡是阻塞的，同時支援多個的話，需要用到go        }}

客戶端：

package mainimport (        "fmt"        "log"        "net/rpc")  func main() {        client, err := rpc.Dial("tcp", "127.0.0.1"+":1234") // tcp的協議來處理        if err != nil {                log.Fatal("dialing:", err)        }        var a int = 10        var outStr string        fmt.Println("Client:send:",a)        err = client.Call("HttpRpcServer.Print", &a, &outStr)        if err != nil {                log.Fatal("arith error:", err)        }        fmt.Println("CLient revieve:",a,outStr)}

運行結果：

服務端：Main start...HttpRpcServer.Print: 10客戶端：Client:send: 10CLient revieve: 10 10

2.3 Json Rpc

Json Rpc主要涉及到的API介面：

net.ResolveTCPAddr("tcp", ":1234")，net.ListenTCP("tcp", tcpAddr)，

listener.Accept(),jsonrpc.ServeConn(conn)，client.Call("HttpRpcServer.Print", &a, &outStr)

服務端：

package main  import (        "fmt"        "strconv"        "net"        "net/rpc"        "net/rpc/jsonrpc")  type HttpRpcServer struct {        a int}  func (s *HttpRpcServer) Print( a *int, o *string) error {        fmt.Println("HttpRpcServer.Print:",*a)        *o = strconv.Itoa(*a)        return nil}  func main() {        fmt.Println("Main start...")        server := new(HttpRpcServer)        rpc.Register(server)        tcpAddr, err := net.ResolveTCPAddr("tcp", ":1234") // 這裡指定協議為tcp        if err != nil {                fmt.Println(err.Error())        }        listener, err := net.ListenTCP("tcp", tcpAddr)        if err != nil {                fmt.Println(err.Error())        }        for {                // AcceptTCP接收下一個呼叫，並返回一個新的*TCPConn。                conn, err := listener.Accept()                if err != nil {                        continue                }                jsonrpc.ServeConn(conn) // 這裡是阻塞的，同時支援多個的話，需要用到go        }}

客戶端：

package mainimport (        "fmt"        "log"        "net/rpc/jsonrpc")  func main() {        client, err := jsonrpc.Dial("tcp", "127.0.0.1"+":1234")        if err != nil {                log.Fatal("dialing:", err)        }        var a int = 10        var outStr string        fmt.Println("Client:send:",a)        err = client.Call("HttpRpcServer.Print", &a, &outStr)        if err != nil {                log.Fatal("arith error:", err)        }        fmt.Println("CLient revieve:",a,outStr)}

運行結果：

服務端：Main start...HttpRpcServer.Print: 10客戶端：Client:send: 10CLient revieve: 10 10

參考文檔： http://www.kancloud.cn:8080/uvohp5na133/golang/934246 https://golang.org/pkg/net/rpc/