我们一起来探寻rpcx框架，本系列会详细详解rpcx的源码，会涉及到他的各个模块，看看这款优秀的rpc框架是如何实现的。

简介

github：https://github.com/smallnest/rpcx，之所以会选择rpcx，原因有二

• 使用简单，功能健全。rpcx框架的参照物就是java的dubbo，这对我这样十几年的java使用者来说，非常具有吸引力，况且dubbo框架是非常优秀的（成为apache的顶级项目，足以说明这一点）。这是作者对rpcx的介绍
  A zero cost, faster multi-language bidirectional microservices framework in Go, like alibaba Dubbo, but with more features, Scale easily. Try it. Test it. If you feel it's better, use it! 𝐉𝐚𝐯𝐚有𝐝𝐮𝐛𝐛𝐨, 𝐆𝐨𝐥𝐚𝐧𝐠有𝐫𝐩𝐜𝐱!

• 性能卓越，这个从github上可以看到，而我，是一名性能偏执狂。

相信很多人对rpc的概念并不陌生，而且现在流行的rpc框架也很多，比如：Dubbo、Montan、Tars、gRPC、Thrift 等，语言不通，选择不同。需求不同，选择不同。这个无可厚非。在讨论和比较他们的时候，也绕不过这些方面：

• 服务治理

• 服务发现

• 负载均衡

• 跨语言

• 序列化

如果有对这些概念不不太明白的，可以自行找相关的资料，这里就不再重复阐述了。

例子

我们来先看一个使用例子，从官网上直接copy下来的：用zookeeper作为注册中心。例子源码：https://github.com/rpcxio/rpcx-examples

这个例子的代码地址是：https://github.com/rpcxio/rpcx-examples/tree/master/registry/zookeeper，我把代码贴出来，并做一些简单的注解（大部分的注解来自于官网）

准备工作

下载库，如果是module管理，则跳过：

go get -u -v github.com/smallnest/rpcx/...

服务端

rpc的服务提供者，会将服务提供者的地址注册到zookeeper上，以便选址

server.go

package mainimport ("flag""log""time"metrics "github.com/rcrowley/go-metrics"example "github.com/rpcxio/rpcx-examples""github.com/smallnest/rpcx/server""github.com/smallnest/rpcx/serverplugin"
)var (addr     = flag.String("addr", "localhost:8972", "server address")zkAddr   = flag.String("zkAddr", "localhost:2181", "zookeeper address")basePath = flag.String("base", "/rpcx_test", "prefix path")
)func main() {flag.Parse()s := server.NewServer()addRegistryPlugin(s)s.RegisterName("Arith", new(example.Arith), "")s.Serve("tcp", *addr)
}func addRegistryPlugin(s *server.Server) {r := &serverplugin.ZooKeeperRegisterPlugin{ServiceAddress:   "tcp@" + *addr,ZooKeeperServers: []string{*zkAddr},BasePath:         *basePath,Metrics:          metrics.NewRegistry(),UpdateInterval:   time.Minute,}err := r.Start()if err != nil {log.Fatal(err)}s.Plugins.Add(r)
}

• ServiceAddress: 本机的监听地址， 这个对外暴露的监听地址， 格式为tcp@ipaddress:port
• ZooKeeperServers: Zookeeper集群的地址
• BasePath: 服务前缀。 如果有多个项目同时使用zookeeper，避免命名冲突，可以设置这个参数，为当前的服务设置命名空间
• Metrics: 用来更新服务的TPS
• UpdateInterval: 服务的刷新间隔， 如果在一定间隔内(当前设为2 * UpdateInterval)没有刷新,服务就会从Zookeeper中删除（这个对zookeeper无效，etcd有效）

客户端

rpc的客户端，也就是使用服务的调用方，会通过既定协议调用服务端的方法

client/client.go

package mainimport ("context""flag""log""time"example "github.com/rpcxio/rpcx-examples""github.com/smallnest/rpcx/client"
)var (zkAddr   = flag.String("zkAddr", "localhost:2181", "zookeeper address")basePath = flag.String("base", "/rpcx_test", "prefix path")
)func main() {flag.Parse()d := client.NewZookeeperDiscovery(*basePath, "Arith", []string{*zkAddr}, nil)xclient := client.NewXClient("Arith", client.Failtry, client.RandomSelect, d, client.DefaultOption)defer xclient.Close()args := &example.Args{A: 10,B: 20,}for {reply := &example.Reply{}err := xclient.Call(context.Background(), "Mul", args, reply)if err != nil {log.Fatalf("failed to call: %v", err)}log.Printf("%d * %d = %d", args.A, args.B, reply.C)time.Sleep(1e9)}}

• 需要注意的是：zkAddr，basePath要和服务端保持一致
• 这个例子调用的是服务端的Mul方法
• args 是传入参数
• reply是返回的结果

结语

我打算花足够多的时间来和大家读一读rpcx的源码，一起来看看rpcx是怎么实现这些模块的，有兴趣的朋友，可以关注我。