使用 MySQL 进行密码认证

作为密码认证方式的一种，EMQX 支持通过集成 MySQL 进行密码认证。

前置准备

熟悉 EMQX 认证基本概念

SQL 表结构与查询语句

MySQL 认证器可以支持任何表结构，甚至是多个表联合查询、或从视图中查询。用户需要提供一个查询 SQL 模板，且确保查询结果包含以下字段：

• password_hash: 必需，数据库中的明文或散列密码字段
• salt: 可选，为空或不存在时视为空盐（salt = ""）
• is_superuser: 可选，标记当前客户端是否为超级用户，默认为 false

示例表结构：

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;

TIP

上面的示例创建了一个有助于查询的隐式 UNIQUE 索引字段（ username ）。当系统中有大量用户时，请确保查询使用的表已优化并使用有效的索引，以提升大量连接时的数据查找速度并降低 EMQX 负载。

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

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

mysql> INSERT INTO mqtt_user(username, password_hash, salt, is_superuser) VALUES ('emqx_u', SHA2(concat('public', 'slat_foo123'), 256), 'slat_foo123', 1);
Query OK, 1 row affected (0,01 sec)

对应的查询语句和密码散列方法配置参数为：

• 密码加密方式：sha256
• 加盐方式：suffix
• SQL：

SELECT password_hash, salt, is_superuser FROM mqtt_user WHERE username = ${username} LIMIT 1

通过 Dashboard 配置

在 EMQX Dashboard 页面上点击左侧导航栏的访问控制 -> 客户端认证，在随即打开的客户端认证页面，单击**+ 创建**，依次选择认证方式为 Password-Based，数据源为 MySQL，点击下一步进入配置参数页签：

您可按照如下说明完成相关配置：

连接： 在此部分完成到 MySQL 数据库的连接设置。

• 服务：填入 MySQL 服务器地址 (host:port) 。
• 数据库：填入 MySQL 的数据库名称。
• 用户名（可选）：填入用户名称。
• 密码（可选）：填入用户密码。

TLS 配置：配置是否启用 TLS。

连接配置：在此部分设置并发连接以及连接超时等待时间。

• Pool size（可选）：填入一个整数用于指定从 EMQX 节点到 MySQL 数据库的并发连接数；默认值：8。
• 查询超时：填入连接超时等待时长，可选单位：小时、分钟、秒、毫秒。

认证配置：在此部分进行认证加密算法相关的配置。

• 密码加密方式：选择应用于明文密码的哈希算法，用于在将结果存储到数据库之前对密码进行加密。可用选项包括 plain、md5、sha、sha256、sha512、bcrypt 和 pbkdf2。具体配置取决于所选择的算法：

  • 选择 md5、sha、sha256 或 sha512算法，需配置：

    • 加盐方式：用于指定盐和密码的组合方式，可选值：suffix（在密码尾部加盐）、prefix（在密码头部加盐）、disable（不启用）。如果无需从外部存储迁移用户凭据到 EMQX 内置数据库，可以保持默认值。
    • 生成的哈希以十六进制字符串形式表示，并与存储的凭据进行不区分大小写的比对。

  • 选择 plain：

    • 加盐方式：应设置为 disable。

  • 选择 bcrypt 算法，需配置:

    • Salt Rounds：指定散列需要的计算次数（2^Salt Rounds），也称成本因子。默认值：10，可选值：5 到 10；数值越高，加密的安全性越高，因此建议采用较大的值，但相应的用户验证的耗时也会增加，您可根据业务需求进行配置。

  • 选择 pbkdf2 算法，需配置：

    • 伪随机函数：指定生成密钥使用的散列函数，如 sha256 等。
    • 迭代次数：指定散列次数，默认值：4096。
    • 密钥长度（可选）：指定希望得到的密钥长度。如不指定，密钥长度将由伪随机函数确定。
    • 生成的哈希以十六进制字符串形式表示，并与存储的凭据进行不区分大小写的比对。

• SQL：根据表结构填入查询 SQL，具体要求见 SQL 表结构与查询语句。

点击创建完成相关配置。

通过配置文件配置

您也可以通过配置文件完成以上配置。

{
  backend = "mysql"
  mechanism = "password_based"

  server = "127.0.0.1:3306"
  username = "root"
  database = "mqtt_user"
  password = ""
  pool_size = 8

  password_hash_algorithm {name = "sha256", salt_position = "suffix"}
  query = "SELECT password_hash, salt FROM mqtt_user where username = ${username} LIMIT 1"
  query_timeout = "5s"
}