Password 认证

Password 认证是当前最常用的方式，通过用户名和密码完成客户端身份校验。

配置说明

Password 认证的核心是 authn_type = "password_based"，并在 storage_config 中指定数据源。
如果使用 MySQL，配置结构应与代码中的 MysqlConfig 对齐：

rust

pub struct MysqlConfig {
    pub mysql_addr: String,
    pub database: String,
    pub username: String,
    pub password: String,
    pub query_user: String,
    pub query_acl: String,
    pub query_blacklist: String,
}

字段说明：

mysql_addr：MySQL 地址（如 127.0.0.1:3306）
database：数据库名
username / password：连接账号与密码
query_user：用户同步 SQL（认证核心数据来源）
query_acl：ACL 同步 SQL
query_blacklist：黑名单同步 SQL

也就是说，Password 认证并不强制你使用固定表结构，只要求查询结果能映射到系统约定字段。

当前支持的数据源包括：

内置数据源（Meta Service）
MySQL
PostgreSQL
Redis
HTTP

数据源的具体参数请参考：

使用说明

在 Broker 配置中启用 password_based 认证；
根据选定数据源完成配置；
客户端连接时携带 username/password；
认证通过后进入会话、订阅、发布等后续流程。

示例（概念示例）

toml

[[mqtt.auth]]
authn_type = "password_based"

[mqtt.auth.config.storage_config]
storage_type = "mysql"

[mqtt.auth.config.storage_config.mysql_config]
mysql_addr = "127.0.0.1:3306"
database = "mqtt"
username = "root"
password = "123456"
query_user = "SELECT username AS username, password AS password, salt AS salt, is_superuser AS is_superuser, created AS created FROM user_table"
query_acl = "SELECT permission AS permission, ipaddr AS ipaddr, username AS username, clientid AS clientid, access AS access, topic AS topic FROM acl_table"
query_blacklist = "SELECT blacklist_type AS blacklist_type, resource_name AS resource_name, end_time AS end_time, `desc` AS `desc` FROM blacklist_table"

注意事项

生产环境建议关闭免密模式；
密码校验属于高频路径，建议保持缓存命中率；
数据源中的查询字段和类型需与系统约定一致。

Password 认证 ​

配置说明 ​

使用说明 ​

示例（概念示例） ​

注意事项 ​

Password 认证

配置说明

使用说明

示例（概念示例）

注意事项