Go语言之GRPC

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 基础

1. 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 main import ( "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 main import ( "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: 10 CLient 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 main import ( "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 main import ( "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: 10 CLient 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 main import ( "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: 10 CLient revieve: 10 10 参考文档： http://www.kancloud.cn:8080/uvohp5na133/golang/934246 https://golang.org/pkg/net/rpc/ 灰子学技术： ​