跳到主要内容

AI 驱动文档

您想了解什么？

MQTT 通信设置

本指南向您展示如何使用 Node-RED 在 OV10i 摄像头与外部设备之间配置 MQTT 通信。MQTT 为物联网应用和远程设备通信提供轻量、可靠的消息传输。

何时使用 MQTT 通信： 物联网设备集成、远程监控系统、发布/订阅消息模式、低带宽环境、分布式传感器网络，或者需要具有自动重连的可靠消息传递时。

跳过手动设置

用简单的英文描述您的 MQTT 集成，Auto-Integration Builder 将在几秒内为您生成完整的 Node-RED 流程。

先决条件​

  • OV10i 摄像头系统已设置并连接
  • 摄像头与 MQTT broker 之间的网络连通性
  • 可用的 MQTT broker（本地或基于云）
  • 对 MQTT 概念的基本理解（topics、publish/subscribe）
  • 摄像头上已配置活动程序

MQTT 通信概览​

MQTT 关键概念：

  • Broker： 在客户端之间路由消息的中央服务器
  • Topics： 消息类别（例如 "camera/status"、"commands/trigger"）
  • Publish： 向 topic 发送消息
  • Subscribe： 从 topic 接收消息
  • QoS： 服务质量级别（0、1、2）

第一步：验证网络配置​

1.1 检查摄像头网络设置​

  1. 导航至系统设置
  2. 记录摄像头 IP 地址（例如 192.168.0.100）
  3. 验证与 MQTT broker 的网络连通性

1.2 MQTT Broker 要求​

确保 MQTT broker 可访问：

  • 同一网络： 摄像头必须能够到达 broker IP 地址
  • 端口访问： 默认 MQTT 端口 1883（TLS 时为 8883）
  • 身份验证： 如果 broker 要求，提供用户名/密码
  • 防火墙： 允许所需端口上的 MQTT 流量

1.3 网络要求​

组件IP 地址端口备注
摄像头192.168.0.100不适用必须能到达 broker
MQTT Broker192.168.0.2001883标准 MQTT 端口
客户端设备192.168.0.xxx可变任何订阅的设备

第二步：访问 Node-RED 编辑器​

2.1 导航至 IO模块​

  1. 在程序编辑器中打开您的活动程序
  2. 点击 Configure IO 或在面包屑菜单中选择 IO Block，进入 Node-RED 编辑器

2.2 验证 MQTT 节点可用​

检查 Node-RED 调色板中的 MQTT 节点：

  • mqtt in - 订阅 MQTT topics
  • mqtt out - 发布到 MQTT topics

检查点： 您应在左侧面板的 Network 部分看到 MQTT 节点。

第三步：配置 MQTT Broker 连接​

3.1 添加 MQTT Broker 配置​

  1. 将 "mqtt in" 节点拖动到画布上（用于初始设置）
  2. 双击节点打开配置
  3. 点击 Server 字段旁的铅笔图标
  4. 点击 "Add new mqtt-broker"

3.2 配置 Broker 设置​

基本 Broker 配置：

设置值说明
NameCamera MQTT Broker描述性标识符
Server192.168.0.200MQTT broker IP 地址
Port1883标准 MQTT 端口
ProtocolMQTT V3.1.1推荐版本
Client ID（自动生成）留空以自动生成

3.3 身份验证设置（如需要）​

如果代理需要身份验证：

设置描述
UsernameMQTT 代理用户名
PasswordMQTT 代理密码
Use TLS启用安全连接（端口 8883）

3.4 高级设置​

连接选项：

设置推荐值描述
Keep Alive60 秒心跳间隔
Clean SessionTrue每次连接重新开始
Auto ConnectTrue自动重新连接

3.5 保存代理配置​

  1. 点击"Add" 保存代理设置
  2. 点击"Done" 关闭节点配置
  3. 代理配置现在可用于所有 MQTT 节点

第 4 步：配置 MQTT 输入（订阅）​

4.1 设置 MQTT In 节点​

  1. 选择您添加的"mqtt in"节点
  2. 双击进行配置
  3. 配置订阅设置：

4.2 MQTT In 配置​

订阅设置：

设置示例值描述
ServerCamera MQTT Broker选择已配置的代理
Topiccamera/commands要订阅的主题
QoS0消息传递质量
Outputauto-detect消息格式
NameCommand Listener节点标识符

4.3 主题命名约定​

推荐的主题结构：

用途主题示例使用场景
命令camera/commands接收控制命令
状态请求camera/status/request状态信息请求
配置camera/config配置变更

4.4 配置消息处理​

  1. 添加"debug"节点以监控传入消息
  2. 连接： MQTT In → Debug
  3. 配置 debug 节点以显示完整消息

第 5 步：配置 MQTT 输出（发布）​

5.1 添加 MQTT Out 节点​

  1. 将"mqtt out"节点拖动到画布上
  2. 双击进行配置
  3. 选择相同的代理配置

5.2 MQTT Out 配置​

发布设置：

设置示例值描述
ServerCamera MQTT Broker与输入相同的代理
Topiccamera/responses相机响应的主题
QoS0消息传递质量
RetainFalse不存储最后一条消息
NameResponse Publisher节点标识符

5.3 响应主题结构​

推荐的响应主题：

响应类型主题示例使用场景
状态更新camera/status相机状态信息
结果camera/results检查结果
确认camera/ack命令确认

第 6 步：创建基本通信流程​

6.1 构建传出消息流程​

创建一个流程以从相机发布消息：

  1. 添加"inject"节点用于触发消息
  2. 添加"function"节点用于消息格式化
  3. 添加"mqtt out"节点用于发布
  4. 连接： Inject → Function → MQTT Out

6.2 构建传入消息流程​

创建一个独立的流程以接收消息：

  1. 添加"mqtt in"节点用于订阅
  2. 添加"debug"节点用于监控
  3. 连接： MQTT In → Debug

6.3 配置 Inject 节点​

  1. 双击 inject 节点
  2. 配置设置：
    • Name： "Send Test Message"
    • Payload： Timestamp
    • Topic： （留空）
  3. 点击 "Done"

6.4 配置 Function 节点​

简单的消息格式化：

// Format outgoing message
msg.topic = "camera/status";
msg.payload = "Camera online - " + new Date().toISOString();
return msg;

  1. 双击 function 节点
  2. 将上述代码复制到 "On Message" 选项卡
  3. Name： "Format Message"
  4. 点击 "Done"

6.5 配置 MQTT Out 节点​

  1. 双击 mqtt out 节点
  2. 选择 broker： Camera MQTT Broker（先前已配置）
  3. Topic： （留空 - 由 function 节点设置）
  4. Name： "Publish Status"
  5. 点击 "Done"

6.6 配置 MQTT In 节点​

  1. 双击 mqtt in 节点
  2. 选择 broker： Camera MQTT Broker
  3. Topic： camera/commands
  4. Name： "Command Listener"
  5. 点击 "Done"

6.7 配置 Debug 节点​

  1. 双击 debug 节点
  2. Output： Complete msg object
  3. Name： "Incoming Messages"
  4. 点击 "Done"

6.8 最终流程结构​

完整的流程应为：

发送方向： Inject → Function → MQTT Out 接收方向： MQTT In → Debug

第 7 步：部署并测试配置​

7.1 部署流程​

  1. 点击 "Deploy" 按钮（右上角）
  2. 确认部署成功消息
  3. 检查节点状态指示灯：
    • 绿点： 已连接到 broker
    • 红点： 连接失败
    • 黄点： 正在连接

7.2 测试内部通信​

测试相机的 MQTT 发布功能：

  1. 点击 inject 按钮发送测试消息
  2. 确认 MQTT Out 节点显示活动状态
  3. 检查 debug 面板中是否有外部消息

7.3 外部测试（可选）​

使用外部 MQTT 客户端向相机发送命令：

使用命令行工具：

# Send a test command to the camera
mosquitto_pub -h 192.168.0.100 -t "camera/commands" -m "test_command"

预期结果： debug 节点应在 Node-RED 调试面板中显示接收到的消息。

7.4 验证通信​

检查以下方面：

测试预期结果状态
Broker 连接MQTT 节点显示绿色状态☐
消息发布Inject 成功触发 MQTT Out☐
消息接收Debug 显示外部消息☐
重新连接网络中断后自动重连☐

第 8 步：MQTT 问题故障排除​

8.1 连接问题​

问题症状解决方案
无法连接到 broker红色状态指示灯检查 broker IP 和端口
身份验证失败连接被拒绝验证用户名/密码
网络超时黄色连接中状态检查网络连通性
防火墙阻止无连接尝试开放 MQTT 端口

8.2 消息问题​

问题症状解决方案
未收到消息Debug 无显示检查主题订阅
消息未发布外部客户端未收到验证发布主题
消息格式错误解析失败使用简单文本消息
消息丢失传输不稳定检查 broker 连接

8.3 性能问题​

问题症状解决方案
高延迟消息传递延迟检查 broker 性能
连接中断频繁重连调整 keep-alive 设置
消息泛滥broker 过载实施消息节流

8.4 调试技巧​

系统化故障排除：

  1. 在 Node-RED 中检查 broker 连接状态
  2. 监控 Node-RED 调试面板以查看消息流
  3. 在处理复杂数据前使用简单的文本消息
  4. 使用 ping 验证网络连通性
  5. 在进行高级流程前使用基本主题进行测试

成功！您的 MQTT 通信已就绪​

您的 MQTT 通信系统现在可以：

  • 连接到 MQTT broker 并进行适当的身份验证
  • 订阅主题以接收命令和数据
  • 发布消息以进行状态更新和响应
  • 处理 JSON 消息格式以实现结构化通信
  • 在网络中断后自动重连
  • 支持多种 QoS 级别以适应不同消息优先级

日常维护​

定期系统检查​

  • 在 Node-RED 中监控 broker 连接状态
  • 使用测试消息验证消息传递
  • 检查 broker 日志以发现错误模式
  • 根据需要更新身份验证凭据

性能监控​

  • 跟踪消息延迟和传递时间
  • 监控 broker 资源使用情况以评估可扩展性
  • 分析主题使用模式以进行优化
  • 根据实际需求审查 QoS 设置

后续步骤​

完成基本 MQTT 通信设置后：

  1. 为您的应用实施特定的消息工作流
  2. 设置主题层次结构以实现有组织的通信
  3. 添加安全措施，例如 TLS 加密
  4. 使用已建立的 MQTT 协议与外部系统集成
  5. 创建监控仪表板以监控系统健康状况
自动生成 MQTT 流程

Integration Builder 可以根据纯英文描述生成完整的 MQTT 通信流程。描述您的消息模式（例如，"将检测结果发布到 MQTT 主题，包含 pass/fail 状态和置信度分数"），即可在几秒内获得一个可用于生产的 Node-RED 流程。

🔗 另请参阅​