一文吃透 Go 内置 RPC 原理

hello 大家好呀，我是小楼，这是系列文《Go底层原理剖析》的第三篇，依旧分析 Http 模块。我们今天来看 Go内置的 RPC。说起 RPC 大家想到的一般是框架，Go 作为编程语言竟然还内置了 RPC，着实让我有些吃鲸。

从一个 Demo 入手

为了快速进入状态，我们先搞一个 Demo，当然这个 Demo 是参考 Go 源码 src/net/rpc/server.go，做了一丢丢的修改。

• 首先定义请求的入参和出参：
  

1. package common
3. type Args struct {
4.         A, B int
5. }
7. type Quotient struct {
8.         Quo, Rem int
9. }

复制代码

• 接着在定义一个对象，并给这个对象写两个方法
  

1. type Arith struct{}
3. func (t *Arith) Multiply(args *common.Args, reply *int) error {
4.         *reply = args.A * args.B
5.         return nil
6. }
8. func (t *Arith) Divide(args *common.Args, quo *common.Quotient) error {
9.         if args.B == 0 {
10.                 return errors.New("divide by zero")
11.         }
12.         quo.Quo = args.A / args.B
13.         quo.Rem = args.A % args.B
14.         return nil
15. }

复制代码

• 然后起一个 RPC  server：
  

1. func main() {
2.         arith := new(Arith)
3.         rpc.Register(arith)
4.         rpc.HandleHTTP()
5.         l, e := net.Listen("tcp", ":9876")
6.         if e != nil {
7.                 panic(e)
8.         }
10.         go http.Serve(l, nil)
12.         var wg sync.WaitGroup
13.         wg.Add(1)
14.         wg.Wait()
15. }

复制代码

• 最后初始化 RPC Client，并发起调用：
  

[code]func main() {        client, err := rpc.DialHTTP("tcp", "127.0.0.1:9876")        if err != nil {                panic(err)        }        args := common.Args{A: 7, B: 8}        var reply int  // 同步调用        err = client.Call("Arith.Multiply", &args, &reply)        if err != nil {                panic(err)        }        fmt.Printf("Call Arith: %d * %d = %d\n", args.A, args.B, reply)  // 异步调用        quotient := new(common.Quotient)        divCall := client.Go("Arith.Divide", args, quotient, nil)        replyCall :=