Istio 环境部署 Dubbo-go 应用
在本章节中，我们将使用应用模板快速创建一组 Dubbo-go Server和 Client 端应用，部署在 Istio 集群中；观察、调试和验证服务发现和调用成功。
1. 准备工作
- dubbo-go cli 工具和依赖工具已安装、grpc_cli (如需本地调试)。
- docker、helm、kubectl 环境已安装。（arm 机器需支持 docker buildx）
- 任务【istio 环境部署】 已完成
2. 开发 server 端 Dubbo-go 应用
2.1 使用 dubbogo-cli 创建项目模板
$ mkdir mesh-app-server
$ cd mesh-app-server
$ dubbogo-cli newApp .
$ tree .
.
├── Makefile
├── api
│ └── api.proto
├── build
│ └── Dockerfile
├── chart
│ ├── app
│ │ ├── Chart.yaml
│ │ ├── templates
│ │ │ ├── _helpers.tpl
│ │ │ ├── deployment.yaml
│ │ │ ├── service.yaml
│ │ │ └── serviceaccount.yaml
│ │ └── values.yaml
│ └── nacos_env
│ ├── Chart.yaml
│ ├── templates
│ │ ├── _helpers.tpl
│ │ ├── deployment.yaml
│ │ └── service.yaml
│ └── values.yaml
├── cmd
│ └── app.go
├── conf
│ └── dubbogo.yaml
├── go.mod
├── go.sum
└── pkg
└── service
└── service.go
生成项目包括几个目录：
api：放置接口文件：proto文件和生成的pb.go文件
build：放置构建相关文件
chart：放置发布用 chart 仓库、基础环境chart 仓库：nacos、mesh（开发中）
cmd：程序入口
conf：框架配置
pkg/service：RPC 服务实现
Makefile：
- 镜像、Helm 安装名称：
IMAGE = $(your_repo)/$(namespace)/$(image_name) TAG = 1.0.0 HELM_INSTALL_NAME = dubbo-go-app
- 提供脚本，例如：
- make build # 打包镜像并推送
- make buildx-publish # arm架构本地打包amd64镜像并推送，依赖buildx
- make deploy # 通过 helm 发布应用
- make remove # 删除已经发布的 helm 应用
- make proto-gen # api下生成 pb.go 文件
- …
2.2 开发和部署 Dubbo-go 应用：
开发应用
编译接口
开发人员需要修改 proto 文件，本任务中直接使用默认接口即可。
$ make proto-gen protoc --go_out=./api --go-triple_out=./api ./api/api.proto拉取依赖
$ go get dubbo.apache.org/dubbo-go/v3@3.0 $ make tidy go mod tidy编写业务逻辑
修改 pkg/service/service.go 实现函数, 返回字符串中显示版本为 v1.0.0
func (s *GreeterServerImpl) SayHello(ctx context.Context, in *api.HelloRequest) (*api.User, error) { return &api.User{Name: "Hello " + in.Name, Id: "v1.0.0"}, nil }修改配置如下字段，从而使用xds协议作为注册中心
conf/dubbogo.yaml
dubbo: registries: xds: protocol: xds address: istiod.istio-system.svc.cluster.local:15010 protocols: triple: name: tri port: 20000 provider: services: GreeterServerImpl: interface: "" # read from stub至此，应用开发完成。
配置构建和部署参数
指定需要构建的镜像：
修改 Makefile 如下字段，指定好需要构建的镜像地址和版本。
指定好需要通过 helm 安装的名称。
IMAGE = xxx/dubbo-go-server TAG = 1.0.0 HELM_INSTALL_NAME = dubbo-go-server-v1指定需要部署的应用和镜像：
修改 chart/app/Chart.yaml 如下字段，指定当前应用名为
dubbo-go-server，部署时会创建一个名为 dubbo-go-server 的 service ，关联当前应用的所有版本。apiVersion: v1 name: dubbo-go-server description: dubbo-go-server修改 chart/app/values.yaml 如下字段，指定需要部署的镜像以及当前开发的应用版本 dubbogoAppVersion 为 v1。
部署的镜像需要和上述构建的镜像一致。当前应用版本用于 mesh 流量规则控制。
image: repository: xxx/dubbo-go-server pullPolicy: Always tag: "1.0.0" # Dubbo-go-mesh version control labels version: labels: dubbogoAppVersion: v1至此，构建参数和发布参数都已指定好，可以进行构建和部署了。
使用模板构建和部署 Dubbo-go 应用
构建、推送镜像
$ make build(本地为 amd64机器)或者
$ make buildx-publish(本地为 arm64机器，依赖 docker buildx 命令)发布 Dubbo-go 应用至集群
$ make deploy helm install dubbo-go-server-v1 ./chart/app NAME: dubbo-go-server-v1 LAST DEPLOYED: Thu Apr 7 11:19:42 2022 NAMESPACE: default STATUS: deployed REVISION: 1 TEST SUITE: None $ helm list NAME NAMESPACE REVISION UPDATED STATUS CHART APP VERSION dubbo-go-server-v1 default 1 2022-04-07 11:19:42.350553 +0800 CST deployed dubbo-go-server-0.0.1 1.16.0可看到通过 helm 部署成功
2.3 验证应用
查看资源部署情况
查看部署好的 deployment ，版本为 v1。
$ kubectl get deployment
NAME READY UP-TO-DATE AVAILABLE AGE
dubbo-go-server-v1 1/1 1 1 26s
查看部署好的 service。
$ kubectl get svc
NAME TYPE CLUSTER-IP EXTERNAL-IP PORT(S) AGE
dubbo-go-server ClusterIP 192.168.216.253 <none> 20000/TCP 70s
（*可选）本地调试部署好的 Dubbo-go 应用
使用 kubectl port-forward Dubbo-go 应用到本地
$ kubectl port-forward svc/dubbo-go-server 20000
Forwarding from 127.0.0.1:20000 -> 20000
Forwarding from [::1]:20000 -> 20000
使用 grpc_cli 调试集群内的应用，参考任务【使用 grpc_cli 调试 Dubbo-go 应用】
$ grpc_cli ls localhost:20000 -l
filename: api/api.proto
package: api;
service Greeter {
rpc SayHello(api.HelloRequest) returns (api.User) {}
rpc SayHelloStream(stream api.HelloRequest) returns (stream api.User) {}
}
使用 grpc_cli 发起调用，测试接口
$ grpc_cli call localhost:20000 SayHello "name: 'laurence'"
connecting to localhost:20000
name: "Hello laurence"
id: "v1.0.0"
Received trailing metadata from server:
accept-encoding : identity,gzip
grpc-accept-encoding : identity,deflate,gzip
Rpc succeeded with OK status
至此，我们成功开发了一个应用，把它部署在了 istio 集群内。
3. 开发 Client 端 Dubbo-go 应用
3.1 使用 dubbogo-cli 创建另一个项目模板
$ dubbogo-cli newApp .
3.2 开发和部署客户端 Dubbo-go 应用：
编写业务逻辑
- 修改 cmd/app.go 的 main 方法，针对下游接口每秒钟发起一次调用
func main() {
client := &api.GreeterClientImpl{}
config.SetConsumerService(client)
if err := config.Load(); err != nil {
panic(err)
}
request := &api.HelloRequest{
Name: "laurence",
}
for{
if rsp, err := client.SayHello(context.Background(), request); err != nil{
logger.Errorf("call server error = %s", err)
}else{
logger.Infof("call server response = %+v", rsp)
}
time.Sleep(time.Second)
}
}
修改如下配置文件，使用xds协议作为注册中心，加载名为 GreeterClientImpl 的客户端服务。
conf/dubbogo.yaml
dubbo: registries: xds: protocol: xds address: istiod.istio-system.svc.cluster.local:15010 consumer: references: GreeterClientImpl: protocol: tri interface: "" # read from stub至此，应用开发完成。
配置构建和部署参数
指定需要构建的镜像：
修改 Makefile 如下字段，指定好需要构建的镜像地址和版本。
指定好需要通过 helm 安装的名称。
IMAGE = xxx/dubbo-go-client TAG = 1.0.0 HELM_INSTALL_NAME = dubbo-go-client指定需要部署的应用和镜像：
修改 chart/app/Chart.yaml 如下字段，指定当前应用名为
dubbo-go-client，部署时会创建一个名为 dubbo-go-client 的 service ，关联当前应用的所有版本。对于一个只有客户端的应用，可以不创建sevice，可以由开发者在模板中修改，本教程中我们默认创建。apiVersion: v1 name: dubbo-go-client description: dubbo-go-client修改 chart/app/values.yaml 如下字段，指定需要部署的镜像以及当前开发的应用版本 dubbogoAppVersion 为 v1。
部署的镜像需要和上述构建的镜像一致。当前应用版本用于 mesh 流量规则控制。
image: repository: xxx/dubbo-go-client pullPolicy: Always tag: "1.0.0" # Dubbo-go-mesh version control labels version: labels: dubbogoAppVersion: v1至此，构建参数和发布参数都已指定好，可以进行构建和部署了。
使用模板构建和部署 Dubbo-go 应用
构建、推送镜像
$ make build(本地为 amd64机器)或者
$ make buildx-publish(本地为 arm64机器，依赖 docker buildx 命令)发布 Dubbo-go Client 应用至集群
$ make deploy helm install dubbo-go-client ./chart/app NAME: dubbo-go-client LAST DEPLOYED: Thu Apr 7 11:49:55 2022 NAMESPACE: default STATUS: deployed REVISION: 1 TEST SUITE: None $ helm list NAME NAMESPACE REVISION UPDATED STATUS CHART APP VERSION dubbo-go-client default 1 2022-04-07 11:49:55.517898 +0800 CST deployed dubbo-go-client-0.0.1 1.16.0 dubbo-go-server-v1 default 1 2022-04-07 11:23:18.397658 +0800 CST deployed dubbo-go-server-0.0.1 1.16.0可看到通过 helm 部署成功, 目前已经在集群中存在 Client 和 Server 两个应用。
3.3 验证应用
查看资源部署情况
查看部署好的 client 和 server 两个 deployment。
$ kubectl get deployment
NAME READY UP-TO-DATE AVAILABLE AGE
dubbo-go-client-v1 1/1 1 1 22m
dubbo-go-server-v1 1/1 1 1 49m
查看客户端调用日志
$ kubectl get pods | grep client | awk '{print $1}' | xargs kubectl logs
...
2022-04-07T04:13:55.777Z INFO cmd/app.go:29 call server response = name:"Hello laurence" id:"v1.0.0"
2022-04-07T04:13:56.778Z INFO cmd/app.go:29 call server response = name:"Hello laurence" id:"v1.0.0"
2022-04-07T04:13:57.779Z INFO cmd/app.go:29 call server response = name:"Hello laurence" id:"v1.0.0"
2022-04-07T04:13:58.781Z INFO cmd/app.go:29 call server response = name:"Hello laurence" id:"v1.0.0"
2022-04-07T04:13:59.782Z INFO cmd/app.go:29 call server response = name:"Hello laurence" id:"v1.0.0"
2022-04-07T04:14:00.784Z INFO cmd/app.go:29 call server response = name:"Hello laurence" id:"v1.0.0"
2022-04-07T04:14:01.785Z INFO cmd/app.go:29 call server response = name:"Hello laurence" id:"v1.0.0"
验证调用成功
4. 小结
dubbogo-cli 提供的应用模板可以方便地支持开发者进行镜像的构建、推送、部署。
在 Istio 环境中，server 应用将自身服务信息注册在 Isito 上，由客户端监听 xds 资源，查询 istio debug 端口进行接口级别的服务发现。开发人员无需关心 service名、主机名、集群名等概念，只需要引入接口，发起调用即可。
