rpc框架之rpcx-简介(1)

我们一起来探寻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 main

import (
	"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 main

import (
	"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是怎么实现这些模块的，有兴趣的朋友，可以关注我。