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

概念

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

RPC 的常用通信协议有 HTTP、TCP，常用的编码协议有 JSON、Protobuf、Thrift 等。

Go 实现 RPC

golang 官方的 net/rpc 库使用 encoding/gob 进行编解码，支持 tcp 和 http 数据传输方式，由于其他语言不支持 gob 编解码方式，所以 golang 的 RPC 只支持 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)