实例管理

云原生消息引擎产品支持创建 MQTT 实例，并支持实例扩容，提升实例的连接数。
MQTT 实例可以为物联网（IoT）应用提供可靠的实时消息传输和设备连接解决方案。

监听器

监听器将根据路由类型、网络信息和协议类型来接受客户端请求。

• 支持创建公网和私网 2 种路由类型的监听器。
• 提供了 TCP、SSL、WS 和 WSS 四种协议类型的监听器，分别适用于不同场景。

用户管理

支持创建用户，用于登录 MQTT Dashboard。
可以根据不同业务部门、不同成员的责任划分创建不同的用户，并为用户分配 Dashboard 的最低访问权限。

• 管理员：拥有 Dashboard 所有功能和资源的完全管理权限。
• 查看者：只能以只读的方式访问 Dashboard 的数据和配置信息。

API密钥

支持创建 API 密钥。创建密钥时将会生成 API Key 和 Secret Key，可以作为访问 REST API 的认证凭证。

监控

Dashboard 提供了较多的监控页面，支持查看看不同的监控指标和统计数据。

• 集群概览：仪表盘页面，支持查看集群概览、节点列表和众多数据指标。
• 客户端：可以查看当前连接的客户端列表，并支持主动断开客户端的连接。
• 订阅管理：可以查看整个 MQTT 集群的订阅列表和主题列表。
• 保留消息：可以查看 MQTT 记录的保留消息列表，支持主动删除保留消息。
• 延迟发布：可以查看正处于延迟发布时间间隔内的消息列表。
• 告警：可以查看当前告警和历史告警。

访问控制

Dashboard 提供了各类访问规则的配置能力。

• 客户端认证：默认允许所有客户端都能连接到 MQTT，但可能存在一些非法客户端。配置客户端认证后，客户端需要配置对应的认证信息，才可以安全连接到 MQTT。您可以选择使用Password-Based、JWT和SCRAM客户端认证方式，快速配置客户端认证授权机制。
• 客户端授权：客户端连接 MQTT 后，您也可以配置客户端授权，控制客户端连接后的发布和订阅操作。
• 黑名单：对于有恶意性或攻击性的客户端连接，您可以通过客户端 ID、用户名和 IP 地址来直接禁用客户端。
• 连接抖动：对于短时间内频繁登录的客户端，支持配置抖动检测，自动封禁抖动客户端。

集成

Dashboard 提供了各类数据系统的集成能力。

• Webhook：使用 Webhook 可以将 MQTT 客户端消息和事件集成到外部 HTTP 服务器。
• Flow 设计器：Flow 设计器是一个功能丰富且易于使用的工具，您可以通过拖拽和连接，轻松创建数据处理流程。有助于高效地处理和集成数据，提高数据管理的可视性和控制性。
• 规则：规则引擎是 MQTT 内置的数据处理功能，通过定义 SQL 语句来处理并筛选来自消息、客户端事件以及外部数据系统的数据，无需编写代码即可实现一站式的 IoT 数据提取、过滤和转换处理，并将处理完成后的数据通过消息发布、打印到控制台或通过 Sink 进行转发。
• 连接器：连接器可以作为 Sink 或 Source 的底层连接通道，用于连接到外部数据系统。
• 编解码：支持 Avro、Protobuf 和 JSON Schema 格式 的消息解码和编码，一般和规则引擎配合使用。

管理

集群配置：支持动态更新 MQTT 集群配置。

• MQTT 配置：可以查看或修改 MQTT 协议相关的配置项，包括通用配置、会话配置、保留消息和系统主题的配置。
• 日志：可以查看或修改日志相关的配置项，包括控制台日志、文件日志、日志限流和审计日志配置。
• 监控：可以查看或修改监控相关的配置项，包括 Erlang 虚拟机和操作系统的配置。

MQTT 高级特性：在发布-订阅模式基础上，提供了很多扩展功能。

• 主题重写：支持主题重写功能，根据用户配置的重写规则在客户端订阅、发布时将原有主题重写为新的目标主题。
• 自动订阅：支持添加自动订阅规则，在设备或客户端成功连接后按照规则为其订阅指定主题，不需要额外发起订阅。
• 延迟发布：支持启用延迟发布功能，可以按照配置的时间间隔延迟发布消息。

问题分析

Dashboard 提供了一些调试工具来帮助调试和定位遇到的错误和问题。

• WebSocket 客户端：一个 WebSocket 客户端测试工具，可用于对客户端进行快速的连接、发布和订阅功能调试，同时还能查看已发送和接收的消息数据。
• 主题监控：支持为目标主题开启主题监控，统计主题的消息收发数量、速率等指标。
• 慢订阅：启用并配置慢订阅参数后，当客户端出现订阅消息时延高的情况时，会将订阅者和主题插入或更新到慢订阅列表中，并按照时延高低对列表进行排序。
• 日志追踪：启用日志追踪后，将根据客户端 ID、主题和 IP 地址追踪 DEBUG 级别日志。

系统设置

• 审计日志：提供审计日志功能，开启后，将实时记录对 MQTT 集群的重要操作变更。
• 备份与恢复：提供备份与恢复功能，保障数据安全。