rpc框架之rpcx-简介(1)

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

简介

github：github.com/smallnest/r…，之所以会选择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作为注册中心。例子源码：github.com/rpcxio/rpcx…

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

准备工作

下载库，如果是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是怎么实现这些模块的，有兴趣的朋友，可以关注我。