FMQ 集成连接器

先理解连接器和任务的职责，再完成双向 RabbitMQ 连接配置；按需要查阅其他协议参数及排障方法。

阅读方法

先确认入口、权限和目标对象，再按编号完成操作。每一步都包含预期结果；详细字段和选项收在可展开的参考表中。

截图说明

截图来自原始操作手册。公开版会隐藏真实节点地址、连接地址和凭据；示例中的状态、时间和数据不代表当前生产环境。

开始前准备

项目	说明
能做什么	配置 FMQ 与外部系统之间的连接，为消息推送和指令下行任务提供连接资源。
从哪里进入	集成 → 连接器
需要权限	连接器查看、配置、测试权限及外部系统对接资料。
预计时间	30 分钟

连接器概述

连接器是 FMQ 对接外部系统时使用的连接组件。它集中保存服务器地址、账号、认证和通信参数，让后续任务不用反复填写同一套对接资料。

例如，温度传感器的数据需要发送给使用 RabbitMQ 的业务系统时，先建立 RabbitMQ 连接器，再由消息推送任务决定发送哪些温度数据。外部系统要下发开关命令时，由指令下行任务使用另一套下行参数接收命令并交给平台处理。

连接器准备的是通信条件，不等于已经开始传送业务消息。是否发送数据、订阅哪个来源、把命令交给哪台设备，分别由消息推送和指令下行任务决定。

组成与选择

先用能力决定方向：只把数据给外部系统，选择消息推送；只接收外部命令，选择指令下行；两件事都需要时，选择双向。双向不是一份参数同时适用于两边，而是同一种连接类型下的两套独立参数。

再用连接类型匹配对方系统：Kafka 看 Broker 与生产/消费规划，RabbitMQ 看交换机、队列和路由键，RocketMQ 看 NameServer、组和 Topic，MQTT 看 Broker 与 Topic，WebHook 或 HTTP 看调用方向、入口和鉴权。

推荐模式先选后填环境资料。模式用于设置可靠性、批量、确认和恢复等可调参数；主机、端口、账号、密码、vhost、队列和 Topic 仍必须向对接方取得，不能把页面示例当成生产值。

连接器组成与操作

字段	用途	值从哪里来	怎么选择	填错表现与恢复	生效条件
必填 连接器名称	给连接资源命名，便于任务选择与运维定位；应区分生产和测试环境；作用于当前连接器，任务启用与业务结果需另行确认。	由当前业务用途、外部系统对接资料及平台页面确定。	给连接资源命名，便于任务选择与运维定位；应区分生产和测试环境。推荐：按对接资料填写默认：—示例：FastBee_双向连接	配置变更可能影响引用它的任务；保留原配置，修正后复测。	范围：当前连接器及引用它的任务发布：不需要 · 重启：不需要 · 重连：不需要
必填 能力	消息推送用于平台向外发送数据；指令下行用于接收外部指令。可启用一种或两种能力，每种最多一套参数；作用于当前连接器，任务启用与业务结果需另行确认。	由当前业务用途、外部系统对接资料及平台页面确定。	消息推送用于平台向外发送数据；指令下行用于接收外部指令。可启用一种或两种能力，每种最多一套参数。推荐：按对接资料填写默认：—示例：—消息推送：平台发送到外部系统；显示 Producer 或发布参数，供消息推送任务引用。指令下行：外部指令进入平台；显示 Consumer、订阅或入口参数，供下行任务引用。	配置变更可能影响引用它的任务；保留原配置，修正后复测。	范围：当前连接器及引用它的任务发布：不需要 · 重启：不需要 · 重连：不需要
必填 连接类型	按外部系统实际使用的协议选择。同一连接器使用一种类型，两条能力的参数分别维护；作用于当前连接器，任务启用与业务结果需另行确认。	由当前业务用途、外部系统对接资料及平台页面确定。	按外部系统实际使用的协议选择。同一连接器使用一种类型，两条能力的参数分别维护。推荐：按对接资料填写默认：—示例：—Kafka：对方已经使用 Kafka，且约定了 Topic 与消费方式时选择；分别展示该类型的上行与下行配置。RabbitMQ：对方用交换机、路由键和队列组织消息时选择 RabbitMQ；分别展示该类型的上行与下行配置。RocketMQ：对方已使用 RocketMQ，并提供 NameServer、组名及 Topic 规划时选择；分别展示该类型的上行与下行配置。MQTT：对方提供 MQTT Broker，双方按 Topic 发布、订阅时选择；分别展示该类型的上行与下行配置。WebHook：上行是平台调用对方回调地址；下行则是对方调用平台入口。先分清谁调用谁；分别展示该类型的上行与下行配置。HTTP：外部系统主动调用平台接口下发指令时选择，当前仅有下行能力；仅支持下行入口。	切换类型会重新初始化两套参数；先选类型，再选模式，最后填写环境值。	范围：当前连接器及引用它的任务发布：不需要 · 重启：不需要 · 重连：不需要
当前通道	点击下方消息推送或指令下行卡片，切换正在编辑的参数；它与上方是否启用该能力不同；作用于当前连接器，任务启用与业务结果需另行确认。	由当前业务用途、外部系统对接资料及平台页面确定。	点击下方消息推送或指令下行卡片，切换正在编辑的参数；它与上方是否启用该能力不同。推荐：按对接资料填写默认：—示例：—	配置变更可能影响引用它的任务；保留原配置，修正后复测。	范围：当前连接器及引用它的任务发布：不需要 · 重启：不需要 · 重连：不需要
推荐模式	一组适配场景的参数预设；先选模式，再填地址与认证。不是安装中间件或性能保证；作用于当前连接器，任务启用与业务结果需另行确认。	由当前业务用途、外部系统对接资料及平台页面确定。	一组适配场景的参数预设；先选模式，再填地址与认证。不是安装中间件或性能保证。推荐：按对接资料填写默认：—示例：—	重新应用模式会覆盖当前通道的已知参数；重新核对地址、认证和通道名，再测试。	范围：当前连接器及引用它的任务发布：不需要 · 重启：不需要 · 重连：不需要
连接状态	状态须结合最近检查时间理解。“已就绪”是必填齐全；“已连通”是相应检查通过，不能等同业务接收成功；作用于当前连接器，任务启用与业务结果需另行确认。	来自最近一次连接检查与平台加载的数据。	先看检查时间，再核对具体反馈；参数变更后重新测试。推荐：按对接资料填写默认：—示例：—	配置变更可能影响引用它的任务；保留原配置，修正后复测。	范围：当前连接器及引用它的任务发布：不需要 · 重启：不需要 · 重连：不需要
引用任务	说明当前资源被哪些任务使用。变更前核对影响范围；解除引用后才能删除；作用于当前连接器，任务启用与业务结果需另行确认。	平台关联任务统计。	无引用也应先核对用途；存在引用时先联系任务负责人。推荐：按对接资料填写默认：—示例：—	配置变更可能影响引用它的任务；保留原配置，修正后复测。	范围：当前连接器及引用它的任务发布：不需要 · 重启：不需要 · 重连：不需要
参数校验 / 测试全部通道	单向检查当前能力，双向分别检查两个能力，必须逐条核对结果。保存按钮可点击不代表已通过测试；作用于当前连接器，任务启用与业务结果需另行确认。	由当前业务用途、外部系统对接资料及平台页面确定。	单向检查当前能力，双向分别检查两个能力，必须逐条核对结果。保存按钮可点击不代表已通过测试。推荐：按对接资料填写默认：—示例：—	RabbitMQ 可能声明和绑定资源；RocketMQ 下行可能消费消息；WebHook 推送会调用外部接口；只在获准隔离资源上测试，按协议边界阅读结果，失败后修正同一连接配置。	范围：当前连接器及引用它的任务发布：不需要 · 重启：不需要 · 重连：不需要
保存连接器	将配置保存为任务可引用的连接资源。双向涉及两次保存；不能仅凭一次提示推断任务已运行；作用于当前连接器，任务启用与业务结果需另行确认。	由当前业务用途、外部系统对接资料及平台页面确定。	将配置保存为任务可引用的连接资源。双向涉及两次保存；不能仅凭一次提示推断任务已运行。推荐：按对接资料填写默认：—示例：—	新建或参数改变后检查状态可能重置；双向部分保存失败需要分别核对；先查已保存资源，再做保存后能力测试，避免重复创建。	范围：当前连接器及引用它的任务发布：不需要 · 重启：不需要 · 重连：不需要
修改与任务重启	运行参数改变后，相关已启用任务需重启读取新配置；停用任务不应自动启动；作用于当前连接器，任务启用与业务结果需另行确认。	由当前业务用途、外部系统对接资料及平台页面确定。	运行参数改变后，相关已启用任务需重启读取新配置；停用任务不应自动启动。推荐：按对接资料填写默认：—示例：—	重启期间可能短暂影响消息处理；安排维护窗口，分别检查重启失败的任务并恢复原配置。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：不需要
补充参数 / 移除 / 高级配置	补充参数将可选项加入表单；移除删除当前可选项；高级 JSON 仅修改当前通道；作用于当前连接器，任务启用与业务结果需另行确认。	由当前业务用途、外部系统对接资料及平台页面确定。	补充参数将可选项加入表单；移除删除当前可选项；高级 JSON 仅修改当前通道。推荐：按对接资料填写默认：—示例：—	错误 JSON 或删除必要约束可能导致无法测试或行为改变；保留原参数，修正 JSON；恢复推荐后重新核对环境值。	范围：当前连接器及引用它的任务发布：不需要 · 重启：不需要 · 重连：不需要
搜索、筛选与刷新	按名称、类型、能力或错误文字搜索，再按异常或未引用等条件筛选；刷新重新获取列表；作用于当前连接器，任务启用与业务结果需另行确认。	由当前业务用途、外部系统对接资料及平台页面确定。	按名称、类型、能力或错误文字搜索，再按异常或未引用等条件筛选；刷新重新获取列表。推荐：按对接资料填写默认：—示例：—	配置变更可能影响引用它的任务；保留原配置，修正后复测。	范围：当前页面查询条件发布：不需要 · 重启：不需要 · 重连：不需要
复制连接器	以现有配置准备一个独立连接资源，修改名称和目标后再保存。复制不代表新目标已经连通；作用于当前连接器，任务启用与业务结果需另行确认。	由当前业务用途、外部系统对接资料及平台页面确定。	以现有配置准备一个独立连接资源，修改名称和目标后再保存。复制不代表新目标已经连通。推荐：按对接资料填写默认：—示例：—	配置变更可能影响引用它的任务；核对新名称、两套参数与认证，重新测试，不覆盖原连接器。	范围：当前连接器及引用它的任务发布：不需要 · 重启：不需要 · 重连：不需要
删除连接器	仅删除明确不再使用且无任务引用的资源。不是暂停消息任务的替代操作；作用于当前连接器，任务启用与业务结果需另行确认。	由当前业务用途、外部系统对接资料及平台页面确定。	仅删除明确不再使用且无任务引用的资源。不是暂停消息任务的替代操作。推荐：按对接资料填写默认：—示例：—	删除后不能继续绑定；双向资源需核对两个方向均已处理；有引用时取消删除，先解除引用；误删恢复须重新建立并验证连接配置。	范围：当前连接器及引用它的任务发布：不需要 · 重启：不需要 · 重连：不需要

双向 RabbitMQ 实战

本实战只完成连接器级别的双向配置、参数校验、保存和保存后复测。不包含任务启用、业务消息收发或设备实际执行验证。

• 共享资料：FMQ 服务器可访问的主机、AMQP 端口、账号、密码和 vhost。
• 上行资料：交换机及与消息推送任务配套的发布路由约定。
• 下行资料：消费队列、关联交换机、绑定路由键和资源维护权限。
• 自动声明交换机、队列或绑定可能改变 MQ 资源；先与管理员确认是否允许。

1. 进入连接器列表

操作位置： 集成→连接器

打开 集成 → 连接器，先查名称、状态和引用任务。

图：已进入连接器中心，确认名称、状态和引用关系后开始新建。

2. 新建连接器并填写名称

操作位置： 集成→连接器

点击 新建连接器，填写能说明用途和环境的名称。

图：新建窗口中填写连接器名称 FastBee_双向连接，尚未保存。

字段说明

字段 / 控件	说明
连接器名称	给连接资源命名，便于任务选择与运维定位；应区分生产和测试环境；作用于当前连接器，任务启用与业务结果需另行确认。必填 · 来源：由当前业务用途、外部系统对接资料及平台页面确定。选择：给连接资源命名，便于任务选择与运维定位；应区分生产和测试环境。推荐：按对接资料填写 · 示例：FastBee_双向连接

3. 选择双向能力和 RabbitMQ 类型

操作位置： 集成→连接器

同时开启 消息推送 与 指令下行，连接类型选择 RabbitMQ。

图：连接类型为 RabbitMQ，消息推送和指令下行均已启用，各自保留独立参数。

字段说明

字段 / 控件	说明
能力	消息推送用于平台向外发送数据；指令下行用于接收外部指令。可启用一种或两种能力，每种最多一套参数；作用于当前连接器，任务启用与业务结果需另行确认。必填 · 来源：由当前业务用途、外部系统对接资料及平台页面确定。选择：消息推送用于平台向外发送数据；指令下行用于接收外部指令。可启用一种或两种能力，每种最多一套参数。推荐：按对接资料填写 · 示例：按实际环境填写
连接类型	按外部系统实际使用的协议选择。同一连接器使用一种类型，两条能力的参数分别维护；作用于当前连接器，任务启用与业务结果需另行确认。必填 · 来源：由当前业务用途、外部系统对接资料及平台页面确定。选择：按外部系统实际使用的协议选择。同一连接器使用一种类型，两条能力的参数分别维护。推荐：按对接资料填写 · 示例：按实际环境填写

4. 配置消息推送的 RabbitMQ 参数

操作位置： 集成→连接器

先在消息推送通道选择 生产推荐，再填写主机、端口、账号、密码、vhost、交换机和发布路由约定。

图：消息推送参数已填写：使用本部署 RabbitMQ 连接信息及本批次独立上行交换机，密码保持隐藏。

字段说明

字段 / 控件	说明
主机地址	RabbitMQ 服务器地址；该值供消息推送任务使用；运行任务需重新加载变更。必填 · 来源：外部系统部署及对接清单；客户端实例名称由实施人员按环境和用途指定。选择：从对接方部署清单取地址，必须能被 FMQ 服务器访问。截图中的本机地址仅为示例；不要把浏览器所在电脑的地址误当成服务端地址。推荐：按对接资料填写 · 示例：127.0.0.1
端口	RabbitMQ AMQP 端口；该值供消息推送任务使用；运行任务需重新加载变更。必填 · 来源：外部系统部署及对接清单；客户端实例名称由实施人员按环境和用途指定。选择：向管理员取得 AMQP 数据端口，常见 5672；管理页面常用的 15672 不能填在这里。以实际部署为准，连接拒绝时先核对端口与防火墙。推荐：按对接资料填写 · 示例：5672
用户名	连接 RabbitMQ 的用户名；该值供消息推送任务使用；运行任务需重新加载变更。必填 · 来源：外部系统部署及对接清单；客户端实例名称由实施人员按环境和用途指定。选择：从 RabbitMQ 管理员取得专用业务账号，并确认对应 vhost 权限。不要直接沿用示例 guest；远程登录或权限不足会失败。推荐：按对接资料填写 · 示例：guest
密码	连接 RabbitMQ 的密码；该值供消息推送任务使用；运行任务需重新加载变更。选填 · 来源：对接管理员通过受控渠道提供，实际值不进入手册或日志。选择：与当前用户名配套，由管理员通过受控渠道提供。表单标为推荐不等于 Broker 允许空密码；保存或复用时不要把掩码当成新密码。推荐：按对接资料填写 · 示例：通过受控渠道填写
虚拟主机	RabbitMQ 的 vhost，用于隔离不同业务环境；该值供消息推送任务使用；运行任务需重新加载变更。选填 · 来源：外部系统部署及对接清单；客户端实例名称由实施人员按环境和用途指定。选择：在 RabbitMQ 管理端查看本业务的 vhost，像同一 Broker 内的独立工作区。两端用错 vhost 时，即使队列同名也不是同一条通道；账号还必须有该 vhost 权限。推荐：按对接资料填写 · 示例：/
默认交换机	消息推送默认使用的交换机名称；该值供消息推送任务使用；运行任务需重新加载变更。选填 · 来源：外部系统部署及对接清单；客户端实例名称由实施人员按环境和用途指定。选择：向 MQ 管理员确认交换机名称与类型。交换机负责转送消息，队列负责存放消息；有交换机并不保证已绑定目标队列。 上行路由键通常还需在消息推送任务中配置，连接器不会决定哪些业务数据被发送。推荐：按对接资料填写 · 示例：fmq.push.exchange
发布确认	发送后等待 Broker 确认，可靠性更高；该值供消息推送任务使用；运行任务需重新加载变更。选填 · 来源：先采用本类型推荐模式，再根据实际负载、接口约定和运行指标调整。选择：开启后等待 Broker 接受发布的确认；重要上行消息优先开启。它不是外部业务系统的处理回执，也不能单独证明路由到目标队列。推荐：开启（true） · 示例：开启（true）

5. 填写下行连接信息与消费队列

操作位置： 集成→连接器

切换到指令下行通道，先选择 生产推荐，再分别填写主机、端口、账号、密码、vhost 和 消费队列。两边共用 Broker 时也须核对各自的连接参数。

图：指令下行独立填写连接资料及本批次消费队列；密码隐藏，队列与上行交换机不同。

字段说明

字段 / 控件	说明
主机地址	RabbitMQ 服务器地址；该值供指令下行任务使用；运行任务需重新加载变更。必填 · 来源：外部系统部署及对接清单；客户端实例名称由实施人员按环境和用途指定。选择：从对接方部署清单取地址，必须能被 FMQ 服务器访问。截图中的本机地址仅为示例；不要把浏览器所在电脑的地址误当成服务端地址。推荐：按对接资料填写 · 示例：127.0.0.1
端口	RabbitMQ AMQP 端口；该值供指令下行任务使用；运行任务需重新加载变更。必填 · 来源：外部系统部署及对接清单；客户端实例名称由实施人员按环境和用途指定。选择：向管理员取得 AMQP 数据端口，常见 5672；管理页面常用的 15672 不能填在这里。以实际部署为准，连接拒绝时先核对端口与防火墙。推荐：按对接资料填写 · 示例：5672
用户名	连接 RabbitMQ 的用户名；该值供指令下行任务使用；运行任务需重新加载变更。必填 · 来源：外部系统部署及对接清单；客户端实例名称由实施人员按环境和用途指定。选择：从 RabbitMQ 管理员取得专用业务账号，并确认对应 vhost 权限。不要直接沿用示例 guest；远程登录或权限不足会失败。推荐：按对接资料填写 · 示例：guest
密码	连接 RabbitMQ 的密码；该值供指令下行任务使用；运行任务需重新加载变更。选填 · 来源：对接管理员通过受控渠道提供，实际值不进入手册或日志。选择：与当前用户名配套，由管理员通过受控渠道提供。表单标为推荐不等于 Broker 允许空密码；保存或复用时不要把掩码当成新密码。推荐：按对接资料填写 · 示例：通过受控渠道填写
虚拟主机	RabbitMQ 的 vhost，用于隔离不同业务环境；该值供指令下行任务使用；运行任务需重新加载变更。选填 · 来源：外部系统部署及对接清单；客户端实例名称由实施人员按环境和用途指定。选择：在 RabbitMQ 管理端查看本业务的 vhost，像同一 Broker 内的独立工作区。两端用错 vhost 时，即使队列同名也不是同一条通道；账号还必须有该 vhost 权限。推荐：按对接资料填写 · 示例：/
消费队列	平台监听并读取下行指令的队列名称；该值供指令下行任务使用；运行任务需重新加载变更。必填 · 来源：外部系统部署及对接清单；客户端实例名称由实施人员按环境和用途指定。选择：从 RabbitMQ 管理端取得外部系统实际投递的消费队列。它不是交换机；同队列多个消费者会分担消息，联调用独立队列避免抢走生产指令。推荐：按对接资料填写 · 示例：fmq.dispatch.queue

6. 配置下行交换机与队列绑定

操作位置： 集成→连接器

在补充参数中添加 交换机、路由键 和 自动绑定队列，填写本次独立下行交换机与约定路由键。首次创建隔离测试资源时，按获准方案启用自动声明和绑定。

图：下行交换机、路由键和自动声明、自动绑定选项已配置，操作范围仅限本批次独立队列。

字段说明

字段 / 控件	说明
交换机	消费链路关联的交换机名称；该值供指令下行任务使用；运行任务需重新加载变更。选填 · 来源：外部系统部署及对接清单；客户端实例名称由实施人员按环境和用途指定。选择：向 MQ 管理员确认交换机名称与类型。交换机负责转送消息，队列负责存放消息；有交换机并不保证已绑定目标队列。推荐：按对接资料填写 · 示例：fmq.dispatch.exchange
路由键	队列绑定的路由键；该值供指令下行任务使用；运行任务需重新加载变更。选填 · 来源：外部系统部署及对接清单；客户端实例名称由实施人员按环境和用途指定。选择：与外部发布方、交换机绑定规则一致；例如按约定用 device.command。拼写或类型匹配错误时，连接正常但队列仍可能收不到消息。推荐：按对接资料填写 · 示例：device.command
自动绑定队列	存在交换机时，是否按路由键把队列自动绑定到交换机；该值供指令下行任务使用；运行任务需重新加载变更。选填 · 来源：先采用本类型推荐模式，再根据实际负载、接口约定和运行指标调整。选择：开启会按交换机和路由键绑定消费队列，需要绑定权限。由管理员维护绑定时可关闭，但应先确认关系已存在。推荐：开启（true） · 示例：开启（true）
自动声明交换机	是否自动声明消费使用的交换机；该值供指令下行任务使用；运行任务需重新加载变更。选填 · 来源：先采用本类型推荐模式，再根据实际负载、接口约定和运行指标调整。选择：开启允许在校验或运行时声明交换机，需要创建权限；关闭则要求交换机已存在。复用生产资源前向管理员确认，不能擅自改已有资源类型。推荐：开启（true） · 示例：开启（true）
自动声明队列	是否自动声明平台消费使用的队列；该值供指令下行任务使用；运行任务需重新加载变更。选填 · 来源：先采用本类型推荐模式，再根据实际负载、接口约定和运行指标调整。选择：开启允许创建队列，需要资源权限；关闭要求队列预先存在。已有队列属性不匹配时请管理员核对，不要删除队列来消除报错。推荐：开启（true） · 示例：开启（true）

7. 核对两个通道都已就绪

操作位置： 集成→连接器

在同一窗口分别查看消息推送和指令下行卡片，确认都显示已就绪。

图：消息推送和指令下行都显示已就绪；这只表示必填参数齐全，下一步仍需测试。

8. 测试全部通道

操作位置： 集成→连接器

点击 测试全部通道，等待消息推送和指令下行分别返回结果。

图：测试全部通道通过：消息推送为 RabbitMQ broker reachable，指令下行为 RabbitMQ queue reachable。

9. 保存双向连接器

操作位置： 集成→连接器

确认两项校验结果仍有效后点击 保存连接器。

图：两个通道已通过检查，保存按钮可用；保持已验证参数不变后提交保存。

字段说明

字段 / 控件	说明
连接器名称	给连接资源命名，便于任务选择与运维定位；应区分生产和测试环境；作用于当前连接器，任务启用与业务结果需另行确认。必填 · 来源：由当前业务用途、外部系统对接资料及平台页面确定。选择：给连接资源命名，便于任务选择与运维定位；应区分生产和测试环境。推荐：按对接资料填写 · 示例：FastBee_双向连接
能力	消息推送用于平台向外发送数据；指令下行用于接收外部指令。可启用一种或两种能力，每种最多一套参数；作用于当前连接器，任务启用与业务结果需另行确认。必填 · 来源：由当前业务用途、外部系统对接资料及平台页面确定。选择：消息推送用于平台向外发送数据；指令下行用于接收外部指令。可启用一种或两种能力，每种最多一套参数。推荐：按对接资料填写 · 示例：按实际环境填写

10. 检查保存后的双向能力

操作位置： 集成→连接器

回到列表或详情，核对连接器名称、消息推送能力、指令下行能力和引用数量。

图：保存后详情显示 RabbitMQ 双向能力，引用任务为0；状态为待验证，需要对已保存资源再做能力测试。

11. 保存后重新测试

操作位置： 集成→连接器

打开刚保存的双向连接器详情，点击 能力测试，查看两个方向的结果。

图：保存后能力测试再次通过，消息推送与指令下行分别返回成功；最近检查时间已更新。

消息推送参数参考

Kafka：对方已经使用 Kafka，且约定了 Topic 与消费方式时选择。

先向管理员取得 Broker 地址，再选模式并填写生产者参数。这里不填 Topic 和消息 Key，它们在消息推送任务或规则动作中配置；不要拿下行消费组替代客户端 ID。

参数校验边界：参数校验会检查整数参数并查询 Kafka 集群信息；即使通过，也没有向目标 Topic 发送业务数据，不证明该 Topic 的写权限和对方消费成功。

RabbitMQ：对方用交换机、路由键和队列组织消息时选择 RabbitMQ。

按 MQ 管理员给出的主机、AMQP 端口、账号和 vhost 填写，再确定默认交换机及发布确认。消息从平台发往交换机，外部系统从其绑定队列接收。

参数校验边界：校验可能连接 Broker 并声明或被动检查交换机；开启相关选项时可能修改资源。Broker 可达不是对方队列收到数据，上行还要核对任务路由键与接收端。

RocketMQ：对方已使用 RocketMQ，并提供 NameServer、组名及 Topic 规划时选择。

填写 NameServer 与生产组，再选择发送超时及重试方案。目标 Topic 在业务任务处确定；生产组名不等同 Topic。

参数校验边界：当前测试启动生产者；另有测试 Topic 时才检查 Topic 路由。没有测试 Topic 时即使提示 nameserver reachable，也不能证明目标 Topic 路由和消息投递成功。

MQTT：对方提供 MQTT Broker，双方按 Topic 发布、订阅时选择。

选择外部 Broker 模式，填写唯一 clientId、Broker 地址、端口及认证。这个 clientId 表示平台发布端，不是某个设备；发布 Topic 在业务任务中配置。

参数校验边界：外部 Broker 连接探测通过不等于目标 Topic 发布权限正常，更不代表订阅者收到消息。独立命名上行、下行客户端，避免踢掉现有连接。

WebHook：上行是平台调用对方回调地址；下行则是对方调用平台入口。先分清谁调用谁。

从对接方接口文档取得完整 URL、请求方法和超时。点击测试连接前确认接口允许测试调用，必要时由对方提供专用测试地址。

参数校验边界：测试连接会真实发送请求；非 GET 情况使用空 JSON 对象测试。接受的 HTTP 响应不代表对方已完成业务处理，接口也可能有副作用。

界面参考

消息推送 / Kafka

图：前次白天模式页面截图，用于定位字段，不作为本次配置或连通成功证明。长表单其余字段请在页面向下滚动，完整解释见本节。

消息推送 / RabbitMQ

图：前次白天模式页面截图，用于定位字段，不作为本次配置或连通成功证明。长表单其余字段请在页面向下滚动，完整解释见本节。

消息推送 / RocketMQ

图：前次白天模式页面截图，用于定位字段，不作为本次配置或连通成功证明。长表单其余字段请在页面向下滚动，完整解释见本节。

消息推送 / MQTT

图：前次白天模式页面截图，用于定位字段，不作为本次配置或连通成功证明。长表单其余字段请在页面向下滚动，完整解释见本节。

消息推送 / WebHook

图：前次白天模式页面截图，用于定位字段，不作为本次配置或连通成功证明。长表单其余字段请在页面向下滚动，完整解释见本节。

消息推送 · Kafka

字段	用途	值从哪里来	怎么选择	填错表现与恢复	生效条件
推荐模式	为消息推送选择一组参数预设；选完后再填写真实环境信息；作用于当前连接器，任务启用与业务结果需另行确认。	平台为本类型提供的推荐模式。	测试推荐：适合本地联调和功能验证，降低等待时间，便于快速看到结果。；稳定优先：优先保证投递可靠性，适合告警、审计和关键业务通知。；高并发：适合大量日志或遥测推送，优先提高批量发送效率。；生产推荐：平衡可靠性、吞吐和维护成本，适合作为通用生产默认方案。推荐：生产推荐默认：—示例：—测试推荐：适合本地联调和功能验证，降低等待时间，便于快速看到结果；覆盖本通道预设参数，随后须重新核对连接信息。稳定优先：优先保证投递可靠性，适合告警、审计和关键业务通知；覆盖本通道预设参数，随后须重新核对连接信息。高并发：适合大量日志或遥测推送，优先提高批量发送效率；覆盖本通道预设参数，随后须重新核对连接信息。生产推荐：平衡可靠性、吞吐和维护成本，适合作为通用生产默认方案；覆盖本通道预设参数，随后须重新核对连接信息。	配置变更可能影响引用它的任务；保留原配置，修正后复测。	范围：当前连接器及引用它的任务发布：不需要 · 重启：不需要 · 重连：不需要
必填 Broker 地址	Kafka 集群地址，多个地址用逗号分隔；该值供消息推送任务使用；运行任务需重新加载变更。	外部系统部署及对接清单；客户端实例名称由实施人员按环境和用途指定。	向 Kafka 管理员索取客户端可访问的 host:port 清单，多项用英文逗号分隔。127.0.0.1 指 FMQ 所在服务器，不是操作人员电脑；连不上先查端口与集群公布的地址。推荐：按对接资料填写默认：127.0.0.1:9092示例：127.0.0.1:9092	向 Kafka 管理员索取客户端可访问的 host:port 清单，多项用英文逗号分隔。127.0.0.1 指 FMQ 所在服务器，不是操作人员电脑；连不上先查端口与集群公布的地址；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
客户端 ID	用于区分当前连接器实例，便于 Broker 侧排查；该值供消息推送任务使用；运行任务需重新加载变更。	外部系统部署及对接清单；客户端实例名称由实施人员按环境和用途指定。	用于在 Broker 日志中识别本连接，不是设备 ID，也不决定消息发到哪里。由实施人员按用途命名；不要用它代替消费组。推荐：按对接资料填写默认：fmq-rule-producer示例：fmq-rule-producer	用于在 Broker 日志中识别本连接，不是设备 ID，也不决定消息发到哪里。由实施人员按用途命名；不要用它代替消费组；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
确认级别	决定消息发送后需要几个副本确认，all 最可靠，1 延迟更低；该值供消息推送任务使用；运行任务需重新加载变更。	先采用本类型推荐模式，再根据实际负载、接口约定和运行指标调整。	all 等待全部当前同步副本确认；1 仅等主副本；0 不等确认。重要消息先选稳定优先，不能把确认当成业务系统已处理。推荐：1默认：1示例：1 / all / 0仅 Leader 确认（1）：等待主副本确认，副本故障时仍存在丢失风险；更换后按仅 Leader 确认（1）处理该字段。全部副本确认（all）：等待所有当前同步副本确认；仍不是业务处理回执；更换后按全部副本确认（all）处理该字段。无需确认（0）：不等待确认，无法从发送结果判断 Broker 是否接收；更换后按无需确认（0）处理该字段。	all 等待全部当前同步副本确认；1 仅等主副本；0 不等确认。重要消息先选稳定优先，不能把确认当成业务系统已处理；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
失败重试次数	发送失败后的自动重试次数；该值供消息推送任务使用；运行任务需重新加载变更。	先采用本类型推荐模式，再根据实际负载、接口约定和运行指标调整。	先取推荐模式值。调大可增加瞬时故障的重试机会，也会延长失败等待；不要用无限重试掩盖错误地址，接收端需防重复。推荐：3默认：3示例：3	先取推荐模式值。调大可增加瞬时故障的重试机会，也会延长失败等待；不要用无限重试掩盖错误地址，接收端需防重复；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
压缩类型	消息压缩算法，常见有 none、gzip、snappy、lz4、zstd；该值供消息推送任务使用；运行任务需重新加载变更。	先采用本类型推荐模式，再根据实际负载、接口约定和运行指标调整。	双方客户端与 Broker 支持后再选算法。none 不压缩；gzip 通常较费 CPU；snappy、lz4 常用于吞吐与延迟折中；zstd 需确认部署兼容性。推荐：lz4默认：lz4示例：lz4不压缩（none）：不压缩，少量联调简单；更换后按不压缩（none）处理该字段。Gzip：GZIP 压缩，关注 CPU 消耗；更换后按Gzip处理该字段。Snappy：Snappy 压缩，常用于速度与压缩折中；更换后按Snappy处理该字段。LZ4：LZ4 压缩，常用于低开销场景；更换后按LZ4处理该字段。Zstd：Zstandard 压缩，先确认部署支持；更换后按Zstd处理该字段。	双方客户端与 Broker 支持后再选算法。none 不压缩；gzip 通常较费 CPU；snappy、lz4 常用于吞吐与延迟折中；zstd 需确认部署兼容性；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
批量等待时间	发送前额外等待的毫秒数，用于聚合更多消息形成批次；该值供消息推送任务使用；运行任务需重新加载变更。	先采用本类型推荐模式，再根据实际负载、接口约定和运行指标调整。	单位毫秒。低延迟场景用较小值；适当增大可合并更多消息，但每条消息可能多等一会儿。先按推荐模式，结合延迟指标调整。推荐：10默认：10示例：10	单位毫秒。低延迟场景用较小值；适当增大可合并更多消息，但每条消息可能多等一会儿。先按推荐模式，结合延迟指标调整；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
批量大小	单批消息缓冲大小，越大吞吐越高，但延迟可能增加；该值供消息推送任务使用；运行任务需重新加载变更。	先采用本类型推荐模式，再根据实际负载、接口约定和运行指标调整。	单位字节，不是消息条数。调大前看实际消息大小和内存预算，小流量一般不必加大。推荐：131072默认：131072示例：131072	单位字节，不是消息条数。调大前看实际消息大小和内存预算，小流量一般不必加大；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
总缓冲区大小	生产者可用于缓存待发送消息的总内存；该值供消息推送任务使用；运行任务需重新加载变更。	先采用本类型推荐模式，再根据实际负载、接口约定和运行指标调整。	单位字节，是待发消息缓冲的预算。积压持续增长先查 Broker 和消费能力，不要只加内存；耗尽时发送可能等待或失败。推荐：67108864默认：67108864示例：67108864	单位字节，是待发消息缓冲的预算。积压持续增长先查 Broker 和消费能力，不要只加内存；耗尽时发送可能等待或失败；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
必填 Key 序列化器	消息 Key 的序列化类，默认使用 Kafka 常用的 StringSerializer；该值供消息推送任务使用；运行任务需重新加载变更。	先采用本类型推荐模式，再根据实际负载、接口约定和运行指标调整。	把消息 Key 转成 Kafka 字节数据的类名。文本 Key 保留 StringSerializer；不是在此填写 Key 内容，填错类名可能导致任务启动失败。推荐：org.apache.kafka.common.serialization.StringSerializer默认：org.apache.kafka.common.serialization.StringSerializer示例：org.apache.kafka.common.serialization.StringSerializer	把消息 Key 转成 Kafka 字节数据的类名。文本 Key 保留 StringSerializer；不是在此填写 Key 内容，填错类名可能导致任务启动失败；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
必填 Value 序列化器	消息 Value 的序列化类，默认使用 Kafka 常用的 StringSerializer；该值供消息推送任务使用；运行任务需重新加载变更。	先采用本类型推荐模式，再根据实际负载、接口约定和运行指标调整。	把消息正文转成字节数据的类名。JSON 文本通常保留 StringSerializer；更换须与对方编码一致，否则可能发送失败或乱码。推荐：org.apache.kafka.common.serialization.StringSerializer默认：org.apache.kafka.common.serialization.StringSerializer示例：org.apache.kafka.common.serialization.StringSerializer	把消息正文转成字节数据的类名。JSON 文本通常保留 StringSerializer；更换须与对方编码一致，否则可能发送失败或乱码；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要

消息推送 · Kafka

字段	用途	值从哪里来	怎么选择	填错表现与恢复	生效条件
请求超时	单次请求等待 Broker 响应的超时时间，单位毫秒；该值供消息推送任务使用；运行任务需重新加载变更。	先采用本类型推荐模式，再根据实际负载、接口约定和运行指标调整。	单位毫秒，取推荐值后根据网络和 Broker 响应调整。过短会误报超时，过长会延后故障发现；先排查慢请求。推荐：15000默认：15000示例：15000	单位毫秒，取推荐值后根据网络和 Broker 响应调整。过短会误报超时，过长会延后故障发现；先排查慢请求；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
投递总超时	消息从进入缓冲到投递失败的最大总耗时；该值供消息推送任务使用；运行任务需重新加载变更。	先采用本类型推荐模式，再根据实际负载、接口约定和运行指标调整。	单位毫秒，包含等待批次、请求与重试的总时间。须覆盖请求超时和批量等待；太短会让重试还未发挥作用就失败。推荐：30000默认：30000示例：30000	单位毫秒，包含等待批次、请求与重试的总时间。须覆盖请求超时和批量等待；太短会让重试还未发挥作用就失败；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
阻塞上限	缓冲区耗尽或元数据不可用时，调用方最多阻塞多久；该值供消息推送任务使用；运行任务需重新加载变更。	先采用本类型推荐模式，再根据实际负载、接口约定和运行指标调整。	单位毫秒，限制发送端因缓冲或元数据问题等待的时间。超时先查集群可达性和缓冲积压，不应直接无限增大。推荐：60000默认：60000示例：60000	单位毫秒，限制发送端因缓冲或元数据问题等待的时间。超时先查集群可达性和缓冲积压，不应直接无限增大；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
单连接并发请求数	同一连接同时发送中的请求数量上限；该值供消息推送任务使用；运行任务需重新加载变更。	先采用本类型推荐模式，再根据实际负载、接口约定和运行指标调整。	用于并发发送，越大不一定越好。对消息顺序敏感时保留稳定方案，并与重试、幂等策略一起评估。推荐：5默认：5示例：5	用于并发发送，越大不一定越好。对消息顺序敏感时保留稳定方案，并与重试、幂等策略一起评估；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
单请求最大字节数	单条请求允许发送的最大字节数；该值供消息推送任务使用；运行任务需重新加载变更。	先采用本类型推荐模式，再根据实际负载、接口约定和运行指标调整。	单位字节，需与 Broker 允许的消息上限协调。消息过大时先精简或拆分报文，不要只调客户端。推荐：10485760默认：10485760示例：10485760	单位字节，需与 Broker 允许的消息上限协调。消息过大时先精简或拆分报文，不要只调客户端；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
发送缓冲区	底层 Socket 发送缓冲区大小；该值供消息推送任务使用；运行任务需重新加载变更。	先采用本类型推荐模式，再根据实际负载、接口约定和运行指标调整。	单位字节，交由运维根据网络吞吐调优。普通联调保留默认值，不是用来设置消息正文大小。推荐：131072默认：131072示例：131072	单位字节，交由运维根据网络吞吐调优。普通联调保留默认值，不是用来设置消息正文大小；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
接收缓冲区	底层 Socket 接收缓冲区大小；该值供消息推送任务使用；运行任务需重新加载变更。	先采用本类型推荐模式，再根据实际负载、接口约定和运行指标调整。	单位字节，是网络接收缓冲。没有明确网络瓶颈时保持默认，调大前计算多连接总内存。推荐：65536默认：65536示例：65536	单位字节，是网络接收缓冲。没有明确网络瓶颈时保持默认，调大前计算多连接总内存；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要

消息推送 · RabbitMQ

字段	用途	值从哪里来	怎么选择	填错表现与恢复	生效条件
推荐模式	为消息推送选择一组参数预设；选完后再填写真实环境信息；作用于当前连接器，任务启用与业务结果需另行确认。	平台为本类型提供的推荐模式。	测试推荐：适合联调环境，尽量减少等待时间并保留必要的连接保护。；稳定优先：优先保证消息投递可靠性，适合关键通知与审计流。；高并发：减少确认等待，更适合高频轻量推送场景。；生产推荐：兼顾自动恢复、发布确认和运维稳态，适合作为生产默认值。推荐：生产推荐默认：—示例：—测试推荐：适合联调环境，尽量减少等待时间并保留必要的连接保护；覆盖本通道预设参数，随后须重新核对连接信息。稳定优先：优先保证消息投递可靠性，适合关键通知与审计流；覆盖本通道预设参数，随后须重新核对连接信息。高并发：减少确认等待，更适合高频轻量推送场景；覆盖本通道预设参数，随后须重新核对连接信息。生产推荐：兼顾自动恢复、发布确认和运维稳态，适合作为生产默认值；覆盖本通道预设参数，随后须重新核对连接信息。	配置变更可能影响引用它的任务；保留原配置，修正后复测。	范围：当前连接器及引用它的任务发布：不需要 · 重启：不需要 · 重连：不需要
必填 主机地址	RabbitMQ 服务器地址；该值供消息推送任务使用；运行任务需重新加载变更。	外部系统部署及对接清单；客户端实例名称由实施人员按环境和用途指定。	从对接方部署清单取地址，必须能被 FMQ 服务器访问。截图中的本机地址仅为示例；不要把浏览器所在电脑的地址误当成服务端地址。推荐：按对接资料填写默认：127.0.0.1示例：127.0.0.1	从对接方部署清单取地址，必须能被 FMQ 服务器访问。截图中的本机地址仅为示例；不要把浏览器所在电脑的地址误当成服务端地址；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
必填 端口	RabbitMQ AMQP 端口；该值供消息推送任务使用；运行任务需重新加载变更。	外部系统部署及对接清单；客户端实例名称由实施人员按环境和用途指定。	向管理员取得 AMQP 数据端口，常见 5672；管理页面常用的 15672 不能填在这里。以实际部署为准，连接拒绝时先核对端口与防火墙。推荐：按对接资料填写默认：5672示例：5672	向管理员取得 AMQP 数据端口，常见 5672；管理页面常用的 15672 不能填在这里。以实际部署为准，连接拒绝时先核对端口与防火墙；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
必填 用户名	连接 RabbitMQ 的用户名；该值供消息推送任务使用；运行任务需重新加载变更。	外部系统部署及对接清单；客户端实例名称由实施人员按环境和用途指定。	从 RabbitMQ 管理员取得专用业务账号，并确认对应 vhost 权限。不要直接沿用示例 guest；远程登录或权限不足会失败。推荐：按对接资料填写默认：guest示例：guest	从 RabbitMQ 管理员取得专用业务账号，并确认对应 vhost 权限。不要直接沿用示例 guest；远程登录或权限不足会失败；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
密码	连接 RabbitMQ 的密码；该值供消息推送任务使用；运行任务需重新加载变更。	对接管理员通过受控渠道提供，实际值不进入手册或日志。	与当前用户名配套，由管理员通过受控渠道提供。表单标为推荐不等于 Broker 允许空密码；保存或复用时不要把掩码当成新密码。推荐：按对接资料填写默认：敏感值不展示示例：通过受控渠道填写	与当前用户名配套，由管理员通过受控渠道提供。表单标为推荐不等于 Broker 允许空密码；保存或复用时不要把掩码当成新密码；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
虚拟主机	RabbitMQ 的 vhost，用于隔离不同业务环境；该值供消息推送任务使用；运行任务需重新加载变更。	外部系统部署及对接清单；客户端实例名称由实施人员按环境和用途指定。	在 RabbitMQ 管理端查看本业务的 vhost，像同一 Broker 内的独立工作区。两端用错 vhost 时，即使队列同名也不是同一条通道；账号还必须有该 vhost 权限。推荐：按对接资料填写默认：/示例：/	在 RabbitMQ 管理端查看本业务的 vhost，像同一 Broker 内的独立工作区。两端用错 vhost 时，即使队列同名也不是同一条通道；账号还必须有该 vhost 权限；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
默认交换机	消息推送默认使用的交换机名称；该值供消息推送任务使用；运行任务需重新加载变更。	外部系统部署及对接清单；客户端实例名称由实施人员按环境和用途指定。	向 MQ 管理员确认交换机名称与类型。交换机负责转送消息，队列负责存放消息；有交换机并不保证已绑定目标队列。 上行路由键通常还需在消息推送任务中配置，连接器不会决定哪些业务数据被发送。推荐：按对接资料填写默认：fmq.push.exchange示例：fmq.push.exchange	向 MQ 管理员确认交换机名称与类型。交换机负责转送消息，队列负责存放消息；有交换机并不保证已绑定目标队列。 上行路由键通常还需在消息推送任务中配置，连接器不会决定哪些业务数据被发送；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
发布确认	发送后等待 Broker 确认，可靠性更高；该值供消息推送任务使用；运行任务需重新加载变更。	先采用本类型推荐模式，再根据实际负载、接口约定和运行指标调整。	开启后等待 Broker 接受发布的确认；重要上行消息优先开启。它不是外部业务系统的处理回执，也不能单独证明路由到目标队列。推荐：开启（true）默认：开启（true）示例：开启（true）	开启后等待 Broker 接受发布的确认；重要上行消息优先开启。它不是外部业务系统的处理回执，也不能单独证明路由到目标队列；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
心跳间隔	与 Broker 协商的心跳间隔，单位秒；该值供消息推送任务使用；运行任务需重新加载变更。	先采用本类型推荐模式，再根据实际负载、接口约定和运行指标调整。	单位秒，用于检测连接是否还活着。先保留推荐值，频繁断线时查网络和 Broker 负载，不要盲目关闭心跳。推荐：30默认：30示例：30	单位秒，用于检测连接是否还活着。先保留推荐值，频繁断线时查网络和 Broker 负载，不要盲目关闭心跳；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
自动恢复	连接异常断开后是否自动恢复；该值供消息推送任务使用；运行任务需重新加载变更。	先采用本类型推荐模式，再根据实际负载、接口约定和运行指标调整。	开启可在网络异常后尝试恢复连接。通常保留开启，但错误凭据、被删除的资源仍需人工修正；自动恢复不是数据不丢的承诺。推荐：开启（true）默认：开启（true）示例：开启（true）	开启可在网络异常后尝试恢复连接。通常保留开启，但错误凭据、被删除的资源仍需人工修正；自动恢复不是数据不丢的承诺；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
确认超时	等待发布确认的超时时间；该值供消息推送任务使用；运行任务需重新加载变更。	先采用本类型推荐模式，再根据实际负载、接口约定和运行指标调整。	单位毫秒，在启用发布确认时尤其重要。过短会把慢响应当失败；超时后先查 Broker 接受情况，避免重复推送造成重复处理。推荐：10000默认：10000示例：10000	单位毫秒，在启用发布确认时尤其重要。过短会把慢响应当失败；超时后先查 Broker 接受情况，避免重复推送造成重复处理；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要

消息推送 · RabbitMQ

字段	用途	值从哪里来	怎么选择	填错表现与恢复	生效条件
交换机类型	交换机类型，常见有 direct、topic、fanout、headers；该值供消息推送任务使用；运行任务需重新加载变更。	先采用本类型推荐模式，再根据实际负载、接口约定和运行指标调整。	必须与现有交换机一致。direct 按完整路由键匹配，topic 按主题模式匹配，fanout 广播到绑定队列，headers 按头属性匹配。选错已有资源类型会声明失败。推荐：topic默认：topic示例：topicTopic：按主题模式匹配路由键；更换后按Topic处理该字段。Direct：完整路由键匹配；更换后按Direct处理该字段。Fanout：投递给全部绑定队列，不按路由键筛选；更换后按Fanout处理该字段。Headers：按消息头匹配，须另行约定头属性与绑定参数；更换后按Headers处理该字段。	必须与现有交换机一致。direct 按完整路由键匹配，topic 按主题模式匹配，fanout 广播到绑定队列，headers 按头属性匹配。选错已有资源类型会声明失败；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
自动声明交换机	是否在发送前自动声明交换机，适合首次部署时使用；该值供消息推送任务使用；运行任务需重新加载变更。	先采用本类型推荐模式，再根据实际负载、接口约定和运行指标调整。	开启允许在校验或运行时声明交换机，需要创建权限；关闭则要求交换机已存在。复用生产资源前向管理员确认，不能擅自改已有资源类型。推荐：开启（true）默认：开启（true）示例：开启（true）	开启允许在校验或运行时声明交换机，需要创建权限；关闭则要求交换机已存在。复用生产资源前向管理员确认，不能擅自改已有资源类型；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
持久化交换机	交换机是否持久化；该值供消息推送任务使用；运行任务需重新加载变更。	先采用本类型推荐模式，再根据实际负载、接口约定和运行指标调整。	持久化的是交换机或队列的资源定义，不等于每条消息都已可靠保存。与现有资源属性必须一致；不一致时先核对，切勿删除业务队列重建。推荐：开启（true）默认：开启（true）示例：开启（true）	持久化的是交换机或队列的资源定义，不等于每条消息都已可靠保存。与现有资源属性必须一致；不一致时先核对，切勿删除业务队列重建；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
自动删除	交换机在无绑定后是否自动删除；该值供消息推送任务使用；运行任务需重新加载变更。	先采用本类型推荐模式，再根据实际负载、接口约定和运行指标调整。	生产长驻通道通常关闭。开启会让资源在满足 Broker 的自动删除条件时消失；临时联调才考虑，勿用于需长期保留的业务队列。推荐：关闭（false）默认：关闭（false）示例：关闭（false）	生产长驻通道通常关闭。开启会让资源在满足 Broker 的自动删除条件时消失；临时联调才考虑，勿用于需长期保留的业务队列；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
连接超时	建立连接的超时时间，单位毫秒；该值供消息推送任务使用；运行任务需重新加载变更。	先采用本类型推荐模式，再根据实际负载、接口约定和运行指标调整。	单位毫秒，是建连等待上限。失败先查地址、端口、防火墙和权限；网络通后再考虑调整时长。推荐：15000默认：15000示例：15000	单位毫秒，是建连等待上限。失败先查地址、端口、防火墙和权限；网络通后再考虑调整时长；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
握手超时	AMQP 握手阶段的超时时间；该值供消息推送任务使用；运行任务需重新加载变更。	先采用本类型推荐模式，再根据实际负载、接口约定和运行指标调整。	单位毫秒，是 AMQP 握手阶段等待上限。异常时确认连的是 AMQP 服务而不是管理端口，检查服务负载。推荐：10000默认：10000示例：10000	单位毫秒，是 AMQP 握手阶段等待上限。异常时确认连的是 AMQP 服务而不是管理端口，检查服务负载；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
关闭超时	连接关闭时等待资源释放的超时时间；该值供消息推送任务使用；运行任务需重新加载变更。	先采用本类型推荐模式，再根据实际负载、接口约定和运行指标调整。	单位毫秒，用于关闭连接时等待资源释放。先保留默认，过短可能使关闭不完整，过长拖慢任务停止。推荐：10000默认：10000示例：10000	单位毫秒，用于关闭连接时等待资源释放。先保留默认，过短可能使关闭不完整，过长拖慢任务停止；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
重连间隔	自动恢复启用时，两次网络重连之间的间隔；该值供消息推送任务使用；运行任务需重新加载变更。	先采用本类型推荐模式，再根据实际负载、接口约定和运行指标调整。	单位毫秒，仅在自动恢复启用时有意义。太短会不断冲击故障 Broker，太长会延迟恢复；先使用生产推荐。推荐：5000默认：5000示例：5000	单位毫秒，仅在自动恢复启用时有意义。太短会不断冲击故障 Broker，太长会延迟恢复；先使用生产推荐；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
内容类型	发送消息的 content-type 属性；该值供消息推送任务使用；运行任务需重新加载变更。	先采用本类型推荐模式，再根据实际负载、接口约定和运行指标调整。	描述正文是什么格式，例如 application/json。应与接收方约定一致；这个属性不会自动把正文转成 JSON。推荐：application/json默认：application/json示例：application/json	描述正文是什么格式，例如 application/json。应与接收方约定一致；这个属性不会自动把正文转成 JSON；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
内容编码	发送消息的内容编码；该值供消息推送任务使用；运行任务需重新加载变更。	先采用本类型推荐模式，再根据实际负载、接口约定和运行指标调整。	按接收端约定填写字符编码，例如 UTF-8。不是压缩开关；编码不一致可能导致中文乱码。推荐：UTF-8默认：UTF-8示例：UTF-8	按接收端约定填写字符编码，例如 UTF-8。不是压缩开关；编码不一致可能导致中文乱码；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
投递模式	1 表示非持久化，2 表示持久化消息；该值供消息推送任务使用；运行任务需重新加载变更。	先采用本类型推荐模式，再根据实际负载、接口约定和运行指标调整。	2 为持久化消息，1 为非持久化。重要消息通常选 2，并结合持久化队列与发布确认；仅改此值不能保证全链路不丢。推荐：2默认：2示例：2持久化（2）：持久化消息，仍需配合持久化队列和确认策略；更换后按持久化（2）处理该字段。非持久化（1）：非持久化消息，适合可丢弃的临时数据；更换后按非持久化（1）处理该字段。	2 为持久化消息，1 为非持久化。重要消息通常选 2，并结合持久化队列与发布确认；仅改此值不能保证全链路不丢；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要

消息推送 · RocketMQ

字段	用途	值从哪里来	怎么选择	填错表现与恢复	生效条件
推荐模式	为消息推送选择一组参数预设；选完后再填写真实环境信息；作用于当前连接器，任务启用与业务结果需另行确认。	平台为本类型提供的推荐模式。	测试推荐：适合联调环境，降低等待时间并保持基础重试能力。；稳定优先：优先保证关键消息送达，提高同步与异步发送重试保护。；高并发：适合大批量消息推送，优先提升压缩和批量传输效率。；生产推荐：兼顾发送超时、重试和压缩阈值，适合作为生产默认方案。推荐：生产推荐默认：—示例：—测试推荐：适合联调环境，降低等待时间并保持基础重试能力；覆盖本通道预设参数，随后须重新核对连接信息。稳定优先：优先保证关键消息送达，提高同步与异步发送重试保护；覆盖本通道预设参数，随后须重新核对连接信息。高并发：适合大批量消息推送，优先提升压缩和批量传输效率；覆盖本通道预设参数，随后须重新核对连接信息。生产推荐：兼顾发送超时、重试和压缩阈值，适合作为生产默认方案；覆盖本通道预设参数，随后须重新核对连接信息。	配置变更可能影响引用它的任务；保留原配置，修正后复测。	范围：当前连接器及引用它的任务发布：不需要 · 重启：不需要 · 重连：不需要
必填 NameServer 地址	RocketMQ NameServer 地址，多个地址可用分号分隔；该值供消息推送任务使用；运行任务需重新加载变更。	外部系统部署及对接清单；客户端实例名称由实施人员按环境和用途指定。	从 RocketMQ 管理员索取 NameServer 地址，多地址格式按页面提示。不是 Broker 地址；取不到路由先检查地址和网络。推荐：按对接资料填写默认：127.0.0.1:9876示例：127.0.0.1:9876	从 RocketMQ 管理员索取 NameServer 地址，多地址格式按页面提示。不是 Broker 地址；取不到路由先检查地址和网络；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
必填 生产组	RocketMQ 生产者组名；该值供消息推送任务使用；运行任务需重新加载变更。	外部系统部署及对接清单；客户端实例名称由实施人员按环境和用途指定。	与 RocketMQ 管理员约定生产组名，用于识别发送方，不是目标 Topic。不要占用其他应用的组名。推荐：按对接资料填写默认：fmq-push-group示例：fmq-push-group	与 RocketMQ 管理员约定生产组名，用于识别发送方，不是目标 Topic。不要占用其他应用的组名；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
实例名称	客户端实例名，便于多实例区分；该值供消息推送任务使用；运行任务需重新加载变更。	外部系统部署及对接清单；客户端实例名称由实施人员按环境和用途指定。	由实施人员为当前环境和实例命名，便于日志定位。多实例避免误用同一身份；名字本身不改变 Topic。推荐：按对接资料填写默认：fmq-rule-producer示例：fmq-rule-producer	由实施人员为当前环境和实例命名，便于日志定位。多实例避免误用同一身份；名字本身不改变 Topic；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
发送超时	单次消息发送超时时间；该值供消息推送任务使用；运行任务需重新加载变更。	先采用本类型推荐模式，再根据实际负载、接口约定和运行指标调整。	单位毫秒。先保留推荐，超时后先查 NameServer、Broker 路由和负载，不要只增加等待。推荐：10000默认：10000示例：10000	单位毫秒。先保留推荐，超时后先查 NameServer、Broker 路由和负载，不要只增加等待；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
同步发送重试次数	同步发送失败时的自动重试次数；该值供消息推送任务使用；运行任务需重新加载变更。	先采用本类型推荐模式，再根据实际负载、接口约定和运行指标调整。	同步发送失败的重试次数，先用推荐值。重试可能带来重复消息，接收端须按消息标识去重。推荐：2默认：2示例：2	同步发送失败的重试次数，先用推荐值。重试可能带来重复消息，接收端须按消息标识去重；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
异步发送重试次数	异步发送失败时的自动重试次数；该值供消息推送任务使用；运行任务需重新加载变更。	先采用本类型推荐模式，再根据实际负载、接口约定和运行指标调整。	仅影响异步发送方式的失败重试；不决定任务是否采用异步发送。先保持推荐，不要当成所有发送的统一重试开关。推荐：2默认：2示例：2	仅影响异步发送方式的失败重试；不决定任务是否采用异步发送。先保持推荐，不要当成所有发送的统一重试开关；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
失败切换 Broker	发送失败后是否尝试切换到下一个 Broker；该值供消息推送任务使用；运行任务需重新加载变更。	先采用本类型推荐模式，再根据实际负载、接口约定和运行指标调整。	允许在发送失败或存储异常时尝试其他 Broker；部署有可用路由才有意义，不能替代修复集群故障。推荐：开启（true）默认：开启（true）示例：开启（true）	允许在发送失败或存储异常时尝试其他 Broker；部署有可用路由才有意义，不能替代修复集群故障；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
启用 VIP 通道	是否启用 VIP 通道，通常内网环境会关闭；该值供消息推送任务使用；运行任务需重新加载变更。	先采用本类型推荐模式，再根据实际负载、接口约定和运行指标调整。	没有管理员明确要求时保持关闭。开启前确认对应 Broker 端口、防火墙和部署支持，否则会连错端口。推荐：关闭（false）默认：关闭（false）示例：关闭（false）	没有管理员明确要求时保持关闭。开启前确认对应 Broker 端口、防火墙和部署支持，否则会连错端口；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要

消息推送 · RocketMQ

字段	用途	值从哪里来	怎么选择	填错表现与恢复	生效条件
压缩阈值	消息体超过该大小时自动压缩；该值供消息推送任务使用；运行任务需重新加载变更。	先采用本类型推荐模式，再根据实际负载、接口约定和运行指标调整。	单位字节，正文超过阈值后才压缩。根据消息大小和 CPU 预算调整，普通联调使用推荐值。推荐：4096默认：4096示例：4096	单位字节，正文超过阈值后才压缩。根据消息大小和 CPU 预算调整，普通联调使用推荐值；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
最大消息大小	允许发送的单条消息最大字节数；该值供消息推送任务使用；运行任务需重新加载变更。	先采用本类型推荐模式，再根据实际负载、接口约定和运行指标调整。	单位字节，须与 Broker 限制协调。过大消息先拆分或精简；不要只改客户端使其超过服务端上限。推荐：4194304默认：4194304示例：4194304	单位字节，须与 Broker 限制协调。过大消息先拆分或精简；不要只改客户端使其超过服务端上限；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要

消息推送 · MQTT

字段	用途	值从哪里来	怎么选择	填错表现与恢复	生效条件
推荐模式	为消息推送选择一组参数预设；选完后再填写真实环境信息；作用于当前连接器，任务启用与业务结果需另行确认。	平台为本类型提供的推荐模式。	外部 Broker：复用同一组 MQTT 客户端连接参数，把消息发布到第三方平台。推荐：外部 Broker默认：—示例：—外部 Broker：复用同一组 MQTT 客户端连接参数，把消息发布到第三方平台；覆盖本通道预设参数，随后须重新核对连接信息。	配置变更可能影响引用它的任务；保留原配置，修正后复测。	范围：当前连接器及引用它的任务发布：不需要 · 重启：不需要 · 重连：不需要
必填 clientId	第三方 MQTT 平台识别当前发布客户端的唯一标识；该值供消息推送任务使用；运行任务需重新加载变更。	外部系统部署及对接清单；客户端实例名称由实施人员按环境和用途指定。	这是 FMQ 连接外部 MQTT Broker 的客户端 ID，不是被控制设备的 ID。按环境和上下行分别命名，避免与在线客户端重复造成互相挤下线。推荐：按对接资料填写默认：—示例：fmq-push-client	这是 FMQ 连接外部 MQTT Broker 的客户端 ID，不是被控制设备的 ID。按环境和上下行分别命名，避免与在线客户端重复造成互相挤下线；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
必填 host	第三方 MQTT Broker 地址；未填写协议时默认按 tcp:// 连接；该值供消息推送任务使用；运行任务需重新加载变更。	外部系统部署及对接清单；客户端实例名称由实施人员按环境和用途指定。	从对接方部署清单取地址，必须能被 FMQ 服务器访问。截图中的本机地址仅为示例；不要把浏览器所在电脑的地址误当成服务端地址。推荐：按对接资料填写默认：—示例：broker.example.com	从对接方部署清单取地址，必须能被 FMQ 服务器访问。截图中的本机地址仅为示例；不要把浏览器所在电脑的地址误当成服务端地址；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
必填 port	第三方 MQTT Broker 端口；该值供消息推送任务使用；运行任务需重新加载变更。	外部系统部署及对接清单；客户端实例名称由实施人员按环境和用途指定。	从外部 MQTT Broker 管理员取得数据端口，常见 1883；加密入口需与协议匹配。不能填管理网页端口。推荐：按对接资料填写默认：1883示例：1883	从外部 MQTT Broker 管理员取得数据端口，常见 1883；加密入口需与协议匹配。不能填管理网页端口；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
必填 userName	连接第三方 MQTT Broker 使用的用户名；该值供消息推送任务使用；运行任务需重新加载变更。	外部系统部署及对接清单；客户端实例名称由实施人员按环境和用途指定。	当前消息推送表单将用户名列为必填，必须从外部 Broker 管理员取得业务账号，不能因 Broker 允许匿名就直接留空；同时确认目标 Topic 的发布权限。推荐：按对接资料填写默认：—示例：mqtt_user	当前消息推送表单将用户名列为必填，必须从外部 Broker 管理员取得业务账号，不能因 Broker 允许匿名就直接留空；同时确认目标 Topic 的发布权限；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
必填 passWord	连接第三方 MQTT Broker 使用的密码；该值供消息推送任务使用；运行任务需重新加载变更。	对接管理员通过受控渠道提供，实际值不进入手册或日志。	当前消息推送表单将密码列为必填，由外部 Broker 管理员安全提供。图中的星号提示不代表已经填写；不要公开实际值或把掩码当作密码。推荐：按对接资料填写默认：敏感值不展示示例：通过受控渠道填写	当前消息推送表单将密码列为必填，由外部 Broker 管理员安全提供。图中的星号提示不代表已经填写；不要公开实际值或把掩码当作密码；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要

消息推送 · WebHook

字段	用途	值从哪里来	怎么选择	填错表现与恢复	生效条件
推荐模式	为消息推送选择一组参数预设；选完后再填写真实环境信息；作用于当前连接器，任务启用与业务结果需另行确认。	平台为本类型提供的推荐模式。	测试推荐：适合本地联调，快速验证回调地址是否可用。；生产推荐：适合正式环境，保留合理超时，避免回调阻塞过久。推荐：生产推荐默认：—示例：—测试推荐：适合本地联调，快速验证回调地址是否可用；覆盖本通道预设参数，随后须重新核对连接信息。生产推荐：适合正式环境，保留合理超时，避免回调阻塞过久；覆盖本通道预设参数，随后须重新核对连接信息。	配置变更可能影响引用它的任务；保留原配置，修正后复测。	范围：当前连接器及引用它的任务发布：不需要 · 重启：不需要 · 重连：不需要
必填 请求地址	Webhook 的完整请求地址；该值供消息推送任务使用；运行任务需重新加载变更。	外部系统部署及对接清单；客户端实例名称由实施人员按环境和用途指定。	由接收方提供完整请求地址，含协议和路径。先使用获准的测试接口；点击测试连接会真实请求对方，不能指向会扣费或直接控制设备的接口。推荐：按对接资料填写默认：http://127.0.0.1:8080/webhook示例：http://127.0.0.1:8080/webhook	由接收方提供完整请求地址，含协议和路径。先使用获准的测试接口；点击测试连接会真实请求对方，不能指向会扣费或直接控制设备的接口；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
请求方法	HTTP 请求方法，常见为 POST 或 PUT；该值供消息推送任务使用；运行任务需重新加载变更。	先采用本类型推荐模式，再根据实际负载、接口约定和运行指标调整。	严格按对方接口文档选择 POST、PUT 或 PATCH；选错常见结果为方法不允许或业务拒绝。不是靠试遍选项判断接口协议。推荐：POST默认：POST示例：POSTPOST：按接口文档提交数据；测试也会真实调用；更换后按POST处理该字段。PUT：按接口文档提交或替换资源，不能当成无副作用检查；更换后按PUT处理该字段。PATCH：按接口文档局部更新，须用安全测试目标；更换后按PATCH处理该字段。	严格按对方接口文档选择 POST、PUT 或 PATCH；选错常见结果为方法不允许或业务拒绝。不是靠试遍选项判断接口协议；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
请求超时（秒）	HTTP 请求超时时间，单位秒；该值供消息推送任务使用；运行任务需重新加载变更。	先采用本类型推荐模式，再根据实际负载、接口约定和运行指标调整。	这里单位是秒，不是其他 MQ 字段的毫秒。按接口响应约定填写；超时先查接收端日志和网络。推荐：15默认：15示例：15	这里单位是秒，不是其他 MQ 字段的毫秒。按接口响应约定填写；超时先查接收端日志和网络；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要

指令下行参数参考

Kafka：对方已经使用 Kafka，且约定了 Topic 与消费方式时选择。

填写 Broker、独立消费组和并发策略。Producer 是发消息，Consumer 是读消息，两套配置不能互抄。订阅来源还要在指令下行任务中配置。

参数校验边界：校验会检查消费组非空及集群访问，但不代表已经订阅、消费或将指令送到设备。联调不要复用正在处理生产消息的消费组。

RabbitMQ：对方用交换机、路由键和队列组织消息时选择 RabbitMQ。

单独填写外部系统投递的消费队列，并核对 vhost、交换机和绑定路由键。优先保留生产推荐的手动确认，再按处理能力选择预取数量。

参数校验边界：校验会检查队列，并按开关声明交换机、声明队列或绑定。它不证明队列中的指令已被设备接收；请先获准使用这些资源。

RocketMQ：对方已使用 RocketMQ，并提供 NameServer、组名及 Topic 规划时选择。

先用隔离的测试 Topic 和消费组，填写订阅 Topic、Tag、消费起点及线程数。不要直接使用有积压生产指令的通道进行参数测试。

参数校验边界：重要：当前校验会短暂启动真实消费者，并可能消费、确认消息，不是纯只读检查。路由检查成功仍不证明设备收到指令，首次联调应由管理员准备隔离资源。

MQTT：对方提供 MQTT Broker，双方按 Topic 发布、订阅时选择。

填写外部 Broker 与订阅 Topic，使用独立 Client ID；接入模式保持订阅入口。外部系统发布 Alink 指令到约定 Topic，平台再交给下行任务处理。

参数校验边界：图中下行已就绪但上行还缺必填项，因此不能测试全部通道；仅需下行时取消上行能力，需要双向时补齐另一通道。校验只检查 Topic 已填写并探测 Broker 连接，不证明订阅权限、报文或设备路由可用。

WebHook：上行是平台调用对方回调地址；下行则是对方调用平台入口。先分清谁调用谁。

配置平台入口路径与 Token，通过受控渠道交给外部系统；不要在这里填写上行回调 URL。还需在指令下行任务中启用入口并确定实际任务地址。

参数校验边界：此处只检查鉴权参数准备情况，不会替外部系统发起调用，也不证明公网入口、反向代理或设备下发链路已通。

HTTP：外部系统主动调用平台接口下发指令时选择，当前仅有下行能力。

仅开启指令下行，选择 HTTP，保留入口路径形式并填写受控 Token。由实施人员提供包含实际任务标识的可访问入口，外部系统按约定调用。

参数校验边界：HTTP 下行与 WebHook 下行均经过 Token 鉴权进入统一链路。参数检查通过只证明入口参数具备，不证明外部调用或设备执行；不要把 {id} 原样当作最终地址。

界面参考

指令下行 / Kafka

图：前次白天模式页面截图，用于定位字段，不作为本次配置或连通成功证明。长表单其余字段请在页面向下滚动，完整解释见本节。

指令下行 / RabbitMQ

图：前次白天模式页面截图，用于定位字段，不作为本次配置或连通成功证明。长表单其余字段请在页面向下滚动，完整解释见本节。

指令下行 / RocketMQ

图：前次白天模式页面截图，用于定位字段，不作为本次配置或连通成功证明。长表单其余字段请在页面向下滚动，完整解释见本节。

指令下行 / MQTT

图：前次白天模式页面截图，用于定位字段，不作为本次配置或连通成功证明。长表单其余字段请在页面向下滚动，完整解释见本节。

指令下行 / WebHook

图：前次白天模式页面截图，用于定位字段，不作为本次配置或连通成功证明。长表单其余字段请在页面向下滚动，完整解释见本节。

指令下行 / HTTP

图：前次白天模式页面截图，用于定位字段，不作为本次配置或连通成功证明。长表单其余字段请在页面向下滚动，完整解释见本节。

指令下行 · Kafka

字段	用途	值从哪里来	怎么选择	填错表现与恢复	生效条件
推荐模式	为指令下行选择一组参数预设；选完后再填写真实环境信息；作用于当前连接器，任务启用与业务结果需另行确认。	平台为本类型提供的推荐模式。	测试推荐：适合本地联调，优先缩短拉取等待时间，快速消费验证消息。；实时优先：优先降低指令到达平台后的处理延迟，适合实时控制。；高吞吐：适合批量命令或回放场景，提高单次拉取数量和并发能力。；生产推荐：兼顾稳定性和吞吐，适合作为生产环境的默认消费配置。推荐：生产推荐默认：—示例：—测试推荐：适合本地联调，优先缩短拉取等待时间，快速消费验证消息；覆盖本通道预设参数，随后须重新核对连接信息。实时优先：优先降低指令到达平台后的处理延迟，适合实时控制；覆盖本通道预设参数，随后须重新核对连接信息。高吞吐：适合批量命令或回放场景，提高单次拉取数量和并发能力；覆盖本通道预设参数，随后须重新核对连接信息。生产推荐：兼顾稳定性和吞吐，适合作为生产环境的默认消费配置；覆盖本通道预设参数，随后须重新核对连接信息。	配置变更可能影响引用它的任务；保留原配置，修正后复测。	范围：当前连接器及引用它的任务发布：不需要 · 重启：不需要 · 重连：不需要
必填 Broker 地址	Kafka 集群地址，多个地址用逗号分隔；该值供指令下行任务使用；运行任务需重新加载变更。	外部系统部署及对接清单；客户端实例名称由实施人员按环境和用途指定。	向 Kafka 管理员索取客户端可访问的 host:port 清单，多项用英文逗号分隔。127.0.0.1 指 FMQ 所在服务器，不是操作人员电脑；连不上先查端口与集群公布的地址。推荐：按对接资料填写默认：127.0.0.1:9092示例：127.0.0.1:9092	向 Kafka 管理员索取客户端可访问的 host:port 清单，多项用英文逗号分隔。127.0.0.1 指 FMQ 所在服务器，不是操作人员电脑；连不上先查端口与集群公布的地址；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
必填 消费组	指令下行所属的消费者组 ID；该值供指令下行任务使用；运行任务需重新加载变更。	外部系统部署及对接清单；客户端实例名称由实施人员按环境和用途指定。	与 Kafka 管理员约定消费组。相同组通常分担消息，不同组可各读一份；复用生产组可能抢走其他应用的指令，联调使用独立组。推荐：按对接资料填写默认：fmq-downstream-ingress-group示例：fmq-downstream-ingress-group	与 Kafka 管理员约定消费组。相同组通常分担消息，不同组可各读一份；复用生产组可能抢走其他应用的指令，联调使用独立组；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
并发实例数	当前指令下行启动的消费者并发数；该值供指令下行任务使用；运行任务需重新加载变更。	先采用本类型推荐模式，再根据实际负载、接口约定和运行指标调整。	是消费者并发数，不是 Broker 节点数。按分区数量和处理能力设置，超过可分配分区时部分实例空闲；先低并发验证。推荐：2默认：1示例：1	是消费者并发数，不是 Broker 节点数。按分区数量和处理能力设置，超过可分配分区时部分实例空闲；先低并发验证；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
起始消费位置	当消费组无位点时从 earliest 或 latest 开始消费；该值供指令下行任务使用；运行任务需重新加载变更。	先采用本类型推荐模式，再根据实际负载、接口约定和运行指标调整。	只在该消费组没有有效位点时决定从哪里读；已有位点不会因切换此选项自动回放。latest 避免旧指令，earliest 用于明确需要的历史回放。推荐：latest默认：latest示例：latest最新消息（latest）：没有有效位点时从新消息开始，减少执行历史指令的风险；更换后按最新消息（latest）处理该字段。最早消息（earliest）：没有有效位点时从最早保留数据开始，可能回放旧指令；更换后按最早消息（earliest）处理该字段。	只在该消费组没有有效位点时决定从哪里读；已有位点不会因切换此选项自动回放。latest 避免旧指令，earliest 用于明确需要的历史回放；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
单次拉取记录数	每次 poll 最多获取多少条消息；该值供指令下行任务使用；运行任务需重新加载变更。	先采用本类型推荐模式，再根据实际负载、接口约定和运行指标调整。	每次最多拉取的消息条数。调大后必须能在拉取最大间隔内处理完；慢业务优先减小批量。推荐：500默认：500示例：500	每次最多拉取的消息条数。调大后必须能在拉取最大间隔内处理完；慢业务优先减小批量；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
最大等待时间	Broker 为凑齐拉取批量最多等待多久；该值供指令下行任务使用；运行任务需重新加载变更。	先采用本类型推荐模式，再根据实际负载、接口约定和运行指标调整。	单位毫秒，需结合最小拉取字节数理解。实时指令用较小等待，批量场景可适当增加。推荐：500默认：500示例：500	单位毫秒，需结合最小拉取字节数理解。实时指令用较小等待，批量场景可适当增加；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
会话超时	Broker 判断消费者失联的时间窗口；该值供指令下行任务使用；运行任务需重新加载变更。	先采用本类型推荐模式，再根据实际负载、接口约定和运行指标调整。	单位毫秒，需落在 Broker 允许范围内。过短可能误判掉线并反复重新分配分区；先查运行抖动。推荐：45000默认：45000示例：45000	单位毫秒，需落在 Broker 允许范围内。过短可能误判掉线并反复重新分配分区；先查运行抖动；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
心跳间隔	消费者向 Broker 发送心跳的间隔；该值供指令下行任务使用；运行任务需重新加载变更。	先采用本类型推荐模式，再根据实际负载、接口约定和运行指标调整。	单位毫秒，应小于会话超时并留出余量。不要把心跳间隔设得比失联判定时间还长。推荐：15000默认：15000示例：15000	单位毫秒，应小于会话超时并留出余量。不要把心跳间隔设得比失联判定时间还长；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
请求超时	消费者请求 Broker 的超时时间；该值供指令下行任务使用；运行任务需重新加载变更。	先采用本类型推荐模式，再根据实际负载、接口约定和运行指标调整。	单位毫秒，取推荐值后根据网络和 Broker 响应调整。过短会误报超时，过长会延后故障发现；先排查慢请求。推荐：30000默认：30000示例：30000	单位毫秒，取推荐值后根据网络和 Broker 响应调整。过短会误报超时，过长会延后故障发现；先排查慢请求；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
必填 Key 反序列化器	消息 Key 的反序列化类，默认使用 Kafka 常用的 StringDeserializer；该值供指令下行任务使用；运行任务需重新加载变更。	先采用本类型推荐模式，再根据实际负载、接口约定和运行指标调整。	把 Kafka Key 字节转成平台对象的类名，文本通常保留 StringDeserializer。与发送方不一致会解析失败。推荐：org.apache.kafka.common.serialization.StringDeserializer默认：org.apache.kafka.common.serialization.StringDeserializer示例：org.apache.kafka.common.serialization.StringDeserializer	把 Kafka Key 字节转成平台对象的类名，文本通常保留 StringDeserializer。与发送方不一致会解析失败；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
必填 Value 反序列化器	消息 Value 的反序列化类，默认使用 Kafka 常用的 StringDeserializer；该值供指令下行任务使用；运行任务需重新加载变更。	先采用本类型推荐模式，再根据实际负载、接口约定和运行指标调整。	把 Kafka 正文转回文本的类名，JSON 文本通常保留 StringDeserializer；这只负责解码，不代替 Alink 指令校验。推荐：org.apache.kafka.common.serialization.StringDeserializer默认：org.apache.kafka.common.serialization.StringDeserializer示例：org.apache.kafka.common.serialization.StringDeserializer	把 Kafka 正文转回文本的类名，JSON 文本通常保留 StringDeserializer；这只负责解码，不代替 Alink 指令校验；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要

指令下行 · Kafka

字段	用途	值从哪里来	怎么选择	填错表现与恢复	生效条件
客户端 ID 前缀	用于生成消费者 client.id 前缀，运行时会自动追加唯一后缀；该值供指令下行任务使用；运行任务需重新加载变更。	外部系统部署及对接清单；客户端实例名称由实施人员按环境和用途指定。	用于在 Broker 日志中识别本连接，不是设备 ID，也不决定消息发到哪里。由实施人员按用途命名；不要用它代替消费组。推荐：按对接资料填写默认：fmq-downstream-ingress-consumer示例：fmq-downstream-ingress-consumer	用于在 Broker 日志中识别本连接，不是设备 ID，也不决定消息发到哪里。由实施人员按用途命名；不要用它代替消费组；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
拉取最大间隔	两次 poll 之间允许的最长间隔；该值供指令下行任务使用；运行任务需重新加载变更。	先采用本类型推荐模式，再根据实际负载、接口约定和运行指标调整。	单位毫秒，必须覆盖一次批量处理的耗时。超限可能导致重新分配分区；优先优化慢处理或减小批量。推荐：300000默认：300000示例：300000	单位毫秒，必须覆盖一次批量处理的耗时。超限可能导致重新分配分区；优先优化慢处理或减小批量；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
最小拉取字节数	Broker 至少累计多少字节后再返回消息；该值供指令下行任务使用；运行任务需重新加载变更。	先采用本类型推荐模式，再根据实际负载、接口约定和运行指标调整。	单位字节，增大可减少小批请求，但可能让小流量指令等待。实时场景先使用实时优先。推荐：1默认：1示例：1	单位字节，增大可减少小批请求，但可能让小流量指令等待。实时场景先使用实时优先；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要

指令下行 · RabbitMQ

字段	用途	值从哪里来	怎么选择	填错表现与恢复	生效条件
推荐模式	为指令下行选择一组参数预设；选完后再填写真实环境信息；作用于当前连接器，任务启用与业务结果需另行确认。	平台为本类型提供的推荐模式。	测试推荐：适合联调环境，便于快速验证消费链路与 ACK 行为。；实时优先：降低单批缓存，缩短单条指令的等待时间。；高吞吐：适合高频轻量命令消费，提高预取窗口与批处理能力。；生产推荐：兼顾恢复能力、手动确认和失败重回队列，适合作为生产默认值。推荐：生产推荐默认：—示例：—测试推荐：适合联调环境，便于快速验证消费链路与 ACK 行为；覆盖本通道预设参数，随后须重新核对连接信息。实时优先：降低单批缓存，缩短单条指令的等待时间；覆盖本通道预设参数，随后须重新核对连接信息。高吞吐：适合高频轻量命令消费，提高预取窗口与批处理能力；覆盖本通道预设参数，随后须重新核对连接信息。生产推荐：兼顾恢复能力、手动确认和失败重回队列，适合作为生产默认值；覆盖本通道预设参数，随后须重新核对连接信息。	配置变更可能影响引用它的任务；保留原配置，修正后复测。	范围：当前连接器及引用它的任务发布：不需要 · 重启：不需要 · 重连：不需要
必填 主机地址	RabbitMQ 服务器地址；该值供指令下行任务使用；运行任务需重新加载变更。	外部系统部署及对接清单；客户端实例名称由实施人员按环境和用途指定。	从对接方部署清单取地址，必须能被 FMQ 服务器访问。截图中的本机地址仅为示例；不要把浏览器所在电脑的地址误当成服务端地址。推荐：按对接资料填写默认：127.0.0.1示例：127.0.0.1	从对接方部署清单取地址，必须能被 FMQ 服务器访问。截图中的本机地址仅为示例；不要把浏览器所在电脑的地址误当成服务端地址；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
必填 端口	RabbitMQ AMQP 端口；该值供指令下行任务使用；运行任务需重新加载变更。	外部系统部署及对接清单；客户端实例名称由实施人员按环境和用途指定。	向管理员取得 AMQP 数据端口，常见 5672；管理页面常用的 15672 不能填在这里。以实际部署为准，连接拒绝时先核对端口与防火墙。推荐：按对接资料填写默认：5672示例：5672	向管理员取得 AMQP 数据端口，常见 5672；管理页面常用的 15672 不能填在这里。以实际部署为准，连接拒绝时先核对端口与防火墙；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
必填 用户名	连接 RabbitMQ 的用户名；该值供指令下行任务使用；运行任务需重新加载变更。	外部系统部署及对接清单；客户端实例名称由实施人员按环境和用途指定。	从 RabbitMQ 管理员取得专用业务账号，并确认对应 vhost 权限。不要直接沿用示例 guest；远程登录或权限不足会失败。推荐：按对接资料填写默认：guest示例：guest	从 RabbitMQ 管理员取得专用业务账号，并确认对应 vhost 权限。不要直接沿用示例 guest；远程登录或权限不足会失败；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
必填 消费队列	平台监听并读取下行指令的队列名称；该值供指令下行任务使用；运行任务需重新加载变更。	外部系统部署及对接清单；客户端实例名称由实施人员按环境和用途指定。	从 RabbitMQ 管理端取得外部系统实际投递的消费队列。它不是交换机；同队列多个消费者会分担消息，联调用独立队列避免抢走生产指令。推荐：按对接资料填写默认：fmq.dispatch.queue示例：fmq.dispatch.queue	从 RabbitMQ 管理端取得外部系统实际投递的消费队列。它不是交换机；同队列多个消费者会分担消息，联调用独立队列避免抢走生产指令；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
密码	连接 RabbitMQ 的密码；该值供指令下行任务使用；运行任务需重新加载变更。	对接管理员通过受控渠道提供，实际值不进入手册或日志。	与当前用户名配套，由管理员通过受控渠道提供。表单标为推荐不等于 Broker 允许空密码；保存或复用时不要把掩码当成新密码。推荐：按对接资料填写默认：敏感值不展示示例：通过受控渠道填写	与当前用户名配套，由管理员通过受控渠道提供。表单标为推荐不等于 Broker 允许空密码；保存或复用时不要把掩码当成新密码；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
虚拟主机	RabbitMQ 的 vhost，用于隔离不同业务环境；该值供指令下行任务使用；运行任务需重新加载变更。	外部系统部署及对接清单；客户端实例名称由实施人员按环境和用途指定。	在 RabbitMQ 管理端查看本业务的 vhost，像同一 Broker 内的独立工作区。两端用错 vhost 时，即使队列同名也不是同一条通道；账号还必须有该 vhost 权限。推荐：按对接资料填写默认：/示例：/	在 RabbitMQ 管理端查看本业务的 vhost，像同一 Broker 内的独立工作区。两端用错 vhost 时，即使队列同名也不是同一条通道；账号还必须有该 vhost 权限；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
预取数量	单个消费者在未确认前最多预取多少条消息；该值供指令下行任务使用；运行任务需重新加载变更。	先采用本类型推荐模式，再根据实际负载、接口约定和运行指标调整。	指未确认前最多预取的条数。慢设备或严格逐条处理可减小，高吞吐才逐步增加；太大容易堆在消费者内存中。推荐：32默认：32示例：32	指未确认前最多预取的条数。慢设备或严格逐条处理可减小，高吞吐才逐步增加；太大容易堆在消费者内存中；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
自动确认	是否在收到消息后立即自动 ack；该值供指令下行任务使用；运行任务需重新加载变更。	先采用本类型推荐模式，再根据实际负载、接口约定和运行指标调整。	开启后收到即确认，后续处理失败可能无法重试；生产通常关闭。手动确认也不自动等同设备已经执行成功，仍需设备结果。推荐：关闭（false）默认：关闭（false）示例：关闭（false）	开启后收到即确认，后续处理失败可能无法重试；生产通常关闭。手动确认也不自动等同设备已经执行成功，仍需设备结果；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
失败重新入队	消息处理失败时是否重新入队等待再次消费；该值供指令下行任务使用；运行任务需重新加载变更。	先采用本类型推荐模式，再根据实际负载、接口约定和运行指标调整。	开启可将处理失败消息重新入队，需保证幂等。持续失败的坏消息可能反复循环；先排查报文和业务错误，不要任其无限重试。推荐：开启（true）默认：开启（true）示例：开启（true）	开启可将处理失败消息重新入队，需保证幂等。持续失败的坏消息可能反复循环；先排查报文和业务错误，不要任其无限重试；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
心跳间隔	与 Broker 协商的心跳间隔，单位秒；该值供指令下行任务使用；运行任务需重新加载变更。	先采用本类型推荐模式，再根据实际负载、接口约定和运行指标调整。	单位秒，用于检测连接是否还活着。先保留推荐值，频繁断线时查网络和 Broker 负载，不要盲目关闭心跳。推荐：30默认：30示例：30	单位秒，用于检测连接是否还活着。先保留推荐值，频繁断线时查网络和 Broker 负载，不要盲目关闭心跳；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
自动恢复	连接异常断开后是否自动恢复；该值供指令下行任务使用；运行任务需重新加载变更。	先采用本类型推荐模式，再根据实际负载、接口约定和运行指标调整。	开启可在网络异常后尝试恢复连接。通常保留开启，但错误凭据、被删除的资源仍需人工修正；自动恢复不是数据不丢的承诺。推荐：开启（true）默认：开启（true）示例：开启（true）	开启可在网络异常后尝试恢复连接。通常保留开启，但错误凭据、被删除的资源仍需人工修正；自动恢复不是数据不丢的承诺；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要

指令下行 · RabbitMQ

字段	用途	值从哪里来	怎么选择	填错表现与恢复	生效条件
路由键	队列绑定的路由键；该值供指令下行任务使用；运行任务需重新加载变更。	外部系统部署及对接清单；客户端实例名称由实施人员按环境和用途指定。	与外部发布方、交换机绑定规则一致；例如按约定用 device.command。拼写或类型匹配错误时，连接正常但队列仍可能收不到消息。推荐：按对接资料填写默认：device.command示例：device.command	与外部发布方、交换机绑定规则一致；例如按约定用 device.command。拼写或类型匹配错误时，连接正常但队列仍可能收不到消息；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
交换机	消费链路关联的交换机名称；该值供指令下行任务使用；运行任务需重新加载变更。	外部系统部署及对接清单；客户端实例名称由实施人员按环境和用途指定。	向 MQ 管理员确认交换机名称与类型。交换机负责转送消息，队列负责存放消息；有交换机并不保证已绑定目标队列。推荐：按对接资料填写默认：fmq.dispatch.exchange示例：fmq.dispatch.exchange	向 MQ 管理员确认交换机名称与类型。交换机负责转送消息，队列负责存放消息；有交换机并不保证已绑定目标队列；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
交换机类型	交换机类型，常见有 direct、topic、fanout、headers；该值供指令下行任务使用；运行任务需重新加载变更。	先采用本类型推荐模式，再根据实际负载、接口约定和运行指标调整。	必须与现有交换机一致。direct 按完整路由键匹配，topic 按主题模式匹配，fanout 广播到绑定队列，headers 按头属性匹配。选错已有资源类型会声明失败。推荐：topic默认：topic示例：topicTopic：按主题模式匹配路由键；更换后按Topic处理该字段。Direct：完整路由键匹配；更换后按Direct处理该字段。Fanout：投递给全部绑定队列，不按路由键筛选；更换后按Fanout处理该字段。Headers：按消息头匹配，须另行约定头属性与绑定参数；更换后按Headers处理该字段。	必须与现有交换机一致。direct 按完整路由键匹配，topic 按主题模式匹配，fanout 广播到绑定队列，headers 按头属性匹配。选错已有资源类型会声明失败；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
自动声明交换机	是否自动声明消费使用的交换机；该值供指令下行任务使用；运行任务需重新加载变更。	先采用本类型推荐模式，再根据实际负载、接口约定和运行指标调整。	开启允许在校验或运行时声明交换机，需要创建权限；关闭则要求交换机已存在。复用生产资源前向管理员确认，不能擅自改已有资源类型。推荐：开启（true）默认：开启（true）示例：开启（true）	开启允许在校验或运行时声明交换机，需要创建权限；关闭则要求交换机已存在。复用生产资源前向管理员确认，不能擅自改已有资源类型；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
自动声明队列	是否自动声明平台消费使用的队列；该值供指令下行任务使用；运行任务需重新加载变更。	先采用本类型推荐模式，再根据实际负载、接口约定和运行指标调整。	开启允许创建队列，需要资源权限；关闭要求队列预先存在。已有队列属性不匹配时请管理员核对，不要删除队列来消除报错。推荐：开启（true）默认：开启（true）示例：开启（true）	开启允许创建队列，需要资源权限；关闭要求队列预先存在。已有队列属性不匹配时请管理员核对，不要删除队列来消除报错；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
自动绑定队列	存在交换机时，是否按路由键把队列自动绑定到交换机；该值供指令下行任务使用；运行任务需重新加载变更。	先采用本类型推荐模式，再根据实际负载、接口约定和运行指标调整。	开启会按交换机和路由键绑定消费队列，需要绑定权限。由管理员维护绑定时可关闭，但应先确认关系已存在。推荐：开启（true）默认：开启（true）示例：开启（true）	开启会按交换机和路由键绑定消费队列，需要绑定权限。由管理员维护绑定时可关闭，但应先确认关系已存在；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
持久化资源	队列或交换机是否持久化；该值供指令下行任务使用；运行任务需重新加载变更。	先采用本类型推荐模式，再根据实际负载、接口约定和运行指标调整。	持久化的是交换机或队列的资源定义，不等于每条消息都已可靠保存。与现有资源属性必须一致；不一致时先核对，切勿删除业务队列重建。推荐：开启（true）默认：开启（true）示例：开启（true）	持久化的是交换机或队列的资源定义，不等于每条消息都已可靠保存。与现有资源属性必须一致；不一致时先核对，切勿删除业务队列重建；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
自动删除	在无消费者后是否自动删除资源；该值供指令下行任务使用；运行任务需重新加载变更。	先采用本类型推荐模式，再根据实际负载、接口约定和运行指标调整。	生产长驻通道通常关闭。开启会让资源在满足 Broker 的自动删除条件时消失；临时联调才考虑，勿用于需长期保留的业务队列。推荐：关闭（false）默认：关闭（false）示例：关闭（false）	生产长驻通道通常关闭。开启会让资源在满足 Broker 的自动删除条件时消失；临时联调才考虑，勿用于需长期保留的业务队列；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
连接超时	建立连接的超时时间；该值供指令下行任务使用；运行任务需重新加载变更。	先采用本类型推荐模式，再根据实际负载、接口约定和运行指标调整。	单位毫秒，是建连等待上限。失败先查地址、端口、防火墙和权限；网络通后再考虑调整时长。推荐：15000默认：15000示例：15000	单位毫秒，是建连等待上限。失败先查地址、端口、防火墙和权限；网络通后再考虑调整时长；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
重连间隔	自动恢复启用时，两次网络重连之间的间隔；该值供指令下行任务使用；运行任务需重新加载变更。	先采用本类型推荐模式，再根据实际负载、接口约定和运行指标调整。	单位毫秒，仅在自动恢复启用时有意义。太短会不断冲击故障 Broker，太长会延迟恢复；先使用生产推荐。推荐：5000默认：5000示例：5000	单位毫秒，仅在自动恢复启用时有意义。太短会不断冲击故障 Broker，太长会延迟恢复；先使用生产推荐；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
消费者标识	消费端的显示名称，便于定位；该值供指令下行任务使用；运行任务需重新加载变更。	外部系统部署及对接清单；客户端实例名称由实施人员按环境和用途指定。	这是 RabbitMQ 里显示的消费者名称，由实施人员按用途命名，用于排障，不是队列名或设备 ID。推荐：按对接资料填写默认：fmq-downstream-ingress-consumer示例：fmq-downstream-ingress-consumer	这是 RabbitMQ 里显示的消费者名称，由实施人员按用途命名，用于排障，不是队列名或设备 ID；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要

指令下行 · RocketMQ

字段	用途	值从哪里来	怎么选择	填错表现与恢复	生效条件
推荐模式	为指令下行选择一组参数预设；选完后再填写真实环境信息；作用于当前连接器，任务启用与业务结果需另行确认。	平台为本类型提供的推荐模式。	测试推荐：适合联调环境，保持轻量线程数与基础批量拉取。；实时优先：优先降低指令消费延迟，减少单批处理规模。；高吞吐：适合批量命令或历史重放，提高拉取批量和线程池规模。；生产推荐：兼顾稳定性与消费效率，适合作为生产默认配置。推荐：生产推荐默认：—示例：—测试推荐：适合联调环境，保持轻量线程数与基础批量拉取；覆盖本通道预设参数，随后须重新核对连接信息。实时优先：优先降低指令消费延迟，减少单批处理规模；覆盖本通道预设参数，随后须重新核对连接信息。高吞吐：适合批量命令或历史重放，提高拉取批量和线程池规模；覆盖本通道预设参数，随后须重新核对连接信息。生产推荐：兼顾稳定性与消费效率，适合作为生产默认配置；覆盖本通道预设参数，随后须重新核对连接信息。	配置变更可能影响引用它的任务；保留原配置，修正后复测。	范围：当前连接器及引用它的任务发布：不需要 · 重启：不需要 · 重连：不需要
必填 NameServer 地址	RocketMQ NameServer 地址；该值供指令下行任务使用；运行任务需重新加载变更。	外部系统部署及对接清单；客户端实例名称由实施人员按环境和用途指定。	从 RocketMQ 管理员索取 NameServer 地址，多地址格式按页面提示。不是 Broker 地址；取不到路由先检查地址和网络。推荐：按对接资料填写默认：127.0.0.1:9876示例：127.0.0.1:9876	从 RocketMQ 管理员索取 NameServer 地址，多地址格式按页面提示。不是 Broker 地址；取不到路由先检查地址和网络；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
必填 消费组	平台监听外部 Alink 指令消息使用的消费组；该值供指令下行任务使用；运行任务需重新加载变更。	外部系统部署及对接清单；客户端实例名称由实施人员按环境和用途指定。	与 RocketMQ 管理员约定独立消费组。测试会启动消费者，不得直接复用有待处理生产命令的组和 Topic。推荐：按对接资料填写默认：fmq-downstream-ingress-consumer示例：fmq-downstream-ingress-consumer	与 RocketMQ 管理员约定独立消费组。测试会启动消费者，不得直接复用有待处理生产命令的组和 Topic；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
必填 订阅 Topic	平台接收下发指令所订阅的 Topic；该值供指令下行任务使用；运行任务需重新加载变更。	外部系统部署及对接清单；客户端实例名称由实施人员按环境和用途指定。	由外部发送方和中间件管理员确认订阅主题。必须匹配外部实际发布位置；接收到了主题消息仍需通过 Alink 内容与设备目标校验。推荐：按对接资料填写默认：fmq_device_command示例：fmq_device_command	由外部发送方和中间件管理员确认订阅主题。必须匹配外部实际发布位置；接收到了主题消息仍需通过 Alink 内容与设备目标校验；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
订阅 Tag	Tag 过滤表达式，* 表示全部；该值供指令下行任务使用；运行任务需重新加载变更。	外部系统部署及对接清单；客户端实例名称由实施人员按环境和用途指定。	用于在 RocketMQ Topic 内筛选消息，星号表示全部。按约定限定指令类别，写错会出现有消息却收不到的情况。推荐：按对接资料填写默认：示例：	用于在 RocketMQ Topic 内筛选消息，星号表示全部。按约定限定指令类别，写错会出现有消息却收不到的情况；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
消息模式	消费模式，常见为 CLUSTERING 或 BROADCASTING；该值供指令下行任务使用；运行任务需重新加载变更。	先采用本类型推荐模式，再根据实际负载、接口约定和运行指标调整。	CLUSTERING 同组分担处理；BROADCASTING 各消费者都处理一份。控制指令通常避免广播，除非明确需要多实例处理且已防重复。推荐：CLUSTERING默认：CLUSTERING示例：CLUSTERING集群消费（CLUSTERING）：同组消费者分担消息，通常用于平台集群；更换后按集群消费（CLUSTERING）处理该字段。广播消费（BROADCASTING）：各消费者各处理一份，存在重复控制风险；更换后按广播消费（BROADCASTING）处理该字段。	CLUSTERING 同组分担处理；BROADCASTING 各消费者都处理一份。控制指令通常避免广播，除非明确需要多实例处理且已防重复；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
起始消费位置	首次启动时从哪里开始消费；该值供指令下行任务使用；运行任务需重新加载变更。	先采用本类型推荐模式，再根据实际负载、接口约定和运行指标调整。	主要决定新消费组或无有效位点时从哪里开始。历史指令可能过期或产生重复动作；没有回放计划就保持从最新开始。推荐：CONSUME_FROM_LAST_OFFSET默认：CONSUME_FROM_LAST_OFFSET示例：CONSUME_FROM_LAST_OFFSET从最新位点开始：新组通常从最新位置开始；更换后按从最新位点开始处理该字段。从最早位点开始：新组从最早保留位置开始，慎用于控制指令；更换后按从最早位点开始处理该字段。从指定时间开始：按指定时间起读；当前表单未提供时间输入，须先与管理员确认配套配置，初学者不要直接选择；更换后按从指定时间开始处理该字段。	主要决定新消费组或无有效位点时从哪里开始。历史指令可能过期或产生重复动作；没有回放计划就保持从最新开始；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
最小消费线程数	消费线程池最小线程数；该值供指令下行任务使用；运行任务需重新加载变更。	先采用本类型推荐模式，再根据实际负载、接口约定和运行指标调整。	最小线程数不应大于最大值。先低并发验证，再按处理耗时和设备承受能力调高。推荐：4默认：4示例：4	最小线程数不应大于最大值。先低并发验证，再按处理耗时和设备承受能力调高；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
最大消费线程数	消费线程池最大线程数；该值供指令下行任务使用；运行任务需重新加载变更。	先采用本类型推荐模式，再根据实际负载、接口约定和运行指标调整。	限定并发处理上限，不是越大越快。过高可能压垮设备或下游系统，需结合 CPU 与积压检查。推荐：16默认：16示例：16	限定并发处理上限，不是越大越快。过高可能压垮设备或下游系统，需结合 CPU 与积压检查；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
单次拉取批量	每次从 Broker 拉取消息的批量大小；该值供指令下行任务使用；运行任务需重新加载变更。	先采用本类型推荐模式，再根据实际负载、接口约定和运行指标调整。	每次从 Broker 拉取的条数，不同于一次回调处理条数。增大前确认内存与后续处理能力。推荐：32默认：32示例：32	每次从 Broker 拉取的条数，不同于一次回调处理条数。增大前确认内存与后续处理能力；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要

指令下行 · RocketMQ

字段	用途	值从哪里来	怎么选择	填错表现与恢复	生效条件
单批处理条数	一次回调最多处理多少条消息；该值供指令下行任务使用；运行任务需重新加载变更。	先采用本类型推荐模式，再根据实际负载、接口约定和运行指标调整。	一次回调处理多少条消息。批量越大，单次失败影响范围可能越大；实时或风险较高指令先小批量。推荐：4默认：1示例：1	一次回调处理多少条消息。批量越大，单次失败影响范围可能越大；实时或风险较高指令先小批量；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
拉取间隔	两次拉取之间的等待间隔，0 表示尽快拉取；该值供指令下行任务使用；运行任务需重新加载变更。	先采用本类型推荐模式，再根据实际负载、接口约定和运行指标调整。	单位毫秒，0 表示尽快拉取。增大可降低请求频率，但会增加等待；按延迟目标选择。推荐：0默认：0示例：0	单位毫秒，0 表示尽快拉取。增大可降低请求频率，但会增加等待；按延迟目标选择；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
启用 VIP 通道	是否启用 VIP 通道；该值供指令下行任务使用；运行任务需重新加载变更。	先采用本类型推荐模式，再根据实际负载、接口约定和运行指标调整。	没有管理员明确要求时保持关闭。开启前确认对应 Broker 端口、防火墙和部署支持，否则会连错端口。推荐：关闭（false）默认：关闭（false）示例：关闭（false）	没有管理员明确要求时保持关闭。开启前确认对应 Broker 端口、防火墙和部署支持，否则会连错端口；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
实例名称	客户端实例名，便于多实例区分；该值供指令下行任务使用；运行任务需重新加载变更。	外部系统部署及对接清单；客户端实例名称由实施人员按环境和用途指定。	由实施人员为当前环境和实例命名，便于日志定位。多实例避免误用同一身份；名字本身不改变 Topic。推荐：按对接资料填写默认：fmq-downstream-ingress-consumer示例：fmq-downstream-ingress-consumer	由实施人员为当前环境和实例命名，便于日志定位。多实例避免误用同一身份；名字本身不改变 Topic；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要

指令下行 · MQTT

字段	用途	值从哪里来	怎么选择	填错表现与恢复	生效条件
推荐模式	为指令下行选择一组参数预设；选完后再填写真实环境信息；作用于当前连接器，任务启用与业务结果需另行确认。	平台为本类型提供的推荐模式。	MQTT 订阅入口：平台作为 MQTT 客户端订阅外部 SaaS 发布的 Alink 指令消息。推荐：MQTT 订阅入口默认：—示例：—MQTT 订阅入口：平台作为 MQTT 客户端订阅外部 SaaS 发布的 Alink 指令消息；覆盖本通道预设参数，随后须重新核对连接信息。	配置变更可能影响引用它的任务；保留原配置，修正后复测。	范围：当前连接器及引用它的任务发布：不需要 · 重启：不需要 · 重连：不需要
必填 Broker 地址	外部 SaaS 使用的 MQTT Broker 地址；未填写协议时默认按 tcp:// 连接；该值供指令下行任务使用；运行任务需重新加载变更。	外部系统部署及对接清单；客户端实例名称由实施人员按环境和用途指定。	从对接方部署清单取地址，必须能被 FMQ 服务器访问。截图中的本机地址仅为示例；不要把浏览器所在电脑的地址误当成服务端地址。推荐：按对接资料填写默认：127.0.0.1示例：127.0.0.1	从对接方部署清单取地址，必须能被 FMQ 服务器访问。截图中的本机地址仅为示例；不要把浏览器所在电脑的地址误当成服务端地址；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
必填 Broker 端口	外部 MQTT Broker 端口；该值供指令下行任务使用；运行任务需重新加载变更。	外部系统部署及对接清单；客户端实例名称由实施人员按环境和用途指定。	从外部 MQTT Broker 管理员取得数据端口，常见 1883；加密入口需与协议匹配。不能填管理网页端口。推荐：按对接资料填写默认：1883示例：1883	从外部 MQTT Broker 管理员取得数据端口，常见 1883；加密入口需与协议匹配。不能填管理网页端口；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
必填 Client ID	平台订阅指令消息使用的客户端标识；该值供指令下行任务使用；运行任务需重新加载变更。	外部系统部署及对接清单；客户端实例名称由实施人员按环境和用途指定。	这是 FMQ 连接外部 MQTT Broker 的客户端 ID，不是被控制设备的 ID。按环境和上下行分别命名，避免与在线客户端重复造成互相挤下线。推荐：按对接资料填写默认：fmq-downstream-ingress-mqtt示例：fmq-downstream-ingress-mqtt	这是 FMQ 连接外部 MQTT Broker 的客户端 ID，不是被控制设备的 ID。按环境和上下行分别命名，避免与在线客户端重复造成互相挤下线；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
必填 订阅 Topic	平台接收 Alink 指令消息所订阅的 Topic；该值供指令下行任务使用；运行任务需重新加载变更。	外部系统部署及对接清单；客户端实例名称由实施人员按环境和用途指定。	由外部发送方和中间件管理员确认订阅主题。必须匹配外部实际发布位置；接收到了主题消息仍需通过 Alink 内容与设备目标校验。推荐：按对接资料填写默认：fmq_device_command示例：fmq_device_command	由外部发送方和中间件管理员确认订阅主题。必须匹配外部实际发布位置；接收到了主题消息仍需通过 Alink 内容与设备目标校验；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要

指令下行 · MQTT

字段	用途	值从哪里来	怎么选择	填错表现与恢复	生效条件
接入模式	指令下行的 MQTT 接入固定为订阅模式；该值供指令下行任务使用；运行任务需重新加载变更。	先采用本类型推荐模式，再根据实际负载、接口约定和运行指标调整。	此处只有 subscribe（订阅入口），保持它即可；不是切换上行和下行的按钮。推荐：subscribe默认：subscribe示例：subscribe订阅入口：平台作为客户端订阅外部指令，保持此固定选项；更换后按订阅入口处理该字段。	此处只有 subscribe（订阅入口），保持它即可；不是切换上行和下行的按钮；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
用户名	连接外部 MQTT Broker 使用的用户名；该值供指令下行任务使用；运行任务需重新加载变更。	外部系统部署及对接清单；客户端实例名称由实施人员按环境和用途指定。	由外部 MQTT Broker 管理员提供，确认发布或订阅权限。允许匿名才可留空；能登录并不代表能访问任意 Topic。推荐：按对接资料填写默认：—示例：—	由外部 MQTT Broker 管理员提供，确认发布或订阅权限。允许匿名才可留空；能登录并不代表能访问任意 Topic；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
密码	连接外部 MQTT Broker 使用的密码；该值供指令下行任务使用；运行任务需重新加载变更。	对接管理员通过受控渠道提供，实际值不进入手册或日志。	由外部 MQTT Broker 管理员安全提供，与用户名配套。不要记录到手册或消息体；用户名填了不代表密码可以省略。推荐：按对接资料填写默认：敏感值不展示示例：通过受控渠道填写	由外部 MQTT Broker 管理员安全提供，与用户名配套。不要记录到手册或消息体；用户名填了不代表密码可以省略；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要

指令下行 · WebHook

字段	用途	值从哪里来	怎么选择	填错表现与恢复	生效条件
推荐模式	为指令下行选择一组参数预设；选完后再填写真实环境信息；作用于当前连接器，任务启用与业务结果需另行确认。	平台为本类型提供的推荐模式。	Token 鉴权入口：外部 SaaS 使用 Token 推送 Alink 指令消息，适合 WebHook 回调集成。推荐：Token 鉴权入口默认：—示例：—Token 鉴权入口：外部 SaaS 使用 Token 推送 Alink 指令消息，适合 WebHook 回调集成；覆盖本通道预设参数，随后须重新核对连接信息。	配置变更可能影响引用它的任务；保留原配置，修正后复测。	范围：当前连接器及引用它的任务发布：不需要 · 重启：不需要 · 重连：不需要
必填 入口路径	外部 SaaS 推送 Alink 指令消息的入口路径；该值供指令下行任务使用；运行任务需重新加载变更。	外部系统部署及对接清单；客户端实例名称由实施人员按环境和用途指定。	先保留平台入口形式，由实施人员把已创建任务的实际入口地址交给外部系统。不要把字面量 {id} 或自行填写的路径当作已发布路由；需要任务启用、网络可达和鉴权。推荐：按对接资料填写默认：/ingress/downstream/{id}示例：/ingress/downstream/	先保留平台入口形式，由实施人员把已创建任务的实际入口地址交给外部系统。不要把字面量 {id} 或自行填写的路径当作已发布路由；需要任务启用、网络可达和鉴权；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
必填 Token	指令下行鉴权 Token，支持 Authorization Bearer 或 X-FMQ-Token 等请求头；该值供指令下行任务使用；运行任务需重新加载变更。	对接管理员通过受控渠道提供，实际值不进入手册或日志。	由双方通过受控渠道约定鉴权值，随调用放入受支持的请求头，不能写在 URL、截图或公开文档里。配置检查通过只说明非空，不证明对方已正确携带。推荐：按对接资料填写默认：敏感值不展示示例：通过受控渠道填写	由双方通过受控渠道约定鉴权值，随调用放入受支持的请求头，不能写在 URL、截图或公开文档里。配置检查通过只说明非空，不证明对方已正确携带；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要

指令下行 · HTTP

字段	用途	值从哪里来	怎么选择	填错表现与恢复	生效条件
推荐模式	为指令下行选择一组参数预设；选完后再填写真实环境信息；作用于当前连接器，任务启用与业务结果需另行确认。	平台为本类型提供的推荐模式。	HTTP 指令下行：外部 SaaS 直接调用平台 HTTP 入口，经过 Token 鉴权后进入统一指令下行链路。推荐：HTTP 指令下行默认：—示例：—HTTP 指令下行：外部 SaaS 直接调用平台 HTTP 入口，经过 Token 鉴权后进入统一指令下行链路；覆盖本通道预设参数，随后须重新核对连接信息。	配置变更可能影响引用它的任务；保留原配置，修正后复测。	范围：当前连接器及引用它的任务发布：不需要 · 重启：不需要 · 重连：不需要
必填 入口路径	外部 SaaS 直接调用的 HTTP 指令下行路径；该值供指令下行任务使用；运行任务需重新加载变更。	外部系统部署及对接清单；客户端实例名称由实施人员按环境和用途指定。	先保留平台入口形式，由实施人员把已创建任务的实际入口地址交给外部系统。不要把字面量 {id} 或自行填写的路径当作已发布路由；需要任务启用、网络可达和鉴权。推荐：按对接资料填写默认：/ingress/downstream/{id}示例：/ingress/downstream/	先保留平台入口形式，由实施人员把已创建任务的实际入口地址交给外部系统。不要把字面量 {id} 或自行填写的路径当作已发布路由；需要任务启用、网络可达和鉴权；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要
必填 Token	指令下行鉴权 Token，支持 Authorization Bearer 或 X-FMQ-Token 等请求头；该值供指令下行任务使用；运行任务需重新加载变更。	对接管理员通过受控渠道提供，实际值不进入手册或日志。	由双方通过受控渠道约定鉴权值，随调用放入受支持的请求头，不能写在 URL、截图或公开文档里。配置检查通过只说明非空，不证明对方已正确携带。推荐：按对接资料填写默认：敏感值不展示示例：通过受控渠道填写	由双方通过受控渠道约定鉴权值，随调用放入受支持的请求头，不能写在 URL、截图或公开文档里。配置检查通过只说明非空，不证明对方已正确携带；根据上述来源和条件修正后重新校验，再核对关联任务。	范围：当前连接器及引用它的任务发布：不需要 · 重启：需要 · 重连：需要

参数校验与排障

参数校验是保存前的门禁。它能证明当前协议在本次检查范围内可访问、字段格式可用或资源可检查；它不能代替消息推送任务的发送确认、外部系统消费确认或设备执行确认。

RabbitMQ 下行校验在自动声明、自动绑定开关开启时可能创建或绑定资源；RocketMQ 下行校验可能短暂启动消费者并消费消息；WebHook 推送测试会真实调用对方接口。先使用获准的隔离资源。

12. 演示一次可控的连接失败

操作位置： 集成→连接器

确认本次测试连接器未绑定任务，打开编辑窗口。仅在未保存的上行草稿中把 AMQP 端口改成获准的无效端口，再点 测试全部通道，不要保存错误配置。

图：在未保存的上行草稿中把端口改为1后，消息推送返回 Connection refused；指令下行仍通过，错误配置没有保存。

字段说明

字段 / 控件	说明
端口	RabbitMQ AMQP 端口；该值供消息推送任务使用；运行任务需重新加载变更。必填 · 来源：外部系统部署及对接清单；客户端实例名称由实施人员按环境和用途指定。选择：向管理员取得 AMQP 数据端口，常见 5672；管理页面常用的 15672 不能填在这里。以实际部署为准，连接拒绝时先核对端口与防火墙。推荐：按对接资料填写 · 示例：5672

13. 改回原端口并复核配置

操作位置： 集成→连接器

在同一 RabbitMQ 草稿中，将刚才修改的上行端口改回管理员提供的原端口，确认主机、账号、vhost 和交换机没有被改动。

图：同一 RabbitMQ 上行草稿的端口已改回5672，保留原主机、认证和交换机，尚需重新测试。

字段说明

字段 / 控件	说明
端口	RabbitMQ AMQP 端口；该值供消息推送任务使用；运行任务需重新加载变更。必填 · 来源：外部系统部署及对接清单；客户端实例名称由实施人员按环境和用途指定。选择：向管理员取得 AMQP 数据端口，常见 5672；管理页面常用的 15672 不能填在这里。以实际部署为准，连接拒绝时先核对端口与防火墙。推荐：按对接资料填写 · 示例：5672
主机地址	RabbitMQ 服务器地址；该值供消息推送任务使用；运行任务需重新加载变更。必填 · 来源：外部系统部署及对接清单；客户端实例名称由实施人员按环境和用途指定。选择：从对接方部署清单取地址，必须能被 FMQ 服务器访问。截图中的本机地址仅为示例；不要把浏览器所在电脑的地址误当成服务端地址。推荐：按对接资料填写 · 示例：127.0.0.1
虚拟主机	RabbitMQ 的 vhost，用于隔离不同业务环境；该值供消息推送任务使用；运行任务需重新加载变更。选填 · 来源：外部系统部署及对接清单；客户端实例名称由实施人员按环境和用途指定。选择：在 RabbitMQ 管理端查看本业务的 vhost，像同一 Broker 内的独立工作区。两端用错 vhost 时，即使队列同名也不是同一条通道；账号还必须有该 vhost 权限。推荐：按对接资料填写 · 示例：/

14. 重测并确认故障已恢复

操作位置： 集成→连接器

再次点击 测试全部通道，分别确认消息推送和指令下行返回成功。

图：恢复5672并核对已保存配置后再次测试，两个通道均显示成功；错误草稿未保存。

参考表

看到什么现象	可能原因	先检查哪里	如何恢复
显示已就绪，但测试失败	必填项齐全不等于 Broker 或接口可达。	先看失败的是上行还是下行，再核对该方向的地址和端口。	只修改失败通道，重新测试。
连接超时或拒绝	地址、AMQP 端口、防火墙或服务状态错误。	从 FMQ 服务器核对到 Broker 的网络和数据端口。	改回管理员提供的地址和端口后重测。
认证或 vhost 权限失败	账号、密码或 vhost 不匹配。	向 RabbitMQ 管理员确认业务账号及 vhost 权限。	更新当前方向的凭据，不在手册或日志中记录密码。
上行通过、下行失败	下行队列、绑定或消费参数独立配置错误。	核对消费队列、交换机、路由键及自动声明/绑定权限。	修正下行参数后测试全部通道。
下行通过、上行失败	上行交换机、发布参数或 Broker 连接错误。	核对上行交换机、vhost、账号和发布确认设置。	修正上行参数后重新测试。
RabbitMQ 资源声明或绑定报错	已有资源类型或属性与当前开关不一致。	确认资源由谁维护，以及交换机、队列、持久化属性。	关闭未获授权的自动声明/绑定，或由管理员调整资源。
Kafka 或 RocketMQ 校验通过但业务没有消息	校验未覆盖目标 Topic 的发送、消费或设备路由。	到对应任务核对 Topic、路由和任务状态。	启用任务后用隔离测试消息分别验证外部接收与设备实收。
保存后复测失败	参数被修改、凭据更新或 Broker 资源发生变化。	比较保存前后参数并核对最近变更。	修正同一连接类型和同一方向后复测，不切换协议规避故障。

日常维护

列表中的搜索、筛选和刷新用于更快找到连接器及查看最新页面状态；它们是查询辅助，不会验证外部系统连通性。复制连接器适合在相同类型、相近环境下复用字段结构，复制后仍要逐项替换地址、账号和资源名。

编辑已被任务引用的连接器前，先确认影响范围。运行参数修改后按页面提示重启原先已启用的任务；原先停用的任务保持停用，不要为更新参数擅自开启。新建或改变运行参数后，应重新做能力测试。删除前必须先解除所有任务引用。

生产操作提示

截图和示例用于说明操作位置与判断方法，不代表当前生产状态。涉及发布、启停、重绑、重试或删除时，应先确认目标环境、影响范围和恢复方案，并由授权人员执行。

蜂信物联（FastBee） · FMQ 操作手册