基于腾讯云容器服务Serverless集群的EMQ X集群搭建

原创

buzzfrog

发布于 2023-04-12 19:00:27

2K0

发布于 2023-04-12 19:00:27

文章被收录于专栏：云上修行云上修行

背景

EMQ X是杭州映云科技有限公司使用Apache License 2.0协议开源的一款MQTT Broker服务软件。

本文介绍使用EMQ X在腾讯云容器服务Serverless集群上搭建MQTT服务。

搭建步骤

创建腾讯云容器服务Serverless集群

按流程往下走，整个过程很顺，我没有碰到什么坑。

创建集群完成后，点击集群名称后，进入集群基本信息页面，打开内外网开关，按照通过Kubectl连接Kubernetes集群操作说明在本地笔记本安装kubectl命令行工具。

部署cert-manager

在本地命令行执行：

kubectl apply -f https://github.com/cert-manager/cert-manager/releases/download/v1.8.2/cert-manager.yaml

由于cert-manager 官方使用的镜像在 quay.io （需要修改为 quay.tencentcloudcr.com ）进行拉取，但由于众说周知的原因网络不通，腾讯云有一篇文档《使用cert-manager签发免费证书》可以参考如何解决这个问题。另外，缺省配置的Secret也有问题。我是在腾讯云控制台修改了yaml的配置解决问题的。

以第一个Deployment为例，演示如何修改：

后面两个Deployment也需要做同样的修改。

部署EMQX Operator

这段可以参考利用 EMQX Operator 部署 EMQX 集群

【重要】务必等待cert-manager安装成功后，再执行安装emqx-operator

在本地命令行执行：

kubectl apply -f "https://github.com/emqx/emqx-operator/releases/download/1.2.2/emqx-operator-controller.yaml"

检查 EMQX Operator 控制器状态：

$ kubectl get pods -l "control-plane=controller-manager" -n emqx-operator-system
NAME                                                READY   STATUS    RESTARTS   AGE
emqx-operator-controller-manager-xxxxxxxx-xxxxx   1/1     Running   0          15s

部署 EMQX 开源版

本地命令行执行：

cat << "EOF" | kubectl apply -f -
apiVersion: apps.emqx.io/v1beta3
kind: EmqxBroker
metadata:
  name: emqx
  labels:
    "foo": "bar"
spec:
  emqxTemplate:
    image: emqx/emqx:4.4.5
EOF

这里我执行得比较坎坷：

cert-manager部署还没有成功的时候，就开始部署EMQX；
EMQX的Secret没有被正确下发，需要下发qcloudregistrykey。

在怀疑Volume的问题上，纠缠了很久。

确认部署好。

$ kubectl get pods
NAME              READY   STATUS    RESTARTS   AGE
emqx-0   2/2     Running   0          22m
emqx-1   2/2     Running   0          22m
emqx-2   2/2     Running   0          22m

$ kubectl exec -it emqx-0 -c emqx -- emqx_ctl status
Node 'emqx@emqx-0.emqx-headless.default.svc.cluster.local' 4.4.5 is started

$ kubectl exec -it emqx-0 -c emqx -- emqx_ctl cluster status
Cluster status: #{running_nodes =>
                   ['emqx@emqx-0.emqx-headless.default.svc.cluster.local',
                    'emqx@emqx-1.emqx-headless.default.svc.cluster.local',
                    'emqx@emqx-2.emqx-headless.default.svc.cluster.local'],
               stopped_nodes => []}