概览
下面给大家介绍一开源高性能 RPC 框架 KiteX,该框架由bytedance开源,实践过数千个微服务,QPS过亿。经过持续迭代、持续更新,在吞吐和延迟方面表现了显著的效果。作为 Golang 微服务 RPC 框架,具有高性能、强可扩展的特点。如果对微服务性能有要求,又希望定制扩展融入自己的治理体系,Kitex 会是一个不错的选择。
架构设计
框架特点
- 高性能
使用自研的高性能网络库 Netpoll,性能相较 go net 具有显著优势。
- 扩展性
提供了较多的扩展接口以及默认扩展实现,使用者也可以根据需要自行定制扩展,具体见下面的框架扩展。
- 多消息协议
RPC 消息协议默认支持 Thrift、Kitex Protobuf、gRPC。Thrift 支持 Buffered 和 Framed 二进制协议;Kitex Protobuf 是 Kitex 自定义的 Protobuf 消息协议,协议格式类似 Thrift;gRPC 是对 gRPC 消息协议的支持,可以与 gRPC 互通。除此之外,使用者也可以扩展自己的消息协议。
- 多传输协议
传输协议封装消息协议进行 RPC 互通,传输协议可以额外透传元信息,用于服务治理,Kitex 支持的传输协议有 TTHeader、HTTP2。TTHeader 可以和 Thrift、Kitex Protobuf 结合使用;HTTP2 目前主要是结合 gRPC 协议使用,后续也会支持 Thrift。
- 多种消息类型
支持 PingPong、Oneway、双向 Streaming。其中 Oneway 目前只对 Thrift 协议支持,双向 Streaming 只对 gRPC 支持,后续会考虑支持 Thrift 的双向 Streaming。
- 服务治理
支持服务注册/发现、负载均衡、熔断、限流、重试、监控、链路跟踪、日志、诊断等服务治理模块,大部分均已提供默认扩展,使用者可选择集成。
- 代码生成
Kitex 内置代码生成工具,可支持生成 Thrift、Protobuf 以及脚手架代码。
实战
基于 Etcd 实现服务注册与发现
- 首先基于 Mac或Linux 环境,搭建 Go 开发环境,安装需要的开发工具。
- 安装需要的软件工具:Etcd、Nacos。
新建 RPC 微服务项目
服务提供者
新建一工程项目,引入依赖:
这里除了引入基于 Http 协议的框架 Hertz,还需要引入 Kitex 依赖,同时,需要引入注册中心服务:etcd、nacos 等。
引入完之后,我们需要新建基于 Hertz 的项目,因为此项目是基于 Hertz(此框架后续会进行相关的开发延伸),实际是基于 Http 协议,新建完成后,我们来看 main 函数:
etcd "github.com/kitex-contrib/registry-etcd"etcd.NewEtcdRegistryserver.WithRegistry(r)
此处的完整代码如下:
服务消费者
同样,消费者采用的 Hertz 框架进行,此处不再赘述:
但在请求生产者之前,都是需要进行服务的发现:这里基于 RPC:
constants.NoteServiceName
这样就实现了服务的发现,同时,服务发现后需要进行相关的接口调用,此处:
这些需要在 RPC 中实现,此处不再赘述,后续会加入基于 Kitex 的完整开发示例。
此时,一个完整的服务注册与发现就实现完毕了。此处基于 Etcd,接下来,基于 Nacos 就简单多了。
基于 Nacos 实现服务注册与发现
前面我们实现了基于 Etcd 的服务注册与发现,接下来,我们基于 Nacos 来实现,简单点,就是把所有基于 Etcd 的地方改成基于 Nacos:
registry.NewDefaultNacosRegistry()resolver.NewDefaultNacosResolver()
最后,可以启动相关服务:
注册的服务:
测试
第一次访问时:
持续访问中:
在这次 Demo 中,我们引用了连接多路复用功能以及基于 Thrift 的 Frugal 功能,或基于 Protobuf 的增强插件 Fastpb,使得编解码的过程性能更优,从而使得速度更快、吞吐更大。