利用 EMQX Operator 部署 EMQX 集群

EMQX Operator 最新信息, 请访问 github基于 k8s 部署 EMQX 集群 - 图1 (opens new window).

  1. 使用 cert-manager基于 k8s 部署 EMQX 集群 - 图2 (opens new window) 给 webhook 服务提供证书,可以参考 cert-manager 文档基于 k8s 部署 EMQX 集群 - 图3 (opens new window) 安装

  2. 可以通过如下两种方式之一来安装 Operator Controller:

    • 使用静态文件安装
    1. curl -f -L "https://github.com/emqx/emqx-operator/releases/download/1.2.2/emqx-operator-controller.yaml" | kubectl apply -f -
    • 使用 Helm 安装

      • 添加 EMQX Helm 仓库
      1. helm repo add emqx https://repos.emqx.io/charts
      2. helm repo update
      • 用 Helm 安装 EMQX Operator 控制器
      1. $ helm install emqx-operator emqx/emqx-operator \
      2. --set installCRDs=true \
      3. --namespace emqx-operator-system \
      4. --create-namespace
  3. 检查 EMQX Operator 控制器状态

    1. $ kubectl get pods -l "control-plane=controller-manager" -n emqx-operator-system
    2. NAME READY STATUS RESTARTS AGE
    3. emqx-operator-controller-manager-68b866c8bf-kd4g6 1/1 Running 0 15s
  4. 部署 EMQX Broker

  • 部署 EMQX Custom Resource

    1. $ cat << "EOF" | kubectl apply -f -
    2. apiVersion: apps.emqx.io/v1beta3
    3. kind: EmqxBroker
    4. metadata:
    5. name: emqx
    6. labels:
    7. "foo": "bar"
    8. spec:
    9. emqxTemplate:
    10. image: emqx/emqx:4.4.5
    11. EOF
  • 检查 EMQX 状态

    1. $ kubectl get pods
    2. NAME READY STATUS RESTARTS AGE
    3. emqx-0 2/2 Running 0 22s
    4. emqx-1 2/2 Running 0 22s
    5. emqx-2 2/2 Running 0 22s
    6. $ kubectl exec -it emqx-0 -c emqx -- emqx_ctl status
    7. Node 'emqx@emqx-0.emqx-headless.default.svc.cluster.local' 4.4.5 is started
    8. $ kubectl exec -it emqx-0 -c emqx -- emqx_ctl cluster status
    9. Cluster status: #{running_nodes =>
    10. ['emqx@emqx-0.emqx-headless.default.svc.cluster.local',
    11. 'emqx@emqx-1.emqx-headless.default.svc.cluster.local',
    12. 'emqx@emqx-2.emqx-headless.default.svc.cluster.local'],
    13. stopped_nodes => []}