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

时间 2019-12-05

标签 dubbo protocol sofamesh 示例演示栏目 Dubbo 繁體版

原文原文链接

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

原文地址：www.servicemesher.com/blog/dubbo-…git

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

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

关于 x-protocol 的介绍请参考蚂蚁金服开源的 SOFAMesh 的通用协议扩展解析。apache

前期准备

安装 Minikube，推荐使用 Minikube v0.28 以上来体验，请参考 github.com/kubernetes/…
安装 kubectl 命令行工具，请参考 kubernetes.io/docs/tasks/…
安装 VM Driver，推荐安装 Virtual Box、Mac 用户也能够选择 hyperkit
了解 Istio Traffic Management 相关概念，相关连接：istio.io/zh/docs/tas…

部署

先看部署效果图：api

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

1. 安装 Kubernetes

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

minikube start --memory=8192 --cpus=4 --kubernetes-version=v1.10.0 \
    --extra-config=controller-manager.cluster-signing-cert-file="/var/lib/localkube/certs/ca.crt" \
    --extra-config=controller-manager.cluster-signing-key-file="/var/lib/localkube/certs/ca.key"
复制代码

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

minikube start --memory=8192 --cpus=4 --kubernetes-version=v1.10.0 \
    --extra-config=controller-manager.cluster-signing-cert-file="/var/lib/localkube/certs/ca.crt" \
    --extra-config=controller-manager.cluster-signing-key-file="/var/lib/localkube/certs/ca.key" \
    --vm-dirver=hyperkit
复制代码

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

kubectl get pods --namespace=kube-system
复制代码

2. 部署 SOFAMesh

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

从 GitHub 拉取最新代码：

git clone https://github.com/alipay/sofa-mesh.git
cd sofa-mesh
复制代码

建立 SOFAMesh 须要的 CRD：

kubectl apply -f install/kubernetes/helm/istio/templates/crds.yaml
kubectl apply -f install/kubernetes/helm/istio/charts/certmanager/templates/crds.yaml
复制代码

使用 Helm 安装 SOFAMesh：

kubectl apply -f install/kubernetes/helm/helm-service-account.yaml
helm init --service-account tiller
helm install install/kubernetes/helm/istio --name istio --namespace istio-system
复制代码

安装 istioctl 命令行工具：

# 使用 make 工具安装 istioctl
make istioctl-install
复制代码

3. 建立示例的命名空间

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

kubectl apply -f samples/e2e-dubbo/platform/kube/e2e-dubbo-ns.yaml
复制代码

4. 注入 SOFAMosn

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

# mosn sidecar inject and deploy
kubectl apply -f <(istioctl kube-inject -f samples/e2e-dubbo/platform/kube/dubbo-consumer.yaml)
kubectl apply -f <(istioctl kube-inject -f samples/e2e-dubbo/platform/kube/dubbo-provider-v1.yaml)
kubectl apply -f <(istioctl kube-inject -f samples/e2e-dubbo/platform/kube/dubbo-provider-v2.yaml)
复制代码

5. 部署示例应用

部署 dubbo consumer service 及 dubbo provider service。

# http service for dubbo consumer
kubectl apply -f samples/e2e-dubbo/platform/kube/dubbo-consumer-service.yaml

# dubbo provider service
kubectl apply -f samples/e2e-dubbo/platform/kube/dubbo-provider-service.yaml
复制代码

检查部署状态：

#kubectl get pods -n e2e-dubbo
NAME                                     READY     STATUS    RESTARTS   AGE
e2e-dubbo-consumer-589d8c465d-cp7cx      2/2       Running   0          13s
e2e-dubbo-provider-v1-649d7cff94-52gfd   2/2       Running   0          13s
e2e-dubbo-provider-v2-5f7d5ff648-m6c45   2/2       Running   0          13s

#kubectl get svc -n e2e-dubbo 
NAME                 TYPE        CLUSTER-IP      EXTERNAL-IP   PORT(S)     AGE
e2e-dubbo-consumer   ClusterIP   192.168.1.7     <none>        8080/TCP    10s
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:

istioctl create -f samples/e2e-dubbo/platform/kube/dubbo-consumer.destinationrule.yaml
复制代码

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

apiVersion: networking.istio.io/v1alpha3
kind: DestinationRule
metadata:
 name: e2e-dubbo-provider
 namespace: e2e-dubbo
spec:
 host: e2e-dubbo-provider
 subsets:
 - name: v1
 labels:
 ver: v1
 - name: v2
 labels:
 ver: v2 
复制代码

配置VirtualService：

istioctl create -f samples/e2e-dubbo/platform/kube/dubbo-consumer.version.vs.yaml
复制代码

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

apiVersion: networking.istio.io/v1alpha3
kind: VirtualService
metadata:
 name: e2e-dubbo-provider
 namespace: e2e-dubbo
spec:
 hosts:
 - e2e-dubbo-provider
 http:
 - route:
 - destination:
 host: e2e-dubbo-provider
 subset: v1
复制代码

路由策略已经生效，能够 http 请求 dubbo consumer 来触发 rpc 请求观察效果，因为使用 Minikube 的关系，须要启动一个 Pod 用来测试

# 启动一个 busybox Pod 并登录
kubectl run -i -t busybox --image=yauritux/busybox-curl --restart=Never
# 使用 e2e-dubbo-consumer 的域名访问服务
curl e2e-dubbo-consumer.e2e-dubbo.svc.cluster.local:8080/sayHello?name=dubbo-mosn
复制代码

清理路由策略：

istioctl delete -f samples/e2e-dubbo/platform/kube/dubbo-consumer.destinationrule.yaml
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:

# 若是在上一示例中已经建立好了，请跳过这一步
istioctl create -f samples/e2e-dubbo/platform/kube/dubbo-consumer.destinationrule.yaml
复制代码

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

apiVersion: networking.istio.io/v1alpha3
kind: DestinationRule
metadata:
 name: e2e-dubbo-provider
 namespace: e2e-dubbo
spec:
 host: e2e-dubbo-provider
 subsets:
 - name: v1
 labels:
 ver: v1
 - name: v2
 labels:
 ver: v2 
复制代码

配置 VirtualService：

istioctl create -f samples/e2e-dubbo/platform/kube/dubbo-consumer.weight.vs.yaml
复制代码

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

apiVersion: networking.istio.io/v1alpha3
kind: VirtualService
metadata:
 name: e2e-dubbo-provider
 namespace: e2e-dubbo
spec:
 hosts:
 - e2e-dubbo-provider
 http:
 - route:
 - destination:
 host: e2e-dubbo-provider
 subset: v1
 weight: 20
 - destination:
 host: e2e-dubbo-provider
 subset: v2
 weight: 80
复制代码

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

# 启动一个 busybox Pod 并登录
kubectl run -i -t busybox --image=yauritux/busybox-curl --restart=Never
# 使用 e2e-dubbo-consumer 的域名访问服务
curl e2e-dubbo-consumer.e2e-dubbo.svc.cluster.local:8080/sayHello?name=dubbo-mosn
复制代码

清理路由策略：

istioctl delete -f samples/e2e-dubbo/platform/kube/dubbo-consumer.destinationrule.yaml
istioctl delete -f samples/e2e-dubbo/platform/kube/dubbo-consumer.weight.vs.yaml
复制代码

更多功能，敬请期待。

SOFAMesh Github 地址：github.com/alipay/sofa…

参考文档

关于SOFAMesh的更多信息请访问 www.sofastack.tech

ServiceMesher社区信息

微信群：联系我入群

社区官网：www.servicemesher.com

Slack：servicemesher.slack.com 须要邀请才能加入

Twitter: twitter.com/servicemesh…

GitHub：github.com/

servicemesher

更多Service Mesh咨询请扫码关注微信公众号ServiceMesher。