EMQ--添加mysql认证及mysql插件访问控制

2024-05-28 01:32
文章标签 mysql 认证 插件 database 访问控制 emq

本文主要是介绍EMQ--添加mysql认证及mysql插件访问控制，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

版权声明：本文为博主原创文章，未经博主允许不得转载。 https://blog.csdn.net/zhen_6137/article/details/81112337

EMQ-百万级分布式开源物联网MQTT消息服务器。

MQTT 认证设置

EMQ 消息服务器认证由一系列认证插件(Plugin)提供，系统支持按用户名密码、ClientID 或匿名认证。

系统默认开启匿名认证(anonymous)，通过加载认证插件可开启的多个认证模块组成认证链:

  1. ----------------           ----------------           ------------
  2. Client --> | Username认证 | -ignore-> | ClientID认证 | -ignore-> | 匿名认证 |
  3. ----------------           ----------------           ------------
  4. |                         |                         |
  5. \|/                       \|/                       \|/
  6. allow | deny              allow | deny              allow | deny

注解

EMQ 2.0 消息服务器还提供了 MySQL、PostgreSQL、Redis、MongoDB、HTTP、LDAP 认证插件。

 1. 首先，当然是禁用匿名认证了，不然你的mqtt服务器任何都可以连接，岂不是很危险。

  进入emqttd安装目录的etc

    

  修改etc目录下的emq.conf文件， vim emq.conf 找到 mqtt.all_anonymous配置项将其置为false

  

2. Mysql插件认证

    通过 MySQL 数据库表认证，可创建如下的 ‘mqtt_user’ 表:

  1. CREATE TABLE `mqtt_user` (
  2.   `id` int(11) unsigned NOT NULL AUTO_INCREMENT,
  3.   `username` varchar(100) DEFAULT NULL,
  4.   `password` varchar(100) DEFAULT NULL,
  5.   `salt` varchar(20) DEFAULT NULL,
  6.   `is_superuser` tinyint(1) DEFAULT 0,
  7.   `created` datetime DEFAULT NULL,
  8. PRIMARY KEY (`id`),
  9.   UNIQUE KEY `mqtt_username` (`username`)
  10. ) ENGINE=MyISAM DEFAULT CHARSET=utf8;

  etc/plugins/emq_auth_mysql.conf 配置 ‘super_query’, ‘auth_query’, ‘password_hash’:

  1. ## Mysql Server 数据库的ip:port
  2. auth.mysql.server = 127.0.0.1:3306
  3.  
  4. ## Mysql Pool Size  池大小
  5. auth.mysql.pool = 8
  6.  
  7. ## Mysql Username  用户名(根据实际情况填写，别问为什么是xxx)
  8. auth.mysql.username =  xxx
  9.  
  10. ## Mysql Password  密码
  11. auth.mysql.password =  xxx
  12.  
  13. ## Mysql Database  数据库实例的名字
  14. auth.mysql.database = mqtt
  15.  
  16. ## Variables: %u = username, %c = clientid
  17.  
  18. ## Authentication Query: select password only
  19. auth.mysql.auth_query = select password from mqtt_user where username = '%u' limit 1
  20.  
  21. ## Password hash: plain, md5, sha, sha256, pbkdf2
  22. ## 密码加密方式 sha256,md5等 也可以加盐 salt,这个稍后细细道来
  23. auth.mysql.password_hash = sha256
  24.  
  25. ## %% Superuser Query
  26. auth.mysql.super_query = select is_superuser from mqtt_user where username = '%u' limit 1

  以上配置项的值根据自身填写。

  需要注意，当你的密码是通过md5+salt加密的时候，需要修改2个配置项

  1. ## Authentication Query: select password only
  2. ## sql语句同时也需将salt查出来，肯定 你事先肯定要存入表中。
  3. auth.mysql.auth_query = select password,salt from mqtt_user where username = '%u' limit 1
  4.  
  5. ## 加密方式为 md5 + salt 盐在密码后
  6. auth.mysql.password_hash = md5,salt

  ok，这样mysql插件 认证搞定。

 

访问控制(ACL)

MQ 消息服务器通过 ACL(Access Control List) 实现 MQTT 客户端访问控制。

ACL 访问控制规则定义:

允许(Allow)|拒绝(Deny) 谁(Who) 订阅(Subscribe)|发布(Publish) 主题列表(Topics)

MQTT 客户端发起订阅/发布请求时，EMQ 消息服务器的访问控制模块，会逐条匹配 ACL 规则，直到匹配成功为止:

  1. ---------              ---------              ---------
  2. Client -> | Rule1 | --nomatch--> | Rule2 | --nomatch--> | Rule3 | --> Default
  3. ---------              ---------              ---------
  4. |                      |                      |
  5. match                  match                  match
  6. \|/                    \|/                    \|/
  7. allow | deny           allow | deny           allow | deny

默认访问控制设置

EMQ 消息服务器默认访问控制，在 etc/emq.conf 中设置:

  1. ## ACL nomatch
  2. mqtt.acl_nomatch = allow
  3.  
  4. ## Default ACL File
  5. mqtt.acl_file = etc/acl.conf

ACL 规则定义在 etc/acl.conf，EMQ 启动时加载到内存:

  1. %% Allow 'dashboard' to subscribe '$SYS/#'
  2. {allow, {user, "dashboard"}, subscribe, ["$SYS/#"]}.
  3.  
  4. %% Allow clients from localhost to subscribe any topics
  5. {allow, {ipaddr, "127.0.0.1"}, pubsub, ["$SYS/#", "#"]}.
  6.  
  7. %% Deny clients to subscribe '$SYS#' and '#'
  8. {deny, all, subscribe, ["$SYS/#", {eq, "#"}]}.
  9.  
  10. %% Allow all by default
  11. {allow, all}.

1. mysql插件的访问控制

 MySQL 插件访问控制，通过 mqtt_acl 表定义 ACL 规则:

  1. CREATE TABLE `mqtt_acl` (
  2.   `id` int(11) unsigned NOT NULL AUTO_INCREMENT,
  3.   `allow` int(1) DEFAULT NULL COMMENT '0: deny, 1: allow',
  4.   `ipaddr` varchar(60) DEFAULT NULL COMMENT 'IpAddress',
  5.   `username` varchar(100) DEFAULT NULL COMMENT 'Username',
  6.   `clientid` varchar(100) DEFAULT NULL COMMENT 'ClientId',
  7.   `access` int(2) NOT NULL COMMENT '1: subscribe, 2: publish, 3: pubsub',
  8.   `topic` varchar(100) NOT NULL DEFAULT '' COMMENT 'Topic Filter',
  9. PRIMARY KEY (`id`)
  10. ) ENGINE=InnoDB DEFAULT CHARSET=utf8;
  11.  
  12. INSERT INTO mqtt_acl (id, allow, ipaddr, username, clientid, access, topic)
  13. VALUES
  14. (1,1,NULL,'$all',NULL,2,'#'),
  15. (2,0,NULL,'$all',NULL,1,'$SYS/#'),
  16. (3,0,NULL,'$all',NULL,1,'eq #'),
  17. (5,1,'127.0.0.1',NULL,NULL,2,'$SYS/#'),
  18. (6,1,'127.0.0.1',NULL,NULL,2,'#'),
  19. (7,1,NULL,'dashboard',NULL,1,'$SYS/#');

 etc/plugins/emq_auth_mysql.conf 配置 ‘acl_query’ 与 ‘acl_nomatch’:

  1. ## ACL Query Command 
  2. ##这个语句 基本不用改动，如果表名为mqtt_acl,字段也相同
  3. auth.mysql.acl_query = select allow, ipaddr, username, clientid, access, topic from mqtt_acl where ipaddr = '%a' or username = '%u' or username = '$all' or clientid = '%c'

 

 

这篇关于EMQ--添加mysql认证及mysql插件访问控制的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/1009162。

相关文章

SQL BETWEEN 的常见用法小结

SQL BETWEEN 的常见用法小结

《SQLBETWEEN的常见用法小结》BETWEEN操作符是SQL中非常有用的工具,它允许你快速选取某个范围内的值,本文给大家介绍SQLBETWEEN的常见用法,感兴趣的朋友一起看看吧... 在SQL中，BETWEEN是一个操作符，用于选取介于两个值之间的数据。它包含这两个边界值。BETWEEN操作符常用
阅读更多...
MySQL索引的优化之LIKE模糊查询功能实现

MySQL索引的优化之LIKE模糊查询功能实现

《MySQL索引的优化之LIKE模糊查询功能实现》：本文主要介绍MySQL索引的优化之LIKE模糊查询功能实现,本文通过示例代码给大家介绍的非常详细,感兴趣的朋友一起看看吧... 目录一、前缀匹配优化二、后缀匹配优化三、中间匹配优化四、覆盖索引优化五、减少查询范围六、避免通配符开头七、使用外部搜索引擎八、分
阅读更多...
MySql match against工具详细用法

MySql match against工具详细用法

《MySqlmatchagainst工具详细用法》在MySQL中,MATCH……AGAINST是全文索引（Full-Textindex）的查询语法,它允许你对文本进行高效的全文搜素,支持自然语言搜... 目录一、全文索引的基本概念二、创建全文索引三、自然语言搜索四、布尔搜索五、相关性排序六、全文索引的限制七
阅读更多...
数据库面试必备之MySQL中的乐观锁与悲观锁

数据库面试必备之MySQL中的乐观锁与悲观锁

《数据库面试必备之MySQL中的乐观锁与悲观锁》：本文主要介绍数据库面试必备之MySQL中乐观锁与悲观锁的相关资料,乐观锁适用于读多写少的场景,通过版本号检查避免冲突,而悲观锁适用于写多读少且对数... 目录一、引言二、乐观锁（一）原理（二）应用场景（三）示例代码三、悲观锁（一）原理（二）应用场景（三）示例
阅读更多...
SQL表间关联查询实例详解

SQL表间关联查询实例详解

《SQL表间关联查询实例详解》本文主要讲解SQL语句中常用的表间关联查询方式,包括：左连接（leftjoin）、右连接（rightjoin）、全连接（fulljoin）、内连接（innerjoin）、... 目录简介样例准备左外连接右外连接全外连接内连接交叉连接自然连接简介本文主要讲解SQL语句中常用的表
阅读更多...
SQL server配置管理器找不到如何打开它

SQL server配置管理器找不到如何打开它

《SQLserver配置管理器找不到如何打开它》最近遇到了SQLserver配置管理器打不开的问题,尝试在开始菜单栏搜SQLServerManager无果,于是将自己找到的方法总结分享给大家,对SQ... 目录方法一：桌面图标进入方法二：运行窗口进入方法三：查找文件路径方法四：检查 SQL Server 安
阅读更多...
MySQL 中的 LIMIT 语句及基本用法

MySQL 中的 LIMIT 语句及基本用法

《MySQL中的LIMIT语句及基本用法》LIMIT语句用于限制查询返回的行数,常用于分页查询或取部分数据,提高查询效率,：本文主要介绍MySQL中的LIMIT语句,需要的朋友可以参考下... 目录mysql 中的 LIMIT 语句1. LIMIT 语法2. LIMIT 基本用法(1) 获取前 N 行数据(
阅读更多...
MySQL 分区与分库分表策略应用小结

MySQL 分区与分库分表策略应用小结

《MySQL分区与分库分表策略应用小结》在大数据量、复杂查询和高并发的应用场景下,单一数据库往往难以满足性能和扩展性的要求,本文将详细介绍这两种策略的基本概念、实现方法及优缺点,并通过实际案例展示如... 目录mysql 分区与分库分表策略1. 数据库水平拆分的背景2. MySQL 分区策略2.1 分区概念
阅读更多...
MySQL高级查询之JOIN、子查询、窗口函数实际案例

MySQL高级查询之JOIN、子查询、窗口函数实际案例

《MySQL高级查询之JOIN、子查询、窗口函数实际案例》：本文主要介绍MySQL高级查询之JOIN、子查询、窗口函数实际案例的相关资料,JOIN用于多表关联查询,子查询用于数据筛选和过滤,窗口函... 目录前言1. JOIN（连接查询）1.1 内连接（INNER JOIN）1.2 左连接（LEFT JOI
阅读更多...
MySQL 中查询 VARCHAR 类型 JSON 数据的问题记录

MySQL 中查询 VARCHAR 类型 JSON 数据的问题记录

《MySQL中查询VARCHAR类型JSON数据的问题记录》在数据库设计中,有时我们会将JSON数据存储在VARCHAR或TEXT类型字段中,本文将详细介绍如何在MySQL中有效查询存储为V... 目录一、问题背景二、mysql jsON 函数2.1 常用 JSON 函数三、查询示例3.1 基本查询3.2
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2