🔥 热搜 🔥
上海习近平新疆鄂州父女瓜乌鲁木齐疫情H工口小学生赛高习明泽芊川一笑图包印尼排华
分类
社会娱乐国际人权科技经济其它
🔥 热搜 🔥
上海习近平新疆鄂州父女瓜乌鲁木齐疫情H工口小学生赛高习明泽芊川一笑图包印尼排华
分类
社会娱乐国际人权科技经济其它
查看原文
其他

Dubbo on x-protocol——SOFAMesh中的x-protocol示例演示

彭泽文 几米宋 2022-09-06

本文作者：彭泽文，阿里巴巴UC事业部高级开发工程师

本文为 SOFAMesh 系列文章之一，下篇文章将带你了解 x-protocol。

SOFAMesh（https://github.com/alipay/sofa-mesh）是基于 Istio 的大规模服务网格解决方案。


X-protocol 的定位是云原生、高性能、低侵入性的通用 Service Mesh 落地方案，依托 Kubernetes 基座，利用其原生的服务注册和服务发现机制，支持各种私有 RPC 协议低成本、易扩展的接入，快速享受 Service Mesh 所带来的红利。

本文将以 Dubbo 为例，演示 Dubbo on x-protocol 场景下 Service Mesh 路由功能，涵盖 Version route 、Weighted route 功能。

关于 x-protocol 的介绍请参考开源 | SOFAMesh 的通用协议扩展。

前期准备

  1. 安装 Minikube，推荐使用 Minikube v0.28 以上来体验，请参考 https://github.com/kubernetes/minikube

  2. 安装 kubectl 命令行工具，请参考 https://kubernetes.io/docs/tasks/tools/install-kubectl/#install-kubectl

  3. 安装 VM Driver，推荐安装 VirtualBox、Mac 用户也可以选择 hyperkit

  4. 了解 Istio Traffic Management 相关概念，相关链接：https://istio.io/zh/docs/tasks/traffic-management/

部署

先看部署效果图：

本示例中dubbo-consumer的部署方式采用直连模式，即不走注册中心，完全依托kubernetes平台提供的服务注册及服务发现能力。

1. 安装 Kubernetes

安装 kubectl 命令行工具 推荐使用 Kubernetes 1.10 版本，并使用合适的 VM Driver，推荐使用默认的 VirtualBox。

  1. minikube start --memory=8192 --cpus=4 --kubernetes-version=v1.10.0 \

  2.    --extra-config=controller-manager.cluster-signing-cert-file="/var/lib/localkube/certs/ca.crt" \

  3.    --extra-config=controller-manager.cluster-signing-key-file="/var/lib/localkube/certs/ca.key"

Mac OSX 用户使用的 hyperkit 需要特别指定：

  1. minikube start --memory=8192 --cpus=4 --kubernetes-version=v1.10.0 \

  2.    --extra-config=controller-manager.cluster-signing-cert-file="/var/lib/localkube/certs/ca.crt" \

  3.    --extra-config=controller-manager.cluster-signing-key-file="/var/lib/localkube/certs/ca.key" \

  4.    --vm-dirver=hyperkit

等待 Kubernetes 启动完毕，通过 kubectl 命令检查

  1. kubectl get pods --namespace=kube-system

2. 部署 SOFAMesh

本示例演示从源代码的 master 分支直接安装最新的 SOFAMesh，安装过程使用 Helm 完成。

从 GitHub 拉取最新代码：

  1. git clone https://github.com/alipay/sofa-mesh.git

  2. cd sofa-mesh

创建 SOFAMesh 需要的 CRD：

  1. kubectl apply -f install/kubernetes/helm/istio/templates/crds.yaml

  2. kubectl apply -f install/kubernetes/helm/istio/charts/certmanager/templates/crds.yaml

使用 Helm 安装 SOFAMesh：

  1. kubectl apply -f install/kubernetes/helm/helm-service-account.yaml

  2. helm init --service-account tiller

  3. helm install install/kubernetes/helm/istio --name istio --namespace istio-system

安装 istioctl 命令行工具：

  1. # 使用 make 工具安装 istioctl

  2. make istioctl-install

3. 创建示例的命名空间

以下示例都将运行在 e2e-dubbo 命名空间下，如无 e2e-dubbo 命名空间，需先创建该命名空间：

  1. kubectl apply -f samples/e2e-dubbo/platform/kube/e2e-dubbo-ns.yaml

4. 注入 SOFAMosn

部署 dubbo-consumer 和 dubbo-provider，部署前需要先使用 istioctl 进行 sidecar 注入，以下示例采用手动注入方式，也可以通过 istio namespace inject 功能来自动注入。

  1. # mosn sidecar inject and deploy

  2. kubectl apply -f <(istioctl kube-inject -f samples/e2e-dubbo/platform/kube/dubbo-consumer.yaml)

  3. kubectl apply -f <(istioctl kube-inject -f samples/e2e-dubbo/platform/kube/dubbo-provider-v1.yaml)

  4. kubectl apply -f <(istioctl kube-inject -f samples/e2e-dubbo/platform/kube/dubbo-provider-v2.yaml)

5. 部署示例应用

部署dubbo consumer service 及 dubbo provider service。

  1. # http service for dubbo consumer

  2. kubectl apply -f samples/e2e-dubbo/platform/kube/dubbo-consumer-service.yaml

  4. # dubbo provider service

  5. kubectl apply -f samples/e2e-dubbo/platform/kube/dubbo-provider-service.yaml

检查部署状态：

  1. #kubectl get pods -n e2e-dubbo

  2. NAME                                     READY     STATUS    RESTARTS   AGE

  3. e2e-dubbo-consumer-589d8c465d-cp7cx      2/2       Running   0          13s

  4. e2e-dubbo-provider-v1-649d7cff94-52gfd   2/2       Running   0          13s

  5. e2e-dubbo-provider-v2-5f7d5ff648-m6c45   2/2       Running   0          13s

  7. #kubectl get svc -n e2e-dubbo    

  8. NAME                 TYPE        CLUSTER-IP      EXTERNAL-IP   PORT(S)     AGE

  9. e2e-dubbo-consumer   ClusterIP   192.168.1.7     <none>        8080/TCP    10s

  10. e2e-dubbo-provider   ClusterIP   192.168.1.62    <none>        12345/TCP   10s

e2e-dubbo-consumer 是一个 Dubbo 客户端应用，它暴露了一个 8080 端口的 HTTP 服务，方便我们进行验证，e2e-dubbo-provider 是一个 Dubbo 应用。 当 e2e-dubbo-consumer 通过 12345 端口调用 e2e-dubbo-provider 时，流量会被 IPtable 规则拦截，导流给 SOFAMosn。

验证路由能力

本示例将验证 Version route 和 Weighted route 能力。

1. 验证 Version Route 能力

本例将演示控制 dubbo-consumer的所有请求指向 dubo-provider-v1 配置DestinationRule:

  1. istioctl create -f samples/e2e-dubbo/platform/kube/dubbo-consumer.destinationrule.yaml

dubbo-consumer.destinationrule.yaml 内容如下：

  1. apiVersion: networking.istio.io/v1alpha3

  2. kind: DestinationRule

  3. metadata:

  4.  name: e2e-dubbo-provider

  5.  namespace: e2e-dubbo

  6. spec:

  7.  host: e2e-dubbo-provider

  8.  subsets:

  9.  - name: v1

  10.    labels:

  11.      ver: v1

  12.  - name: v2

  13.    labels:

  14.      ver: v2

配置VirtualService：

  1. istioctl create -f samples/e2e-dubbo/platform/kube/dubbo-consumer.version.vs.yaml

dubbo-consumer.version.vs.yaml 内容如下：

  1. apiVersion: networking.istio.io/v1alpha3

  2. kind: VirtualService

  3. metadata:

  4.  name: e2e-dubbo-provider

  5.  namespace: e2e-dubbo

  6. spec:

  7.  hosts:

  8.    - e2e-dubbo-provider

  9.  http:

  10.  - route:

  11.    - destination:

  12.        host: e2e-dubbo-provider

  13.        subset: v1

路由策略已经生效，可以 http 请求 dubbo consumer 来触发 rpc 请求观察效果，由于使用 Minikube 的关系，需要启动一个 Pod 用来测试

  1. # 启动一个 busybox Pod 并登陆

  2. kubectl run -i -t busybox --image=yauritux/busybox-curl --restart=Never

  3. # 使用 e2e-dubbo-consumer 的域名访问服务

  4. curl e2e-dubbo-consumer.e2e-dubbo.svc.cluster.local:8080/sayHello?name=dubbo-mosn

清理路由策略：

  1. istioctl delete -f samples/e2e-dubbo/platform/kube/dubbo-consumer.destinationrule.yaml

  2. istioctl delete -f samples/e2e-dubbo/platform/kube/dubbo-consumer.version.vs.yaml

退出 Minikube shell

2. 验证 Weight Route 能力

本例将演示控制 dubbo-consumer 的请求指向 dubo-provider-v1，dubo-provider-v2。并控制流量分配比例为 v1：20%，v2：80%。

配置DestinationRule:

  1. # 如果在上一示例中已经创建好了，请跳过这一步

  2. istioctl create -f samples/e2e-dubbo/platform/kube/dubbo-consumer.destinationrule.yaml

dubbo-consumer.destinationrule.yaml 内容如下：

  1. apiVersion: networking.istio.io/v1alpha3

  2. kind: DestinationRule

  3. metadata:

  4.  name: e2e-dubbo-provider

  5.  namespace: e2e-dubbo

  6. spec:

  7.  host: e2e-dubbo-provider

  8.  subsets:

  9.  - name: v1

  10.    labels:

  11.      ver: v1

  12.  - name: v2

  13.    labels:

  14.      ver: v2

配置 VirtualService：

  1. istioctl create -f samples/e2e-dubbo/platform/kube/dubbo-consumer.weight.vs.yaml

dubbo-consumer.weight.vs.yaml 内容如下：

  1. apiVersion: networking.istio.io/v1alpha3

  2. kind: VirtualService

  3. metadata:

  4.  name: e2e-dubbo-provider

  5.  namespace: e2e-dubbo

  6. spec:

  7.  hosts:

  8.    - e2e-dubbo-provider

  9.  http:

  10.  - route:

  11.    - destination:

  12.        host: e2e-dubbo-provider

  13.        subset: v1

  14.        weight: 20

  15.    - destination:

  16.        host: e2e-dubbo-provider

  17.        subset: v2

  18.        weight: 80

路由策略已经生效，可以 http 请求 dubbo consumer 来触发 rpc 请求观察效果：

  1. # 启动一个 busybox Pod 并登陆

  2. kubectl run -i -t busybox --image=yauritux/busybox-curl --restart=Never

  3. # 使用 e2e-dubbo-consumer 的域名访问服务

  4. curl e2e-dubbo-consumer.e2e-dubbo.svc.cluster.local:8080/sayHello?name=dubbo-mosn

清理路由策略：

  1. istioctl delete -f samples/e2e-dubbo/platform/kube/dubbo-consumer.destinationrule.yaml

  2. istioctl delete -f samples/e2e-dubbo/platform/kube/dubbo-consumer.weight.vs.yaml

更多功能，敬请期待。

SOFAMesh - https://github.com/alipay/sofa-mesh

参考文档

  • 蚂蚁金服开源的 SOFAMesh 的通用协议扩展解析 - servicemesher.com

  • 在 Kubernetes 中快速开始 - istio.io

  • 注入 Istio sidecar - istio.io

  • Dubbo quick start - dubbo.incubator.apache.org

点击【阅读原文】跳转到ServiceMesher网站上阅读可以查看本文中的链接。

相关阅读

开源 | 蚂蚁金服分布式中间件开源第三弹: 下一代微服务SOFAMesh

蚂蚁金服开源Go语言版Service Mesh数据平面SOFAMosn性能报告

蚂蚁金服大规模微服务架构下的Service Mesh探索之路

一键在本地搭建运行Istio 1.0的分布式Kubernetes集群

Service Mesh Meetup深圳站回顾、视频回放及PPT资料分享

必读！Istio Service Mesh中的流量管理概念解析

合作社区

参与社区

以下是参与ServiceMesher社区的方式，最简单的方式是联系我！

  • 加入微信交流群：关注本微信公众号后访问主页右下角有获取联系方式按钮，添加好友时请注明姓名-公司

  • 社区网址：http://www.servicemesher.com

  • Slack：https://servicemesher.slack.com （需要邀请才能加入）

  • GitHub：https://github.com/servicemesher

  • Istio中文文档进度追踪：https://github.com/servicemesher/istio-official-translation

  • Twitter: https://twitter.com/servicemesher

  • 提供文章线索与投稿：https://github.com/servicemesher/trans


您可能也对以下帖子感兴趣

文章有问题？点此查看未经处理的缓存