Go中使用RPC

44次阅读

共计 1579 个字符,预计需要花费 4 分钟才能阅读完成。

概念

远程过程调用(RPC)是一种协议,允许一台计算机(客户端)通过网络调用另一台计算机(服务器)上的程序或服务。它允许不同的系统之间进行通信,从而可以调用远程方法或函数。它包含了传输协议和编码(对象序列号)协议。RPC 本质上也是将 url 映射到对应的函数。

RPC 的常用通信协议有 HTTPTCP,常用的编码协议有 JSONProtobufThrift 等。

Go 实现 RPC

golang 官方的 net/rpc 库使用 encoding/gob 进行编解码,支持 tcphttp 数据传输方式,由于其他语言不支持 gob 编解码方式,所以 golangRPC 只支持 golang 开发的服务器与客户端之间的交互。

服务端

编写服务

type Args struct {
    Number1 int
    Number2 int
}
type CalServer struct {
}

func (s *CalServer) Add(args Args, res *int) error {
    *res = args.Number1 + args.Number2
    return nil
}

func (s *CalServer) Cut(args Args, res *int) error {
    *res = args.Number1 - args.Number2
    return nil
}
  1. 结构体字段首字母要大写。
  2. 函数名首字要母大写。
  3. 函数第一参数是接收参数,第二个参数是返回给客户端的参数且必须是指针类型。
  4. 函数还必须有一个返回值 error

注册服务

不指定服务名称,使用结构体名称。

server := &CalServer{}
rpc.Register(server)

指定服务名称

server := &CalServer{}
rpc.RegisterName("CalServer", server)

绑定传输协议并启动服务

使用 TCP 协议

// 服务端使用 TCP 协议
listener, _ := net.Listen("tcp", ":8080")
conn, _ := listener.Accept()
rpc.ServeConn(conn)

// 客户端对应使用 TCP 协议
rpc.Dial("tcp", ":8080")

使用 HTTP 协议

// 服务端使用 HTTP 协议
rpc.HandleHTTP()
http.ListenAndServe(":8080", nil)

// 客户端对应使用 HTTP 协议
rpc.DialHTTP("tcp", ":1235")

客户端

建立连接

使用 TCP 协议

rpc.Dial("tcp", ":8080")

使用 HTTP 协议

rpc.DialHTTP("tcp", ":8080")

调用

同步调用

client.Call("CalServer.Add", &Args{1, 2}, &reply)

异步调用

call := client.Go("CalServer.Add", &Args{1, 2}, &reply, nil)
<-call.Done

Go 实现 JsonRPC

在上面 RPC 的基础上,将编码协议改为 JSON 即可。

服务端

l, _ := net.Listen("tcp", ":8080")
conn, _ := l.Accept()
// 设置编码协议为 json
rpc.ServeCodec(jsonrpc.NewServerCodec(conn))

客户端

conn, _ := net.Dial("tcp", ":8080")
// 设置编码协议为 json
client := rpc.NewClientWithCodec(jsonrpc.NewClientCodec(conn))
client.Call("CalServer.Add", &Args{1, 2}, &reply)

或者你可以直接用 jsonrpc 包中的 Dial 方法。

client, _ := jsonrpc.Dial("tcp", ":8080")
client.Call("CalServer.Add", &Args{1, 2}, &reply)
正文完
 
dkp
版权声明:本站原创文章,由 dkp 2024-01-02发表,共计1579字。
转载说明:除特殊说明外本站文章皆由CC-4.0协议发布,转载请注明出处。