使用 Helm 安装 MQTT 服务器-EMQX

EMQX

ℹ️ Info:
使用 EMQX
通过 Helm3 在 Kubernetes 上部署 EMQX 4.0 集群 | EMQ
emqx/deploy/charts/emqx at main-v4.4 · emqx/emqx (github.com)
emqx/values.yaml at main-v4.4 · emqx/emqx (github.com)
emqx/emqx-operator: A Kubernetes Operator for EMQ X Broker (github.com)
配置项 | EMQX 文档

EMQX 安装

ℹ️ Info:
即 EMQX 服务器端。

1. > helm repo add emqx https://repos.emqx.io/charts
2. "emqx" has been added to your repositories
3. > helm repo update
4. Hang tight while we grab the latest from your chart repositories...
5. ...Successfully got an update from the "emqx" chart repository
6. Update Complete. ⎈Happy Helming!⎈
7. > helm search repo emqx
8. NAME                    CHART VERSION   APP VERSION     DESCRIPTION                              
9. emqx/emqx               4.4.0           4.4.0           A Helm chart for EMQ X                  
10. emqx/emqx-ee            4.4.1           4.4.1           A Helm chart for EMQ X                  
11. emqx/emqx-operator      1.0.1           1.1.2           A Helm chart for EMQX Operator Controller
12. emqx/kuiper             0.9.0           0.9.0           A lightweight IoT edge analytic software

复制代码

安装：
vi values.yaml:

1. replicaCount: 1
2. image:
3.   repository: emqx/emqx
4.   pullPolicy: IfNotPresent
6. recreatePods: false
8. podManagementPolicy: Parallel
10. extraEnv: []
12. extraEnvFrom: []
14. extraArgs: []
16. extraVolumes: []
18. extraVolumeMounts: []
20. persistence:
21.   enabled: true
22.   size: 8Gi
23.   storageClass: "local-path"
24.   accessMode: ReadWriteOnce
26. resources: {}
27.   # limits:
28.   #   cpu: 500m
29.   #   memory: 512Mi
30.   # requests:
31.   #   cpu: 500m
32.   #   memory: 512Mi
34. # Containers that run before the creation of EMQ X containers. They can contain utilities or setup scripts.
35. initContainers: {}
36.   # - name: mysql-probe
37.   #   image: alpine
38.   #   command: ["sh", "-c", "for i in $(seq 1 300); do nc -zvw1 mysql 3306 && exit 0 || sleep 3; done; exit 1"]
40. ## EMQ X configuration item, see the documentation (https://hub.docker.com/r/emqx/emqx)
41. emqxConfig:
42.   EMQX_NAME:  "{{ .Release.Name }}"
43.   ## Cluster discovery by k8s
44.   EMQX_CLUSTER__DISCOVERY: "k8s"
45.   EMQX_CLUSTER__K8S__APP_NAME: "{{ .Release.Name }}"
46.   EMQX_CLUSTER__K8S__APISERVER: "https://kubernetes.default.svc:443"
47.   EMQX_CLUSTER__K8S__SERVICE_NAME: "{{ .Release.Name }}-headless"
48.   EMQX_CLUSTER__K8S__NAMESPACE: "{{ .Release.Namespace }}"
49.   EMQX_CLUSTER__K8S__ADDRESS_TYPE: "hostname"
50.   EMQX_CLUSTER__K8S__SUFFIX: "svc.cluster.local"
52. emqxAclConfig: >
53.   {allow, {user, "dashboard"}, subscribe, ["$SYS/#"]}.
54.   {allow, {ipaddr, "127.0.0.1"}, pubsub, ["$SYS/#", "#"]}.
55.   {deny, all, subscribe, ["$SYS/#", {eq, "#"}]}.
56.   {allow, all}.
58. emqxLoadedPlugins: >
59.   {emqx_management, true}.
60.   {emqx_recon, true}.
61.   {emqx_retainer, true}.
62.   {emqx_dashboard, true}.
63.   {emqx_telemetry, true}.
64.   {emqx_rule_engine, true}.
65.   {emqx_bridge_mqtt, false}.
67. emqxLoadedModules: >
68.   {emqx_mod_acl_internal, true}.
69.   {emqx_mod_presence, true}.
70.   {emqx_mod_trace, false}.
71.   {emqx_mod_st_statistics, false}.
72.   {emqx_mod_delayed, false}.
73.   {emqx_mod_rewrite, false}.
74.   {emqx_mod_subscription, false}.
75.   {emqx_mod_topic_metrics, false}.
77. service:
78.   type: LoadBalancer
79.   mqtt: 1883
80.   mqttssl: 8883
81.   mgmt: 8081
82.   ws: 8083
83.   wss: 8084
84.   dashboard: 18083
86. podSecurityContext:
87.   enabled: true
88.   fsGroup: 1000
89.   fsGroupChangePolicy: Always
90.   runAsUser: 1000
91.   supplementalGroups:
92.     - 1000
94. containerSecurityContext:
95.   enabled: true
96.   runAsNonRoot: true
97.   runAsUser: 1000

复制代码

1. helm install emqx emqx/emqx --namespace emqx --create-namespace -f ./values.yaml --wait

复制代码

安装输出：

1. NAME: emqx
2. LAST DEPLOYED: Sat Feb 19 20:48:49 2022
3. NAMESPACE: emqx
4. STATUS: deployed
5. REVISION: 1
6. TEST SUITE: None

复制代码

EMQX 验证

安装后查看 EMQX 集群情况：

1. # kubectl -n emqx get pods
2. NAME               READY   STATUS    RESTARTS   AGE
3. svclb-emqx-kbl22   6/6     Running   0          41s
4. emqx-0             1/1     Running   0          41s
6. # kubectl -n emqx  exec -it emqx-0 -- emqx_ctl cluster status
7. Cluster status: #{running_nodes =>
8.                       ['emqx@emqx-0.emqx-headless.emqx.svc.cluster.local'],
9.                   stopped_nodes => []}
11. # kubectl -n emqx get svc
12. NAME            TYPE           CLUSTER-IP      EXTERNAL-IP      PORT(S)                                                                                      AGE
13. emqx-headless   ClusterIP      None            <none>           1883/TCP,8883/TCP,8081/TCP,8083/TCP,8084/TCP,18083/TCP,4370/TCP                              86s
14. emqx            LoadBalancer   10.43.193.192   10.<none> .245   1883:31558/TCP,8883:31122/TCP,8081:31592/TCP,8083:30322/TCP,8084:31095/TCP,18083:32427/TCP   86s

复制代码

访问控制台：
访问 URL:18083，输入默认用户名：admin，默认密码：public，登陆 EMQX dashboard。

MQTT 消息验证：
可以通过 MQTT X: Cross-platform MQTT 5.0 Desktop Client 连接并进行收发验证。


免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！