跳到主要内容

AI 驱动文档

您想了解什么？

MQTT 通信设置

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

When to Use MQTT Communication: IoT 设备集成、远程监控系统、publish/subscribe 消息模式、低带宽环境、分布式传感器网络，或在需要具备自动重连功能的可靠消息传递时使用。

先决条件​

  • OV80i 摄像头系统已设置并连接
  • 摄像头与 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 检查相机网络设置​

  1. 转到系统设置
  2. 记录摄像头 IP 地址（例如 10.250.0.100）
  3. 验证与 MQTT Broker 的网络连通性

1.2 MQTT Broker 要求​

确保 MQTT Broker 可访问：

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

1.3 网络需求​

组件IP 地址端口备注
相机10.250.0.100N/A必须可达 MQTT Broker
MQTT Broker10.250.0.2001883标准 MQTT 端口
客户端设备10.250.0.xxx变量任何订阅设备

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

2.1 导航到 IO Block​

  1. 在 Recipe Editor 中打开您正在使用的活动配方
  2. 点击 Configure IO 或在面包屑菜单中选择 IO Block 以进入 Node-RED 编辑器

2.2 验证 MQTT 节点是否可用​

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

  • mqtt in - 订阅 MQTT 主题
  • mqtt out - 发布到 MQTT 主题

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

第3步：配置 MQTT Broker 连接​

3.1 添加 MQTT Broker 配置​

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

3.2 配置 Broker 设置​

基本 Broker 配置：

设置值描述
名称Camera MQTT Broker描述性标识符
服务器192.168.0.200MQTT broker IP 地址
端口1883标准 MQTT 端口
协议MQTT V3.1.1推荐版本
Client ID(auto-generate)为空以实现自动生成

3.3 认证设置（如需）​

若代理需要认证：

设置项说明
用户名MQTT broker 用户名
密码MQTT broker 密码
Use TLS启用以建立安全连接（端口 8883）

3.4 高级设置​

连接选项：

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

3.5 保存 Broker 配置​

  1. 点击 "Add" 以保存 broker 设置
  2. 点击 "Done" 以关闭节点配置
  3. Broker 配置现已可用于所有 MQTT 节点

Step 4: Configure MQTT Input (Subscribe)​

4.1 设置 MQTT In 节点​

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

4.2 MQTT In Configuration​

订阅设置：

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

4.3 主题命名约定​

推荐的主题结构：

用途主题示例用途
Commandscamera/commands接收控制命令
Status requestscamera/status/request状态信息请求
Configurationcamera/config配置变更

4.4 配置消息处理​

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

Step 5: Configure MQTT Output (Publish)​

5.1 添加 MQTT Out 节点​

  1. 将 "mqtt out" 节点拖拽到画布上
  2. 双击以配置
  3. 选择相同的 broker 配置

5.2 MQTT Out 配置​

发布设置：

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

5.3 响应主题结构​

推荐的响应主题：

响应类型主题示例用途
Status updatescamera/status相机状态信息
Resultscamera/results检查结果
Acknowledgmentscamera/ack命令确认

Step 6: Create Basic Communication Flow​

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. 配置设置：
    • 名称： "Send Test Message"
    • 载荷（Payload）： 时间戳
    • 主题： 留空
  3. 点击“完成”

6.4 配置 Function Node​

简单消息格式化：

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

  1. 双击函数节点
  2. 将上面的代码复制 到 “On Message” 标签
  3. 名称： "Format Message"
  4. 点击“完成”

6.5 配置 MQTT Out Node​

  1. 双击 mqtt out 节点
  2. 选择 broker： Camera MQTT Broker（前面配置）
  3. Topic：（留空——由函数节点设置）
  4. 名称： "Publish Status"
  5. 点击“完成”

6.6 配置 MQTT In Node​

  1. 双击 mqtt in 节点
  2. 选择 broker： Camera MQTT Broker
  3. Topic： camera/commands
  4. 名称： "Command Listener"
  5. 点击“完成”

6.7 配置 Debug Node​

  1. 双击调试节点
  2. 输出： 完整的 msg 对象
  3. 名称： "Incoming Messages"
  4. 点击“完成”

6.8 最终流程结构​

您的完整流程应为：

输出： Inject → Function → MQTT Out
输入： MQTT In → Debug

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

7.1 部署流程​

  1. 点击“Deploy” 按钮（右上角）
  2. 验证部署成功 信息
  3. 检查节点状态指示灯：
    • 绿色圆点： 连接到 broker
    • 红色圆点： 连接失败
    • 黄色圆点： 正在连接

7.2 测试内部通信​

测试摄像头的 MQTT 发布：

  1. 点击注入按钮 发送测试消息
  2. 验证 MQTT Out 节点 显示活动
  3. 检查调试面板，如果有外部消息

7.3 外部测试（可选）​

使用外部 MQTT 客户端向摄像头发送命令进行测试：

使用命令行工具：

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

预期结果： 调试节点应在 Node-RED 调试面板中显示传入的消息。

7.4 验证通信​

检查以下方面：

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

第 8 步：排除 MQTT 问题​

8.1 连接问题​

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

8.2 消息问题​

问题症状解决方案
未接收到消息调试无显示检查主题订阅
消息未发布外部客户端未看到任何内容验证发布主题
消息格式错误解析失败使用简单文本消息
消息丢失断续投递检查 broker 连接

8.3 性能问题​

问题症状解决方案
High latency消息传递延迟检查 MQTT 代理性能
Connection drops频繁重新连接调整 keep-alive 设置
Message flooding代理过载实现消息限流

8.4 调试技巧​

系统化故障排除：

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

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

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

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

持续维护​

定期系统检查​

  • 在 Node-RED 中监控 MQTT broker 连接状态
  • 使用测试消息验证消息投递情况
  • 检查 MQTT broker 日志中的错误模式
  • 必要时更新认证凭据

性能监控​

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

下一步​

在完成基本 MQTT 通信设置后：

  1. 为您的应用实现具体的消息工作流
  2. 建立主题层级以实现有序通信
  3. 添加安全措施，如 TLS 加密
  4. 使用已确立的 MQTT 协议与外部系统集成
  5. 创建系统健康监控仪表板
Generate MQTT flows automatically

The Integration Builder can generate complete MQTT communication flows from a plain English description. Describe your messaging pattern (e.g., "publish inspection results to an MQTT topic with pass/fail status and confidence scores") and get a production-ready Node-RED flow in seconds.

🔗 相关链接​