基于 MongoDB 进行授权

EMQX 支持通过集成 MongoDB 进行授权验证，即可以将客户端的权限列表存储在 MongoDB 数据库中。

前置准备

熟悉 EMQX 授权基本概念

数据结构与查询语句

MongoDB 认证器支持将权限数据存储为 MongoDB 文档。用户需要提供一个查询语句模板，且确保查询结果包含以下字段：

• permission: 用于指定操作权限，可选值有 allow 和 deny。
• action: 用于指定当前规则适用于哪些操作，可选值有 publish、subscribe 和 all。
• topics: 用于指定当前规则适用的主题列表，可以使用主题过滤器和主题占位符。
• qos:（可选）用于指定当前规则适用的消息 QoS，可选值有 0、1、2，也可以使用数字数组同时指定多个 QoS。默认为所有 QoS。
• retain: （可选）用于指定当前规则是否支持发布保留消息，可选值有 0、1，或 true、false。默认允许保留消息。

禁止用户名为 emqx_u 的客户端发布主题为 t/1 且 QoS 值为 1 的消息:

> db.mqtt_acl.insertOne(
  {
      "username": "emqx_u",
      "clientid": "emqx_c",
      "ipaddress": "127.0.0.1",
      "permission": "deny",
      "action": "publish",
      "qos": 1,
      "topics": ["t/1"]
  }
);
{
  acknowledged: true,
  insertedId: ObjectId("62b4a1a0e693ae0233bc3e98")
}

相应的配置参数如下：

collection = "mqtt_acl"
filter { username = "${username}" }

TIP

当系统中有大量用户时，请确保查询使用的集合已优化并使用有效的索引，以提升大量发布订阅时的数据查找速度并降低 EMQX 负载。

配置项

此认证器支持 3 种部署模式的 MongoDB。

MongoDB Authorizer 必需有 type = mongodb。

有三种不同的连接模式：

Standalone：

{
  type = mongodb
  enable = true

  collection = "mqtt_user"
  filter { username = "${username}" }

  mongo_type = single
  server = "127.0.0.1:27017"

  database = "mqtt"
  username = "emqx"
  password = "secret"
}

ReplicaSet：

{
  type = mongodb
  enable = true

  collection = "mqtt_user"
  filter { username = "${username}" }

  mongo_type = rs
  servers = "10.123.12.10:27017,10.123.12.11:27017,10.123.12.12:27017"
  replica_set_name = "rs0"

  database = "mqtt"
  username = "emqx"
  password = "secret"
}

Sharded Cluster：

{
  type = mongodb
  enable = true

  collection = "mqtt_user"
  filter { username = "${username}" }

  mongo_type = sharded
  servers = "10.123.12.10:27017,10.123.12.11:27017,10.123.12.12:27017"

  database = "mqtt"
  username = "emqx"
  password = "secret"
}

collection

必填字段，指定 MongoDB 中用于存储授权信息的 Collection。

filter

用于指定 MongoDB 查询时使用哪些字段进行过滤。 这些字段名称没有限制，值可以使用以下这些占位符:

• ${clientid} — 客户端 ID
• ${username} — 客户端登录时使用的用户名
• ${peerhost} — 客户端的源 IP 地址

database

指定在哪个 MongoDB 数据库中查询授权数据。

username

指定访问 MongoDB 数据库时使用的用户名。

password

指定访问 MongodDB 数据库时使用的密码。

pool_size

指定 MongoDB 的连接池的大小。默认值是 8。

ssl

SSL 客户端参数。

srv_record

可选的布尔类型参数。默认是 false 。该配置设置成 true 时，EMQX 会从 DNS 记录中查找指定的 MongoDB 地址和端口。

详情请参考 DNS Seed List Connection Format.

topology

指定 MongDB 连接参数的更多字段。

• pool_size — 连接池大小。
• max_overflow — 当连接池中所有的连接都忙时，可以额外创建的连接数上限。
• overflow_ttl — 额外创建的连接允许存活的时间。
• overflow_check_period — 时间间隔（毫秒），用于指定间隔多久做一次 overflow_ttl 的检查。
• connect_timeout_ms — 时间间隔（毫秒），用于指定连接初始化最长的等待时间。
• server_selection_timeout_ms — 时间间隔（毫秒），用于指定发现一个MongoDB服务器的时间。

MongoDB 单机模式

server

MongoDB 服务器的 FQDN 或者 IP 地址和端口号

w_mode

该配置在授权中用不到。

MongoDB ReplicaSet模式

servers

必选的字符串类型配置，用逗号分隔，指定用于连接或被用作 seeds 的 MongoDB 服务器地址列表。

w_mode

该配置在授权中用不到。

r_mode

指定读模式，默认为 master。 设置为 master 时，所有的读操作都会返回最新的数据。如果连接的服务器不是主节点，那么读取将会失败。 设置为 slave_ok 时，如果连接到的 MongoDB 是一个备节点，则可能会读到过期的数据。

replica_set_name

MongoDB 的 Replica set 名称，此参数为必填项。但在 srv_record 设置为 true 时，可能会被发现的信息覆写。

MongoDB Cluster 模式

servers

必填字段，用于指定可用于连接的所有 MongoDB 服务器的 FQDN 和端口号，使用逗号分隔。

w_mode

该配置在授权中用不到。