AI 代理通信
MCP over MQTT
通过 MQTT 将 AI 代理连接到远程工具和服务,并借助消息服务器实现服务发现。
下一代协议
以 MQTT 连接 AI 与物联网,覆盖自动驾驶、智能制造到机器人等场景。

本文将探讨如何将 Microduck 和 Device Agent 集成,通过 Device Agent 中集成的 LLM,ASR 和 TTS 等 AI 服务,进一步为其提供面向用户的智能交互与自动化能力。

Microduck 是一台面向 Physical AI、强化学习和机器人开发的小型双足机器人,它可以通过强化学习策略行走、转向并完成多种动作,实现一些非常有趣的功能。本系列文章将介绍如何利用 Device Agent 来扩展 Microduck,通过 MQTT 为其接入云端运行的 LLM,Web 或者手机端应用等,实现更加复杂、有趣的边云协作场景。

了解 A2A over MQTT 如何解决跨运行时 AI Agent 协同难题,实现 Agent 自动发现、任务通信、状态流转、负载均衡与企业级智能体互操作。
MQTT for AI 是一组用于连接 AI 代理、设备和服务的 MQTT 增强功能,主要包括:
MCP over MQTT 使用 MQTT,通过模型上下文协议(MCP)将 AI 代理与远程工具和服务连接起来。它支持服务发现,可在物联网、边缘和云环境中实现可扩展的通信。
MQTT Streams 为 MQTT 增加了数据流存储与回放能力。应用可以从指定位置读取历史消息,在停机后补上进度或重新处理数据。
EMQX 中的 MQTT Queues 会存储消息以便稍后投递,即使消费者处于离线状态也不会丢失。它们在可用的消费者之间分发消息,并在确认后删除每条消息,适用于异步任务和设备指令。
MQTT 批量发布将多条消息打包进单个 MQTT 5.0 PUBLISH 报文,可降低协议开销,并提升发送大量小消息的应用的吞吐量。
MQTT 订阅过滤器在主题匹配之外,增加了基于消息属性的条件。消息服务器只投递满足条件的消息,从而减少订阅端的网络流量和处理负载。