Go语言之GRPC

幸运草
幸运草
幸运草
9
文章
0
评论
2020年4月20日21:18:42 评论 203

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

特别声明:以上文章内容仅代表作者本人观点,不代表变化吧观点或立场。如有关于作品内容、版权或其它问题请于作品发表后的30日内与变化吧联系。

转载请注明:{{title}}-变化吧
  • 赞助本站
  • 微信扫一扫
  • weinxin
  • 赞助本站
  • 支付宝扫一扫
  • weinxin
幸运草
Go语言中的常量 函数代码

Go语言中的常量

1 概述 常量,一经定义不可更改的量。功能角度看,当出现不需要被更改的数据时,应该使用常量进行存储,例如圆周率。从语法的角度看,使用常量可以保证数据,在整个运行期间内,不会被更改。例如当前处理器的架构...
Go语言的接口 函数代码

Go语言的接口

Go语言-接口 在Go语言中,一个接口类型总是代表着某一种类型(即所有实现它的类型)的行为。一个接口类型的声明通常会包含关键字type、类型名称、关键字interface以及由花括号包裹的若干方法声明...
Go语言支持的正则语法 函数代码

Go语言支持的正则语法

1 字符 语法 说明 . 任意字符,在单行模式(s标志)下,也可以匹配换行 字符类 否定字符类 d Perl 字符类 D 否定 Perl 字符类 ASCII 字符类 否定 ASCII 字符类 pN U...
Go语言的包管理 函数代码

Go语言的包管理

1 概述 Go 语言的源码复用建立在包(package)基础之上。包通过 package, import, GOPATH 操作完成。 2 main包 Go 语言的入口 main() 函数所在的包(pa...