zoukankan      html  css  js  c++  java
  • 通过 Helm3 在 Kubernetes 上部署 EMQ X 4.0 集群

    Helm 在 2019 年 11 月发布了 Helm3 , Helm3 相比于 Helm2 增加了不少新特性, 本文介绍如何通过 Helm3 在 Kubernetes 上部署 EMQ X 集群.

    Helm3 新特性

    • 移除了 Tiller
    • 不同的 namespace 可以使用相同的 Release Name
    • 简化模板对象 .Capabilities
    • 使用 JSONSchema 验证 charts 的 Values
    • requirements.yaml 合并到 Chart.yaml
    • helm install 时需要指定 Release Name,开启自动生成需要 --generate-name 参数
    • 支持 push 到远端 registry (如:harbor)
    • 移除 helm serve
    • 命令行变化(将原先的命令保留为别名 Aliases)
      • helm delete --> helm uninstall
      • helm inspect -> helm show
      • helm fetch -> helm pull
    • go 导入路径改变 k8s.io/helm --> helm.sh/helm

    具体新特性可以参考 Helm 官方文档

    Install Helm3

    Helm3 提供了官方脚本简化了安装步骤, 可以执行 curl https://raw.githubusercontent.com/helm/helm/master/scripts/get-helm-3 | bash 一键安装, 或者查看 Helm 官方文档 的详细说明

    快速部署一个简单的 EMQ X 集群

    • 添加 helm 仓库

      $ helm repo add emqx https://repos.emqx.io/charts
      $ helm repo update
      
    • 查询 EMQ X

      helm search repo emqx
      NAME       	 CHART VERSION	APP VERSION	DESCRIPTION
      emqx/emqx  	 v4.0.0       	v4.0.0     	A Helm chart for EMQ X
      emqx/emqx-ee v4.0.0       	v4.0.0     	A Helm chart for EMQ X
      emqx/kuiper	 0.1.1        	0.1.1      	A lightweight IoT edge analytic software
      
    • 启动 EMQ X 集群,设置 service.type=NodePort

      $ helm install my-emqx emqx/emqx --set service.type=NodePort
      
    • 查看 EMQ X 集群情况

      $ kubectl get pods
      NAME       READY  STATUS             RESTARTS  AGE
      my-emqx-0  1/1     Running   0          56s
      my-emqx-1  1/1     Running   0          40s
      my-emqx-2  1/1     Running   0          21s
      
      $ kubectl exec -it my-emqx-0 -- emqx_ctl cluster status
      Cluster status: #{running_nodes =>
                            ['my-emqx@my-emqx-0.my-emqx-headless.default.svc.cluster.local',
                             'my-emqx@my-emqx-1.my-emqx-headless.default.svc.cluster.local',
                             'my-emqx@my-emqx-2.my-emqx-headless.default.svc.cluster.local'],
                        stopped_nodes => []}
      
    • 查看 EMQ X service

      $ kubectl get svc
      NAME                 TYPE        CLUSTER-IP      EXTERNAL-IP   PORT(S)                                                                                      AGE
      my-emqx              NodePort       10.101.143.92    <none>        1883:32756/TCP,8883:31569/TCP,8081:30585/TCP,8083:31804/TCP,8084:30523/TCP,18083:31253/TCP   4m33s
      my-emqx-headless     ClusterIP      None             <none>        1883/TCP,8883/TCP,8081/TCP,8083/TCP,8084/TCP,18083/TCP                                       4m33s
      

    可以看到 my-emqx 的 18083 端口对应的宿主机 IP 是 31539。(NodePort 在每次部署的时候都会变化,以实际部署时为准。)

    • 访问 Kubernetes 的任意一台节点 IP 的 31539 端口,输入默认用户名:admin,默认密码:public,登陆 EMQ X dashboard。

    • 删除 EMQ X 集群

      $ helm uninstall my-emqx
      release "my-emqx" uninstalled
      

    部署一个持久化的 EMQ X 集群

    EMQ X 通过 创建 PVC 资源挂载 /opt/emqx/data/mnesia 目录实现持久化 pods在部署 EMQ X 之前,用户需要部署 Haproxy 或 Nginx-PLUS 等负载均衡器,并自行在 Kubernetes 中创建 PVC 资源或是 Storage Classes 资源

    • 启动 EMQ X 集群

      • 如果用户部署了 PVC 资源,那么设置 persistence.existingClaim=your_pv_name

        $ helm install my-emqx emqx/emqx --set persistence.enabled=true --set persistence.existingClaim=your_pv_name
        
      • 如果用户部署了 Storage Classes 资源,那么设置persistence.storageClass=your_storageClass_name

        $ helm install my-emqx emqx/emqx --set persistence.enabled=true --set persistence.storageClass=your_storageClass_name
        
    • 查看 EMQ X 集群情况

      $ kubectl get pods
      NAME       READY  STATUS             RESTARTS  AGE
      my-emqx-0  1/1     Running   0          56s
      my-emqx-1  1/1     Running   0          40s
      my-emqx-2  1/1     Running   0          21s
      
      $ kubectl exec -it my-emqx-0 -- emqx_ctl cluster status
      Cluster status: #{running_nodes =>
                            ['my-emqx@my-emqx-0.my-emqx-headless.default.svc.cluster.local',
                             'my-emqx@my-emqx-1.my-emqx-headless.default.svc.cluster.local',
                             'my-emqx@my-emqx-2.my-emqx-headless.default.svc.cluster.local'],
                        stopped_nodes => []}
      
    • 以 Storage Classes 为例,可以看到 PVC 资源已经成功的建立

      $ kubectl get pvc
      NAME                  STATUS    VOLUME                                     CAPACITY   ACCESS MODES   STORAGECLASS   AGE
      emqx-data-my-emqx-0   Bound     pvc-8094cd75-adb5-11e9-80cc-0697b59e8064   1Gi        RWO            gp2            2m11s
      emqx-data-my-emqx-1   Bound     pvc-9325441d-adb5-11e9-80cc-0697b59e8064   1Gi        RWO            gp2            99s
      emqx-data-my-emqx-2   Bound     pvc-ad425e9d-adb5-11e9-80cc-0697b59e8064   1Gi        RWO            gp2            56s
      

      集群会将 EMQ X 的 /opt/emqx/data/mnesia 目录挂载到 PVC 中,当 Pods 被重新调度之后,EMQ X 会从 /opt/emqx/data/mnesia 目录中获取数据并恢复

    • 查看 EMQ X 的 ClusterIP

      $ kubectl get svc
      NAME                 TYPE        CLUSTER-IP      EXTERNAL-IP   PORT(S)                                                  AGE
      my-emqx              ClusterIP   10.100.205.13   <none>        1883/TCP,8883/TCP,8081/TCP,8083/TCP,8084/TCP,18083/TCP   26m
      my-emqx-headless     ClusterIP   None            <none>        1883/TCP,8883/TCP,8081/TCP,8083/TCP,8084/TCP,18083/TCP   26m
      

    可以看到 my-emqx 的 ClusterIP 为 10.100.205.13 (ClusterIP 在每次部署的时候都会变化,以实际部署时为准。)

    • 将负载均衡监听的 URL 的 1883、8883、8081、8083、8084、18083 端口转发到 my-emqx 的 ClusterIP,如果有 TLS 连接的需要,推荐在负载均衡器终结 SSL 连接。客户端与负载均衡器之间 TLS 安全连接,LB 与 EMQ X 之间普通 TCP 连接。

    • 访问 URL:18083,输入默认用户名:admin,默认密码:public,登陆 EMQ X dashboard。

    • 使用 helm upgrade 命令可以轻松扩展 EMQ X 集群,下面以增加 EMQ X 节点为例展示 helm upgrade 命令

      # 将 EMQ X 的节点数量变更为5个
      # 注意:EMQ X 的节点数量建议为单数
      $ helm upgrade --set replicaCount=5 my-emqx emqx/emqx
      Release "my-emqx" has been upgraded. Happy Helming!
      
      $ kubectl get pods
      NAME       READY  STATUS             RESTARTS  AGE
      my-emqx-0  1/1    Running            0         4m25s
      my-emqx-1  1/1    Running            0         4m14s
      my-emqx-2  1/1    Running            0         4m
      my-emqx-3  1/1    Running            0         31s
      my-emqx-4  1/1    Running            0         15s
    
      $ kubectl exec -it my-emqx-0 -- emqx_ctl cluster status
      Cluster status: #{running_nodes =>
                            ['my-emqx@my-emqx-0.my-emqx-headless.default.svc.cluster.local',
                             'my-emqx@my-emqx-1.my-emqx-headless.default.svc.cluster.local',
                             'my-emqx@my-emqx-2.my-emqx-headless.default.svc.cluster.local',
                             'my-emqx@my-emqx-3.my-emqx-headless.default.svc.cluster.local',
                             'my-emqx@my-emqx-4.my-emqx-headless.default.svc.cluster.local'],
                        stopped_nodes => []}
    
    
    • 删除 EMQ X 集群

      $ helm uninstall my-emqx
      release "my-emqx" uninstalled
      

    注意:EMQ X 集群删除掉之后 PVC 资源不会自动释放掉,以便恢复 EMQ X,确认不需要恢复后需要手动删除 PVC 资源

      $ kubectl get pvc
      NAME                  STATUS    VOLUME                                     CAPACITY   ACCESS MODES   STORAGECLASS   AGE
      emqx-data-my-emqx-0   Bound     pvc-8094cd75-adb5-11e9-80cc-0697b59e8064   1Gi        RWO            gp2            84m
      emqx-data-my-emqx-1   Bound     pvc-9325441d-adb5-11e9-80cc-0697b59e8064   1Gi        RWO            gp2            84m
      emqx-data-my-emqx-2   Bound     pvc-ad425e9d-adb5-11e9-80cc-0697b59e8064   1Gi        RWO            gp2            83m
      emqx-data-my-emqx-3   Bound     pvc-b6c5a565-adbd-11e9-80cc-0697b59e8064   1Gi        RWO            gp2            25m
      emqx-data-my-emqx-4   Bound     pvc-c626cafd-adbd-11e9-80cc-0697b59e8064   1Gi        RWO            gp2            25m
    
      $ kubectl delete pvc emqx-data-my-emqx-0 emqx-data-my-emqx-1 emqx-data-my-emqx-2 emqx-data-my-emqx-3 emqx-data-my-emqx-4                    
      persistentvolumeclaim "emqx-data-my-emqx-0" deleted
      persistentvolumeclaim "emqx-data-my-emqx-1" deleted
      persistentvolumeclaim "emqx-data-my-emqx-2" deleted
      persistentvolumeclaim "emqx-data-my-emqx-3" deleted
      persistentvolumeclaim "emqx-data-my-emqx-4" deleted
    

    部署 EMQ X Edge 集群和 EMQ X 企业版集群

    EMQ X Edge

    部署 EMQ X Edge 集群指定 image.repository=emqx/emqx-edge,其他设置与部署 EMQ X 集群保持一致

    $ helm install my-emqx-edge emqx/emqx --set image.repository=emqx/emqx
    $ kubectl get pods
    NAME            READY   STATUS    RESTARTS   AGE
    my-emqx-edge-0  1/1     Running   0          35s
    my-emqx-edge-1  1/1     Running   0          23s
    my-emqx-edge-2  1/1     Running   0          9s
    

    EMQ X EE

    部署 EMQ X 企业版集群首先需要登陆 emqx.io](https://emqx.io) 申请并下载 License 文件,并将 License 文件创建为 Secret 资源

    $ kubectl create secret generic your-license-secret-name --from-file=/path/to/emqx.lic
    

    然后在部署时指定 repo 为 emqx/emqx-ee , emqxLicneseSecretName=your-license-secret-name, 其他设置与部署 EMQ X 集群保持一致

    $ helm install my-emqx-ee emqx/emqx-ee emqxLicneseSecretName=your-license-secret-name
    

    EMQ X Helm Chart 配置项

    参数 描述 Default Value
    replicaCount EMQ X 节点数量,建议保持奇数个节点,不然脑裂后无法自动恢复 3
    image.repository EMQ X 镜像名称 emqx/emqx
    image.pullPolicy 获取镜像的策略 IfNotPresent
    persistence.enabled 是否启用 PVC false
    persistence.storageClass Storage class 名称 nil
    persistence.existingClaim PV 名称 ""
    persistence.accessMode PVC 访问模式 ReadWriteOnce
    persistence.size PVC 容量 20Mi
    resources CPU/ 内存资源 {}
    nodeSelector pod 分配的节点标签 {}
    tolerations []
    affinity {}
    service.type Emqx cluster service type ClusterIP
    emqxConfig EMQ X 配置项,详情查看文档 {}
    emqxLicneseSecretName EMQ X 企业版需要手动将 License 文件创建为 Secret 资源 (仅在 emqx/emqx-e 有效) ""

    当需要设置复杂参数的时候,可以使用 Yaml 文件来记录参数

    $ helm install my-emqx emqx/emqx -f values.yaml 
    

    你可以从 Github 获取默认的 values.yaml

  • 相关阅读:
    并查集
    博弈——Bash、Nim、Wythoff
    博弈——SG函数模板
    数据结构——二叉树
    数据结构——链式队列
    sonar-maven-plugin问题
    确立核心模型
    调度思路+EurekaServer获得当前机器的instanceid
    简易的RestClient代码
    Spring Cloud App(Service) Pom示例
  • 原文地址:https://www.cnblogs.com/emqx/p/11577939.html
Copyright © 2011-2022 走看看