Helm部署EMQX集群

news2025/1/11 21:44:10

端口说明：

端口说明集群内端口Nodeport备注
mqtt188331274Port for MQTT
mqttssl888331170Port for MQTT(SSL)
mgmt8081无
ws808330099Port for WebSocket/HTTP
wss808432580Port for WSS/HTTPS
dashboard1808331303Port for dashboard

一、Helm在线部署EMQX集群

1、安装helm

wget https://get.helm.sh/helm-v3.12.3-linux-amd64.tar.gz
cp linux-amd64/helm /usr/local/bin/
helm version

2、添加helm仓库

helm repo add emqx https://repos.emqx.io/charts
helm repo list
helm repo update
helm search repo emqx

3、创建storageClass或者pv,pvc(略)

4、使用持久化资源storageClass安装emqx

helm install emqx emqx/emqx \
  --set replicaCount=3 \
  --set image.tag=5.2.1 \
  --set persistence.enabled=true \
  --set persistence.size=100Mi \
  --set persistence.storageClass=nfs  \
  --set service.type=NodePort \
  --set service.nodePorts.mqtt=31274 \
  --set service.nodePorts.mqttssl=31170 \
  --set service.nodePorts.ws=30099 \
  --set service.nodePorts.wss=32580 \
  --set service.nodePorts.dashboard=31303 \
  --namespace emqx \
  --create-namespacee

5、使用持久化资源pv,pvc安装emqx

helm install emqx emqx/emqx \
  --set replicaCount=3 \
  --set image.tag=5.2.1 \
  --set persistence.enabled=true \
  --set persistence.size=100Mi \
  --set persistence.existingClaim=emqx-data-pvc  \
  --set service.type=NodePort \
  --set service.nodePorts.mqtt=31274 \
  --set service.nodePorts.mqttssl=31170 \
  --set service.nodePorts.ws=30099 \
  --set service.nodePorts.wss=32580 \
  --set service.nodePorts.dashboard=31303 \
  --namespace emqx \
  --create-namespace

6、验证emqx

heml status -n emqx emqx
helm list -n emqx
kubectl get pods -n emqx
kubectl get svc -n emqx
kubectl get pv,pvc -n emqx

7、登录dashboard

http://192.168.1.47:31303
admin / public #默认账号密码
admin / public123

8、创建mysql数据库实例emqx_user，并授权

mysql> create databases mqtt_user;
mysql> grant all privileges on mqtt_user.* to 'mqtt_user'@'%' identified by 'mqtt123';
myql> flush privileges;

9、创建表

  • https://docs.emqx.com/zh/enterprise/v5.2/access-control/authn/mysql.html
mysql> CREATE TABLE `mqtt_user` (
 `id` int(11) unsigned NOT NULL AUTO_INCREMENT,
 `username` varchar(100) DEFAULT NULL,
 `password_hash` varchar(100) DEFAULT NULL,
 `salt` varchar(35) DEFAULT NULL,
 `is_superuser` tinyint(1) DEFAULT 0,
 `created` datetime DEFAULT NULL,
 PRIMARY KEY (`id`),
 UNIQUE KEY `mqtt_username` (`username`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;

9、插入表数据

在此表中使用 username 作为查找条件。

例如，我们希望添加一名用户名为 emqx_user、密码为 public、盐值为 slat_foo123、散列方式为 sha256 且超级用户标志为 true 的用户：

mysql> INSERT INTO mqtt_user(username, password_hash, salt, is_superuser) VALUES ('mqtt_user', SHA2(concat('public', 'slat_foo123'), 256), 'slat_foo123', 1);

10、添加客户端认证

![外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传](https://img-home.csdnimg.cn/images/202307240241在这里插入图片描述
在这里插入图片描述

二、Helm离线部署EMQX集群

1、制作应用的离线安装包(需能访问外放)

1.1 安装helm

wget https://get.helm.sh/helm-v3.12.3-linux-amd64.tar.gz
cp linux-amd64/helm /usr/local/bin/
helm version

1.2 添加仓库

helm repo add emqx https://repos.emqx.io/charts

1.3 使用helm下载对应版本的chats

1.3.1 查询版本
helm search repo emqx --version 5.2.1

在这里插入图片描述

1.3.2 pull应用chats到本地并上传到指定服务器
helm pull emqx/emqx --version 5.2.1

在这里插入图片描述

2、下载并定制镜像

docker pull emqx/emqx:5.2.1
docker login
docker tag emqx/emqx:5.2.1 58.34.20.154:5500/iecs/emqx:5.2.1 
docker push 58.34.20.154:5500/iecs/emqx:5.2.1

docker login
docker pull 58.34.20.154:5500/iecs/emqx:5.2.1
docker tag 58.34.20.154:5500/iecs/emqx:5.2.1 10.140.20.28/iecs/emqx:5.2.1
docker push 10.140.20.28/iecs/emqx:5.2.1

3、创建storageClass或者pv\pvc(略)

4、使用持久化资源storageClass创建emqx集群

helm install emqx ./emqx-5.2.1.tgz \
  --set replicaCount=3 \
  --set image.repository=10.140.20.28/iecs/emqx:5.2.1 \
  --set image.tag=5.2.1 \
  --set persistence.enabled=true \
  --set persistence.size=100Mi \
  --set persistence.storageClass=nfs  \
  --set service.type=NodePort \
  --set service.nodePorts.mqtt=31274 \
  --set service.nodePorts.mqttssl=31170 \
  --set service.nodePorts.ws=30099 \
  --set service.nodePorts.wss=32580 \
  --set service.nodePorts.dashboard=31303 \
  --namespace emqx \
  --create-namespacee

5、使用持久化资源pv\pvc创建emqx集群

helm install emqx ./emqx-5.2.1.tgz \
--set replicaCount=3 \
--set image.repository=10.140.20.28/iecs/emqx:5.2.1 \
  --set image.tag=5.2.1 \
  --set persistence.enabled=true \
  --set persistence.size=100Mi \
  --set persistence.existingClaim=emqx-data-pvc  \
  --set service.type=NodePort \
  --set service.nodePorts.mqtt=31274 \
  --set service.nodePorts.mqttssl=31170 \
  --set service.nodePorts.ws=30099 \
  --set service.nodePorts.wss=32580 \
  --set service.nodePorts.dashboard=31303 \
  --namespace emqx \
--create-namespace

6、验证emqx

heml status -n emqx emqx
helm list -n emqx
kubectl get pods -n emqx
kubectl get svc -n emqx
kubectl get pv,pvc -n emqx

7、登录dashboard

http://192.168.1.47:31303
admin / public #默认账号密码
admin / public123

8、创建mysql数据库实例emqx_user，并授权

mysql> create databases mqtt_user;
mysql> grant all privileges on mqtt_user.* to 'mqtt_user'@'%' identified by 'mqtt123';
myql> flush privileges;

9、创建表

  • https://docs.emqx.com/zh/enterprise/v5.2/access-control/authn/mysql.html
mysql> CREATE TABLE `mqtt_user` (
 `id` int(11) unsigned NOT NULL AUTO_INCREMENT,
 `username` varchar(100) DEFAULT NULL,
 `password_hash` varchar(100) DEFAULT NULL,
 `salt` varchar(35) DEFAULT NULL,
 `is_superuser` tinyint(1) DEFAULT 0,
 `created` datetime DEFAULT NULL,
 PRIMARY KEY (`id`),
 UNIQUE KEY `mqtt_username` (`username`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;

10、插入表数据

在此表中使用 username 作为查找条件。

例如，我们希望添加一名用户名为 emqx_user、密码为 public、盐值为 slat_foo123、散列方式为 sha256 且超级用户标志为 true 的用户：

mysql> INSERT INTO mqtt_user(username, password_hash, salt, is_superuser) VALUES ('mqtt_user', SHA2(concat('public', 'slat_foo123'), 256), 'slat_foo123', 1);

11、添加客户端认证

在这里插入图片描述
在这里插入图片描述
在这里插入图片描述

三、卸载EMQX集群

#卸载emqx集群
helm uninstall emqx -n emqx
#删除pv/pvc
kubectl delete -n emqx pvc emqx-data-emqx-0

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/1065905.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

Compose输入框

Compose输入框

TextField label设置提示内容，TextFieldDefaults.textFieldColors设置输入框背景颜色 TextField(modifier Modifier.fillMaxWidth().padding(5.dp),value text.value,onValueChange { text.value it },label { Text(text "请输入内容") },colors …
阅读更多...
算法题：买卖股票的最佳时机 II

算法题：买卖股票的最佳时机 II

这道题是贪心算法的中级难度练习题，由于题目设定，整个价格都是透明的，这里并不涉及需要预测股票涨势的问题。解决思路不难，就是一旦股票价格开始下降了就买入，一旦上升了，就赶紧卖出。（完整题目…
阅读更多...
led护眼台灯对眼睛有伤害吗？推荐好用的led护眼台灯

led护眼台灯对眼睛有伤害吗？推荐好用的led护眼台灯

其实led护眼台灯对眼睛伤害是不大的，而且和白炽灯、卤素灯等老式台灯相对比，反而更加护眼。因为白炽灯、卤素灯等光线都不太稳定，而且光线不是很均匀可以明显感觉有明暗差，最主要的是频闪现象会比较严重，长时间使用的话…
阅读更多...
Apache Tomcat安装、运行

Apache Tomcat安装、运行

介绍 Apache Tomcat是下面多个规范的一个开源实现：Jakarta Servlet、Jakarta Server Pages、Jakarta Expression Language、Jakarta WebSocket、Jakarta Annotations 和 Jakarta Authentication。这些规范是 Jakarta EE 平台的一部分。 Jakarta EE 平台是Java EE平…
阅读更多...
汽车发电机三根线接线图图解，发电机调节器怎么接线

汽车发电机三根线接线图图解，发电机调节器怎么接线

特此记录 anlog 2023年10月7日
阅读更多...
Vue Router的使用

Vue Router的使用

使用 项目中注入路由器 在项目中 src 目录下新建 router 目录，其中包含 index.js 路由主文件。 // src/router/index.jsimport Vue from vue import Router from vue-router import { routes } from ./routes.jsVue.use(Router) const router new Router({route…
阅读更多...
EPDB 08、EPDBS 10、PDRV、EPDZA06插装式比例减压阀放大器

EPDB 08、EPDBS 10、PDRV、EPDZA06插装式比例减压阀放大器

比例方向阀W42E-5PS03、W43E-5PS05、W42E-1AS06、W43E-1AS06、插装式S22E-1V08放大器。 该放大器既可用于工业及移动设备应用，也可用于固定安装。因此，电压范围非常宽，在8至35VDC之间变化。这些放大器对欠压和电压尖峰非常不敏感&#xff0c…
阅读更多...
浅谈时间流管理体系

浅谈时间流管理体系

不想聊技术，但又想分享一些东西，这篇文章分享下如何构造自己的时间流管理体系以及如何完整的把控一个事件安排统筹，这里对一个大型事件或大型知识体系如何分解为不同问题的小点不做点出，这里只提时间管理体系化。 好处的话也不做阐…
阅读更多...
Nginx+Keepalived实现服务高可用

Nginx+Keepalived实现服务高可用

Nginx 和 Keepalived 是常用于构建高可用性（High Availability）架构的工具。Nginx 是一款高性能的Web服务器和反向代理服务器，而Keepalived则提供了对Nginx服务的健康状态监测和故障切换功能。 下载Nginx 在服务器1和服务器2分别下载nginx …
阅读更多...
深入理解 python 虚拟机：原来虚拟机是这么实现闭包的

深入理解 python 虚拟机：原来虚拟机是这么实现闭包的

深入理解 python 虚拟机：原来虚拟机是这么实现闭包的 在本篇文章当中主要从虚拟机层面讨论函数闭包是如何实现的，当能够从设计者的层面去理解闭包就再也不用死记硬背一些闭包的概念了，因为如果你理解闭包的设计原理之后，这些都是…
阅读更多...
嵌入式学习笔记（48）什么是I2C通信

嵌入式学习笔记（48）什么是I2C通信

10.1.1物理接口：SCL SDA (1)SCL：时钟线，传输CLK，一般是I2C主设备向从设备提供时钟的通道。 (2)SDA：数据线，通信数据都通过SDA线传输。 10.1.2通信特征：串行、同步、非差分、低速 (1)I2C属于…
阅读更多...
Python中的多态

Python中的多态

迷途小书童 读完需要 3分钟 速读仅需 1 分钟 当我们谈到多态时，可以将其比喻为一个人具有多种身份的能力。在不同的情境下，这个人可以表现出不同的行为和特征。在 Python 中，多态是面向对象编程中的一个重要概念，它允许我们使用相…
阅读更多...
PHP 伪协议：使用 php://filter 为数据流应用过滤器

PHP 伪协议：使用 php://filter 为数据流应用过滤器

文章目录 参考环境PHP 伪协议概念为什么需要 PHP 伪协议？ php://filter概念格式 基本使用普通读写file_get_contents 与 file_put_contentsinclude 过滤器的基本使用base64 的编码与解码rot13 加解密rot13 算法string.rot13 过滤器列表多个过滤器的使用注意事项 处理…
阅读更多...
【软件测试】功能测试/接口测试/自动化测试/性能测试/验收测试

【软件测试】功能测试/接口测试/自动化测试/性能测试/验收测试

软件测试的主要流程 一、测试主要的四个阶段 1.测试计划设计阶段：产品立项之后，进行需求分析，需求评审，业务需求评级，绘制业务流程图。确定测试负责人，开始制定测试计划； 2.测试准备阶段&…
阅读更多...
【每日一题】股票价格跨度

【每日一题】股票价格跨度

文章目录 Tag题目来源题目解读解题思路方法一：暴力枚举方法二：单调栈 写在最后 Tag 【单调栈】【设计类】【数组】【2023-10-07】 题目来源 901. 股票价格跨度 题目解读 找出小于等于今天股票价格的最大连续天数（从今天往回数，…
阅读更多...
AI颠覆法律行业，律师要失业了？

AI颠覆法律行业，律师要失业了？

如果要说一个 AI 真正起飞，并且对行业从业者带来的更多是正面影响的垂直行业，小编觉得在目前阶段，法律可以算一个。这个行业有几个特点：对人的依赖很大，专业性很强，大量繁复的文字工作。因此，在…
阅读更多...
水土保持方案编制丨点型项目、市政工程、线型工程、矿山工程、水利工程、取土场/弃渣场、补报项目、水土保持监测验收等

水土保持方案编制丨点型项目、市政工程、线型工程、矿山工程、水利工程、取土场/弃渣场、补报项目、水土保持监测验收等

目录 专题一 点型水土保持方案编制方法及案例分析 专题二 市政工程水土保持方案编制方法及案例分析 专题三 线型工程水土保持方案编制方法及案例分析 专题四 矿山工程水土保持方案编制方法及案例分析 专题五 水利工程水土保持方案编制方法及案例分析 专题六 取土场、弃渣…
阅读更多...
电影产业的数据洞察：爬虫技术在票房分析中的应用

电影产业的数据洞察：爬虫技术在票房分析中的应用

概述 电影产业是一个庞大而复杂的行业，涉及到各种各样的因素，如导演、演员、类型、主题、预算、宣传、口碑、评分、奖项等。这些因素都会影响电影的票房收入，也会反映出电影市场的动态和趋势。为了更好地了解电影产业的数据洞察，…
阅读更多...
Python机器学习实战-特征重要性分析方法（6）：XGBoost（附源码和实现效果）

Python机器学习实战-特征重要性分析方法（6）：XGBoost（附源码和实现效果）

实现功能 计算一个特性用于跨所有树拆分数据的次数。更多的分裂意味着更重要。 实现代码 import xgboost as xgb import pandas as pd from sklearn.datasets import load_breast_cancer import matplotlib.pyplot as pltX, y load_breast_cancer(return_X_yTrue) df pd.D…
阅读更多...
CMMI5认证哪些企业可以申请

CMMI5认证哪些企业可以申请

CMMI5认证哪些企业可以申请 什么是CMMI5认证 CMMI（Capability Maturity Model Integration）是一种用于评估组织的软件工程能力的国际标准。CMMI模型包括5个等级，其中CMMI5是最高等级，代表组织具有达到持续优化和创新的能力。获得…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023