杭州开课啦教育科技有限公司高级开发工程师 曾凡维
技术选型背景
2020年是我司发展壮大的一年，整个公司团队由原来的几百人扩充至现在的几千人，在集中使用的时候基本上会有几千人同时在运营后台进行操作，公司原有的内部后台运营系统是用PHP搭建起来的，性能跟业务上已逐渐不能满足公司的需求规划，加上目前我司开发部已经做了微服务拆分，主体对外服务是java语言的Dubbo集群，后台系统需要无缝对接java的Dubbo服务，所以PHP已经逐渐不能满足我司的需求。
当时自己也调研过PHP的Dubbo项目，由于项目已基本无人更新维护所以pass掉，后面自己对简洁高性能的go语言感兴趣，然后就关注到了Dubbo-go项目，经过一段时间的调研之后发现Dubbo Go 符合我们的业务需要，并且社区非常的活跃，后面便决定选用 Dubbo-go 作为后台的 pc 业务框架。
可能也有同学会问为什么不使用跨言支持程度更好的 gRPC 呢，因为很多公司最开始的 RPC 服务集群都是基于Dubbo 生态构建的，如果换框架成本太大，所以基本不会考虑，gRPC 虽然跨语言支持程度更好但是很多东西都需要自己造轮子，比如服务注册，服务发现，日志监控等。
当时在决定选用 Dubbo-go 的时候开发内部也有一些反对的声音的，为什么不直接转 java，转 java 的话就没有跨语言通信的问题了，转 java 的问题在于入门成本高，而且对于整个公司的技术栈来说，保持语言的多样性，才能更加从容的应对未来的业务变化，Go 本身是一个不弱于 Java 的高性能语言，非常适合微服务架构。
面临的挑战
确定了框架选型后，我接到的首要任务便是要搭建出一套可快速创建业务项目的脚手架，开发出基于 HTTP 协议的RPC 代理服务，部署需要接入公司的容器化部署平台，一切都是从零开始，在网上基本上找不到可以借鉴的资料。 首先是要进行 Dubbo-go 项目的架构的规划，确定项目目录结构，经过参考 Dubbo-go Demo以及其它的 Go 项目最终确定了项目的目录结构，以下目录结构可作为参考。
![]()
为了与 Java服务注册中心保持一致，Dubbo-go 在项目选型上选用如下组件：
- 使用 zookeeper 作为注册中心
- nacos 作为配置中心
- 数据库 orm 采用 gorm
- 消息队列使用 RocketMQ
为了增加开发的效率我们在 provider 服务初始化前可以对配置进行精简只保留最基础的配置就可以类似下面这种，provider 服务的编码参考 Dubbo-go demo 就可以了
![]()
下面是服务启动的main方法代码
![]()
Dubbo-go RPC 服务网关设计
一般使用 Dubbo，provider 端需要暴露出接口和方法，consumer 端要十分明确服务使用的接口定义和方法定义，还有入参返参类型等等信息，还需要基于provider端提供的 API，两端才能正常通信调用。
然而网关的使用场景是并不关心要调用的接口的详细定义，网关只关注要调用的方法、传递的参数、能接收返回结果就可以了，实现网关代理的基础是 Dubbo/Dubbo-go 的泛化调用特性。
下面是 Dubbo-go 官方给的 demo，泛化服务加载后需要等待 3 秒才能完成调用，然而在实际使用的时候肯定是不能实时加载服务去等待 3 秒，所以在网关应用启动时就需要加载缓存好需要泛化调的服务。
![]()
经过对 Dubbo-go 泛化调用 demo 的研究，发现用该特性设计 dubbo-go 网关是可行的，难点在于我们需要把每一个需要网关代理 RPC 服务方法的参数以及服务的路径等配置获取到并缓存起来，这样才能在调用前初始化好泛化调用服务，一个服务的配置如下。
![]()
由于是用 go 语言做的网关代理，所以不能通过 Java 的 jar 包来获取到 Java RPC 服务配置，如果通过人工维护的话工作量太大，而且易出错，显然是不可接受的。经过一段时间的了解，Java 服务可以通过注解来实现配置的获取，Java 端在方法上加上注解后启动服务的时候会将配置信息通过消息发送到 MQ，网关消费这些消息来实现获取Java RPC 服务的配置
Dubbo Go 的 RPC 服务由于 go 语言不支持注解，所以我经过思考自己写了一个扫描代码的小工具，在每个 RPC 服务方法前加上对应的注释，通过对注释的扫描来获取 RPC 服务的配置，获取到配置后在项目目录内生成 RPC 服务配置，启动应用的时候读取配置发送到 MQ。
网关代理实现之后还可以在网关的基础实现更多的功能，比如 token验证、白名单、限流、熔断、日志监控功能，网关代理请求实现效果如下：
![]()
容器化部署
公司内部的容器化部署环境为阿里云的 k8s，部署至 k8s 平台只需要提供镜像文件，由于 Dubbo-go 编译后是一个二进制的文件，不需任何额外的第三方库，能在 Docker 环境下稳定运行。有 docker 镜像文件如下图所示，可以用 centos 等任一 linux 发行版作为 base 镜像。
LABEL maintainer="<xxx@xx.com>"
LABEL version="1.0"
LABEL description="KKL-GO-NKO-BASE"`
ARG envType=stable
#设置环境变量
ENV envType ${envType}
#编译打包好的压缩包
ADD ./target/nko-base-${envType}.tar.gz /app/
WORKDIR /app
EXPOSE 20000
镜像写好后提供给发布平台，发布平台机器启动镜像并解压打包文件，执行Dubbo-Go程序 。
Container entrypoint set to [bash, -c, tar -zxf nko-base-stable.tar.gz && SERVER_ENV=kubernetes && sh ./nko-base/bin/load.sh start -group=stable]
由于开发测试到生产一般是有多个部署环境的，所以我们需要改动的 dubbo-go samples demo【见相关链接 1】 里的编译脚本，让其支持多环境打包。
另外，Dubbo-go 默认注册的 IP 是 k8s pod 的虚拟 IP，不同 k8s 集群之间网络是不能互通的，所以如果需要跨集群调用就需要修改默认注册 IP，将默认注册的 pod IP + 端口 修改为 kubernetes 实体机的 IP 加对应端口，kubernetes 会在 pod 内写入实体机的 IP 加对应端口环境变量，应用程序可以通过读取环境变量获取实体机的 IP加端口，如果需要实现此功能需要修改 Dubbo-go 的注册逻辑。例如以 zookeeper 注册中心为例，我们可以通过扩展 registery/zookeeper/registry.go的registerTempZookeeperNode 方法来实现修改注册 IP 跟端口，代码如下图，Dubbo-go 官方将在后面的版本以配置的形式支持自定义注册 IP 跟端口的功能。
func (r *zkRegistry) registerTempZookeeperNode(root string, node string) error {
...
regIp = os.Getenv(constant2.RegistryEnvIP) //实体机的ip
regPort = os.Getenv(constant2.RegistryEnvPort) //实体机的端口
urlNode, _ := common.NewURL(node)
role, _ := strconv.Atoi(urlNode.GetParam(constant.ROLE_KEY, ""))
if role == common.PROVIDER && regIp != "" && regPort != "" {
urlNode.Ip = regIp
urlNode.Port = regPort
node = url.QueryEscape(urlNode.String())
}
zkPath, err = r.client.RegisterTemp(root, node)
...
}
最后的话
如果使用 dubbo-go 过程中遇到一些问题，可以提交 issue 或者进社区钉钉群进行沟通交流。
个人建议，如果你做好了入坑 Dubbo-go 的准备，最好自己解决这些问题并给官方反馈 PR，遇到问题解决问题你才能成长并有所收获，不是吗？
相关链接
作者介绍
曾凡维（github @jack15083), 一个有9年服务端业务开发经验的一线程序员，曾在腾讯阅文等多家公司担任后端开发工程师，目前就职杭州开课啦教育科技有限公司，从事 go 语言服务基础架构和中间件及部分业务开发工作。
欢迎对 apache/dubbo-go 项目有兴趣的同学通过钉钉扫码加入交流群【或搜索钉钉群号 31363295】：
![]()
