MQTT 服务端转发

启动内置 MQTT Server，向已连接客户端发布变量、设备、报警和插件事件，并按权限处理变量 RPC 写入和历史读取请求。

转发组范围、触发、分批、缓存和启停见数据转发。本页只说明监听、TLS、客户端限制、Topic、RPC、模板和服务端调试。

功能入口

进入“开发配置 → 数据转发”，按以下顺序配置：

1. 保存转发组范围、触发、定时间隔、在线过滤和批处理策略。
2. 新增目标，选择“MQTT 服务端转发”，填写目标基本信息。
3. 打开“目标属性”，配置监听、安全认证、消息主题、脚本、模板和缓存。
4. 保存并启用目标，用测试 MQTT 客户端连接后再打开“目标调试”。

目标基本信息

目标属性

监听与安全

消息与 RPC

方法协议按被调用设备或目标的“允许方法调用”开关执行，不要求绑定变量，也不配置逐方法白名单。请求禁止 Retain，方法入口不额外设置载荷大小上限；MQTT 协议和服务端报文配置仍生效。主题不能与变量、历史或快照请求及响应重叠。连接身份继续使用本目标的认证，示例和结果处理见插件方法调用。

验证连接与发布

先用一个在线变量、固定变量 Topic 和定时触发完成订阅。外部客户端使用唯一 Client ID 连接，核对服务端列表中的远端地址和身份，再改变现场值，检查同一主题的新变量、质量和时间。

“允许连接ID前缀”匹配 CONNECT 中的客户端 ID，与用户名、设备名和 IP 无关；更改后重新连接验证。用户名密码也在 CONNECT 阶段校验，正确凭据与符合前缀两项都要满足。客户端普通发布只在 Broker 中分发，不会自动改写现场变量。

WebSocket 客户端使用 ws://主机:端口/路径，SSL 开启后使用 wss://...。路径只控制 HTTP 升级入口，不是 MQTT Topic。TLS 服务端需带私钥的服务身份。保持默认关闭“允许不受信任证书”时，还需为客户端证书建立信任，并由客户端出示私钥身份；没有客户端证书的连接会失败。客户端仍需验证服务名称和签发链，MQTT 用户名密码也单独校验。SSL协议版本=None 由系统选择 TLS，并不关闭加密；Default 是旧协议集合，不能当作系统自动选择。开启吊销检查前确保有可用吊销信息。

QoS 以实际发布和订阅共同允许的等级为准。QoS 1 可重复，QoS 2 的协议交付保证也不能扩大为现场写入或数据库业务只执行一次。Retain 在线标志、主题最后值存储和失败缓存分别评估；当前内置服务没有迟订阅保留重放，零字节 Retain 发布也不能被描述为删除了已保存主题。

快照、写入与历史读取

请求当前快照

1. 配置专用“数据请求Topic”，客户端先订阅数据 Topic 及完成响应路径。
2. 生成唯一的 32 位小写十六进制编号，向数据请求 Topic 发布：

{"Source":"TGateway","RequestId":"6e8c1a7445064ad6b4bb5d5af9cf28b1"}

3. 核对组内变量、设备和报警快照，只会发送已经配置的模型。
4. 在 数据请求Topic/Response/6e8c1a7445064ad6b4bb5d5af9cf28b1 收取 {"RequestId":"6e8c1a7445064ad6b4bb5d5af9cf28b1","Success":true}。数据正文与结束标记分别核对。

改变请求 Topic 不会改变变量发布 Topic。使用本次唯一编号和新接收窗口判断结果，不要只从周期消息中找一个相同值。

写入现场变量

向 RPC写入Topic/请求编号 发布按设备名、变量名组织的对象：

{"Demo_Modbus_Device":{"Demo_Modbus_Value":1700}}

在 RPC写入Topic/请求编号/Response 逐变量核对结果，再确认现场回读、采集值及订阅消息一致。关闭目标变量“允许RPC写入”后，同样请求应被拒绝，现场原值保持不变；源变量及设备权限仍然生效。

绑定 MQTT 动态 RPC 脚本时，自定义业务字段由脚本转换，再通过标准写入入口执行。清空脚本恢复默认字典契约；脚本编译存在不表示目标已使用它。完整协议和开发入口见反向写入与 RPC。

读取已有历史

历史请求使用独立前缀，发到 历史读取RPC Topic/请求编号，正文编号必须相同：

{"requestId":"6e8c1a7445064ad6b4bb5d5af9cf28b1","operation":"targets","responseChunkBytes":4096,"input":null}

响应位于 历史读取RPC Topic/请求编号/Response。检查成功状态，按 chunkIndex 收齐 chunkCount 块，各块 Base64 解码后顺序拼接，再 gzip 解压并解析 JSON。targets 返回空列表也可能是有效结果，它只表示当前没有可查询 provider。

先创建历史存储并形成两个不同样本，再枚举稳定目标名，使用 numberRecords 查询分页或 series 的 Raw 序列，填写真实变量 ID 与 UTC 时间窗口。上传分片、响应字节分块和历史查询分页是三个不同参数；原始序列与聚合查询也应分别核对。

目标变量属性

变量必须已在转发组范围内；新增目标变量属性不会把变量加入转发组。

该插件还继承通用 数据1～数据10 预留文本字段，默认为空，不会自动进入消息；需要由实体脚本读取并输出，再参与模板。

消息、模板与缓存

数据与脚本

JSON、列表、字典和四类实体脚本的默认值及作用见公共上传参数。

公共模板不会改变服务端的 Topic、身份认证、快照或 RPC 规则；这些行为以本页为准。

上传模板字段

在“上传模板配置”中选择对应实体；字段清单、模板语法与外层结构统一在公共手册维护。预览后保存目标，再看独立订阅端的新消息。

缓存与容量

没有订阅客户端时服务端仍可能成功发布，因此客户端断开不等于发送失败，也不会自动形成每客户端离线邮箱。缓存只在真实失败及配置保留条件下补发；使用离线期间不同旧值验证，不能只看服务在线。容量按缓存模型分别限制，增加上限不能找回已经淘汰的数据。验证步骤见离线缓存与补传。

目标调试

进入“开发配置 → 数据转发”，选择 MQTT 服务端目标，打开“调试 → 协议调试 · MqttServer”。

服务端调试

发布消息

状态监控

断开客户端会立即中断其连接，执行前必须确认客户端身份和影响范围。

手工发布使用输入的 Topic、UTF-8 原文、QoS 和 Retain，独立客户端应收到唯一标记，现场变量保持原值。客户端和主题列表分别有搜索、排序及分页；搜索不会建立或删除订阅，主题订阅数也不是累计发布次数。踢出只关闭当前会话，不修改账号和 ID 前缀，允许的客户端仍可重新连接。

验证方法

1. 启用目标，确认 Listener 已启动。
2. 使用允许的 Client ID 和凭据连接测试 MQTT 客户端。
3. 订阅变量 Topic，让一个转发范围内的测试变量产生新值。
4. 核对 Topic、正文、QoS、Retain 和消息条数。
5. 需要 RPC 时，再单独核对请求 Topic、响应 Topic 和变量权限。

常见问题

相关操作

• 数据转发：配置转发组、触发、缓存和公共目标操作。
• 证书管理：维护 MQTT 服务端证书和 CA。
• 插件索引：查找其它采集或数据转发插件。