emqx mysql_基于 MySQL 的 EMQ X Auth & ACL

╰+攻爆jí腚メ 2022-10-26 15:25 18阅读 0赞

在阅读该教程之前，假定你已经了解 MQTT、MQTT 5 以及 EMQ X 的简单知识。

emqx-auth-mysql 它通过检查每个终端接入的 username 和 password 是否与用户指定 的 MySQL 数据库中存储的信息一致来实现对终端的访问控制。其功能逻辑如下：

![9ba387a4f10c588580a6962a7f7ac2b8.png][]

本文假设 MySQL 已经安装在您的机器上，并且您可以连接到 MySQL 服务器。注：EMQ X 开源版至 v3.1-beta.2 为止，尚不支持 MySQL 8.0，因此以下内容仅适用于 MySQL 5.7 及以下版本。

$ mysql --version

mysql Ver 14.14 Distrib 5.7.25, for macos10.14 (x86\_64) using EditLine wrapper

插件配置项说明

mqtt.sql

emqx-auth-mysql 提供了 mqtt.sql 文件帮助用户快速创建数据表以及导入默认数据。mqtt.sql 将会为 mqtt\_acl 数据表导入以下默认规则：

mysql> select \* from mqtt\_acl;

\+----+-------+-----------+-----------+----------+--------+--------+

\+----+-------+-----------+-----------+----------+--------+--------+

| 1 | 1 | NULL | $all | NULL | 2 | \# |

| 2 | 0 | NULL | $all | NULL | 1 | $SYS/\# |

| 3 | 0 | NULL | $all | NULL | 1 | eq \# |

| 4 | 1 | 127.0.0.1 | NULL | NULL | 2 | $SYS/\# |

| 5 | 1 | 127.0.0.1 | NULL | NULL | 2 | \# |

| 6 | 1 | NULL | dashboard | NULL | 1 | $SYS/\# |

\+----+-------+-----------+-----------+----------+--------+--------+

6 rows in set (0.00 sec)

allow - 1: allow; 0: deny

access - 1: subscribe; 2: publish; 3: publish and subscribe

以上规则分别表示：

允许任何用户发布除以 '$' 字符开头以外的任何主题的消息

拒绝任何用户订阅任何以 "$SYS/" 开头的主题

拒绝任何用户订阅 "\#" 主题

允许本机用户发布任何以 "$SYS/" 开头的主题

允许本机用户发布发布除以 '$' 字符开头以外的任何主题的消息

允许 dashboard 用户订阅任何以 "$SYS/" 开头的主题

除此之外，用户可以导入自定义的 ACL 规则。

Auth 与 ACL 功能验证

Mac 环境安装 mosquitto

brew install mosquitto

创建数据库，导入数据

mqtt.sql 路径可根据实际情况自行改动

mysql> create database mqtt;

mysql> use mqtt;

mysql> source ./emqx\_auth\_mysql/mqtt.sql

mysql> insert into mqtt\_user (id, is\_superuser, username, password, salt)

\-> values (1, false, 'test', 'password', 'salt');

mysql> insert into mqtt\_acl (id, allow, ipaddr, username, clientid, access, topic)

\-> values (7, 0, NULL, 'test', NULL, 1, 'mytopic');

mysql> exit;

修改配置文件

禁止匿名访问：

\#\# .../etc/emqx.conf

allow\_anonymous = false

配置数据库中密码的加密方式为 plain ，即不加密：

\#\# .../etc/plugins/emqx\_auth\_mysql.conf

auth.mysql.password\_hash = plain

配置要访问的数据库以及用户名密码：

\#\# .../etc/plugins/emqx\_auth\_mysql.conf

auth.mysql.username = root

auth.mysql.password = public

auth.mysql.database = mqtt

启动 EMQ X 与 emqx-auth-mysql

$ ./\_rel/emqx/bin/emqx start

emqx 3.1 is started successfully!

$ ./\_rel/emqx/bin/emqx\_ctl plugins load emqx\_auth\_mysql

测试

使用正确的用户名和密码进行连接，并订阅 "topic" 主题

$ mosquitto\_sub -p 1883 -u test -P password -t 'topic' -d

Client mosqsub|91114-zhouzibod sending CONNECT

Client mosqsub|91114-zhouzibod received CONNACK

Client mosqsub|91114-zhouzibod sending SUBSCRIBE (Mid: 1, Topic: topic, QoS: 0)

Client mosqsub|91114-zhouzibod received SUBACK

Subscribed (mid: 1): 0

现象：连接并订阅成功

使用错误的用户名或密码进行连接，并订阅 "topic" 主题

$ mosquitto\_sub -p 1883 -u bad\_user -P password -t 'topic' -d

Client mosqsub|91136-zhouzibod sending CONNECT

Client mosqsub|91136-zhouzibod received CONNACK

Connection Refused: not authorised.

现象：连接被拒绝

使用正确的用户名和密码进行连接，并订阅 "\#" 主题

$ mosquitto\_sub -p 1883 -u test -P password -t '\#' -d

Client mosqsub|11257-zhouzibod sending CONNECT

Client mosqsub|11257-zhouzibod received CONNACK

Client mosqsub|11257-zhouzibod sending SUBSCRIBE (Mid: 1, Topic: \#, QoS: 0)

Client mosqsub|11257-zhouzibod received SUBACK

Subscribed (mid: 1): 128

现象：连接成功，订阅失败，原因码128

使用正确的用户名和密码进行连接，并订阅 "mytopic" 主题

$ mosquitto\_sub -p 1883 -u test -P password -t 'mytopic' -d

Client mosqsub|13606-zhouzibod sending CONNECT

Client mosqsub|13606-zhouzibod received CONNACK

Client mosqsub|13606-zhouzibod sending SUBSCRIBE (Mid: 1, Topic: mytopic, QoS: 0)

Client mosqsub|13606-zhouzibod received SUBACK

Subscribed (mid: 1): 128

现象：连接成功，订阅失败，原因码128

[9ba387a4f10c588580a6962a7f7ac2b8.png]: /images/20221024/485f6f2fec60406ab06e4d6c1f0cf151.png

emqx mysql_基于 MySQL 的 EMQ X Auth & ACL

发表评论取消回复

还没有评论，来说两句吧...

相关阅读

相关 EMQ X 简介

相关 EMQ X 入门教程——导读

相关 EMQ api访问失败 api/v4/auth_clientid / URL Not Found

相关项目实战-物联网平台搭建-EMQ x数据转存mysql（二）

相关 EMQ X 入门教程基础篇②——EMQ-X 消息存储到数据库的四种方法

相关 vsftpd基于mysql_vsftpd 基于mysql的虚拟账户

相关 MySQL基于DMG文件安装Mac OS X

相关 MySql5.x升级MySql8.x的方法步骤

相关 emqx mysql_基于 MySQL 的 EMQ X Auth & ACL

相关 EMQ源码之--EMQ的启动