当前位置: 首页 > 工具软件 > rpcx > 使用案例 >

rpc框架之rpcx-简介(1)

羊煜
2023-12-01

我们一起来探寻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是怎么实现这些模块的,有兴趣的朋友,可以关注我。

 类似资料: