MQTTX + MCP:MQTT 客户端秒变物联网 Agent

引言:MQTTX 与 MCP 的融合

作为最受欢迎的 MQTT 客户端工具,MQTTX 在 1.12.0 beta 版本中集成了模型上下文协议(MCP)到 Copilot AI 功能中,显著提升了服务能力。这一融合让 MQTTX 转变为 MCP Host(也就是发起请求的 LLM 应用程序),支持 MQTTX Copilot 直接与 MQTT 服务(如 EMQX)和本地资源进行交互。这种将大语言模型(LLM)与 MQTT 操作相结合的方式,为物联网自动化、监控和开发带来了全新可能。

下载最新版本:Release v1.12.0-beta.2 · emqx/MQTTX

由于目前处于测试版本,应用不会自动更新。请从 Assets 部分手动下载并安装。

MCP 简介

模型上下文协议(MCP)提供了 AI 模型与外部数据源或工具间的标准化接口,可以理解为「AI 应用的 USB-C 接口」。通过这一协议,MQTTX Copilot 可以实现以下功能:

  • 访问训练数据之外的上下文信息。
  • 与本地和远程系统进行安全交互。
  • 在各种 AI 提供商间维持统一接口。
  • 通过标准化工具调用实现特定功能。

MCP 基于客户端-服务器架构设计,Host 应用(比如 Cursor、MQTTX 等)内置 MCP 客户端,通过客户端连接到 MCP 服务器以提供特定功能。这种架构不仅确保了数据在用户自有基础设施中的安全存储,同时还支持强大的 AI 驱动工作流。

MQTTX Host 功能实现概览

通过集成 MCP 客户端,MQTTX 成为 MCP Host,可以与各种 MCP 服务器连接,这一实现支持:

  • SSE(服务器推送事件)和 Stdio(标准输入输出)两种 MCP 服务器类型。
  • 通过 MQTTX 设置界面进行简单配置。
  • 集成多种 AI 模型,包括 OpenAI GPT-4o、Claude 3.5/3.7、Grok 2 和 DeepSeek 等。
  • 对特定模型提供「思维链」支持,实现高级推理能力。

配置过程非常简单,用户只需通过 MQTTX 设置面板,将 MCP 服务器设置为命令行进程或 HTTP 端点即可。

应用场景:MQTTX 中的 MCP 实践

让我们通过实例来探索如何在 MQTTX 中设置和使用 MCP:

在 MQTTX 中设置 MCP

  1. 打开 MQTTX 并导航至左侧边栏的「设置」。
  2. 启用 Copilot 功能并使用 API 密钥配置您偏好的 AI 模型。
  3. 向下滚动至 MCP 部分并启用它。
  4. 在提供的输入框中以 JSON 格式添加 MCP 服务器配置。
  5. 添加配置后,可用服务器将显示在下方列表中。
  6. 点击右上角的「连接」按钮,测试服务器连接。
  7. 对于成功连接的服务器,您将看到可用工具列表。
  8. 使用「禁用/启用」开关切换服务器状态。

image.png

本地文件系统集成

通过文件系统 MCP 服务器,Copilot 可以与您的本地文件交互,直接生成并保存代码到指定目录:

{"mcpServers": {"filesystem": {"command": "npx","args": ["-y","@modelcontextprotocol/server-filesystem","/Users/username/Desktop","/Users/username/Downloads"]}}
}

具体工作流程示例如下:

  1. 按照上述方式配置文件系统 MCP 服务器。
  2. 在 Copilot 聊天框中,使用 @connection 关键词提取当前连接详情。
  3. 要求 Copilot “为这个 MQTT @connection 生成 JavaScript 代码并将其保存到 /Users/username/Downloads 路径下,命名为 mqtt-test.js”。
  4. AI 将使用 MCP 创建文件并保存到您指定的位置。

image.png

image.png

在终端中使用 cat mqtt-test.js 命令可以验证代码已成功创建,并包含了正确的连接参数。

image.png

这种方法通过消除「复制粘贴」的工作流程,极大地简化了开发过程:代码会直接生成并保存到您需要的位置,随时可以执行。

通过 MCP SSE 服务器进行 MQTT 操作

要通过 AI 直接执行 MQTT 操作,您可以部署自定义的 MQTTX MCP SSE 服务器(https://github.com/ysfscream/mqttx-mcp-sse-server)。

{"mcpServers": {"mqttx-server": {"url": "http://localhost:4000/mqttx/sse"}}
}

具体工作流程示例如下:

  1. 在本地或云端部署 MQTTX MCP SSE 服务器。
  2. 按照上述方式在 MQTTX 中配置服务器。
  3. 在 Copilot 聊天框中,输入请求:“连接到 mqtt://broker.emqx.io:1883 并向 testtopic/mcp 主题发布消息”。
  4. 在另一个 MQTTX 连接中,订阅相同的主题。
  5. AI 将通过 MCP 调用发布的消息,并实时显示在您的订阅窗口中。

image.png

这一功能彻底改变了用户与 MQTT 服务的交互方式:用户无需再手动配置连接或发布消息,只需通过自然语言指令,即可让 MQTTX Copilot 自动执行操作。这一特性在快速 MQTT 交互测试、调试以及教学场景中展现出重要价值,极大提升了效率和易用性。

结论

将 MCP 整合到 MQTTX 是 EMQ 连接物联网与 AI 技术融合愿景中的关键一步。目前的 beta 版本已经实现让 AI 助手通过自然语言与 MQTT 服务交互,但我们的目标远不止于此。

EMQ 正在积极开发「MCP over MQTT」实现方案,旨在利用 MQTT 的服务发现和发布-订阅机制来突破现有 MCP 架构的限制。这些探索将为智能物联网通信奠定坚实基础,结合 MQTTX Copilot 的 AI 服务能力,未来将支持模式生成、连接诊断及测试数据创建等更多功能。

欢迎社区成员体验这些新功能并提供反馈,助力开发更友好、更强大的 MQTT 操作解决方案。

「构建物联网应用或集成 AI 到 MQTT 工作流程」欢迎与我们联系。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/diannao/80176.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

UML统一建模

UML UML(统一建模语言)介绍 UML(统一建模语言)介绍 面向对象软件开发需要经过OOA面向对象分析、OOD面向对象设计和OOP面向对象编程三个阶段。OOA对目标系统进行分析并寄哪里分析模型,并将之文档化,OOD用面向…

CPP_类和对象

面向对象: 更接近真实世界(关注各对象之间的关系,而非各步骤的进行) 将结构体升级成立类 类里面可以有:成员函数,成员变量 class Stack { public:void Init(int defaultCapacity4 ) {_a (int*)malloc(s…

极狐GitLab 如何撤销变更?

极狐GitLab 是 GitLab 在中国的发行版,关于中文参考文档和资料有: 极狐GitLab 中文文档极狐GitLab 中文论坛极狐GitLab 官网 还原更改 (BASIC ALL) 在极狐GitLab 中,您可以还原单个提交或整个合并请求。 当您在 Git 中还原一个提交时&…

PNG透明免抠设计素材大全26000+

在当今的数字设计领域,寻找高质量且易于使用的素材是每个设计师的日常需求。今天,我们将为大家介绍一个超全面的PNG透明免抠设计素材大全,涵盖多种风格、主题和应用场景,无论是平面设计、网页设计还是多媒体制作,都能轻…

uniapp小程序使用echarts

1、引入插件 在Dcloud插件市场下载echarts插件&#xff1a;插件地址 2、页面使用简单示例&#xff1a; <template><view class"pie-view flex-center"><view style"width: 100%; height: 600rpx"><l-echart ref"chartRef&quo…

7-1 三种语言的单词转换

编写程序实现&#xff1a;首先从键盘输入若干个中文与英文单词的偶对&#xff0c;以空行作结束标记&#xff1b;再输入若干个英文与丹麦文单词的偶对&#xff0c;以空行作结束标记。然后输入一个中文单词&#xff0c;输出对应的丹麦文单词&#xff1b;若不存在该单词&#xff0…

开源AI守护童心——幼儿跌倒报警系统的智能安全革命

幼儿园是孩子们成长的乐园&#xff0c;但跌倒事件却时常让家长和园方忧心。教室、走廊、操场&#xff0c;幼儿的每一次意外跌倒都可能带来安全隐患。传统人工监管难以全天候覆盖&#xff0c;反应速度也常受限。如何让幼儿园更安全、更放心&#xff1f;幼儿跌倒报警系统&#xf…

Halcon应用:相机标定

提示&#xff1a;若没有查找的算子&#xff0c;可以评论区留言&#xff0c;会尽快更新 Halcon应用&#xff1a;相机标定 前言一、Halcon应用&#xff1f;二、应用实战1、图像理解1.1、开始标定 前言 本篇博文主要用于记录学习Halcon中算子的应用场景&#xff0c;及其使用代码和…

Arduino示例代码讲解:Project 08 - Digital Hourglass 数字沙漏

Arduino示例代码讲解:Project 08 - Digital Hourglass 数字沙漏 Project 08 - Digital Hourglass 数字沙漏程序功能概述功能:硬件要求:输出:代码结构全局变量`setup()` 函数`loop()` 函数计时和点亮LED:读取倾斜开关状态:重置LED和计时器:运行过程注意事项Project 08 - …

《计算机视觉度量:从特征描述到深度学习》—深度学习图像特征工程

传统算法的图像特征分析和描述&#xff0c;一直贯穿图像算法的发展。2017年深度学习的出现&#xff0c;很多开发人员和技术人员认为&#xff0c;图像特征分析这个概念可以被深度学习完全取代。很长一段时间以深度学习为主的视觉方案成为主流&#xff0c;逐渐淡化了传统视觉的特…

零部件三维激光扫描检测

制造业竞争激烈&#xff0c;零部件的精准检测与三维数据的高效获取&#xff0c;已成为企业确保产品质量、提升生产效率的核心要素。传统检测手段&#xff0c;往往因效率低下、精度不足&#xff0c;难以满足复杂零部件的检测需求。 传统零部件检测&#xff0c;检测人员通常是手…

KafkaSpark

Kafka Kafka基本概念 卡夫卡是一个分布式、分布订阅的消息系统&#xff0c;作为消息中间件使用。 设计上是一个分布式的、分区的和可复制的提交日志服务。 Kafka的优势 分布式系统&#xff0c;易于扩展。 高吞吐量&#xff0c;支持发布和订阅模式。 支持多地复制&#xff…

图文结合 - 光伏系统产品设计PRD文档 -(慧哥)慧知开源充电桩平台

光伏系统产品设计PRD文档 ‌版本号‌&#xff1a;1.0 ‌修订日期‌&#xff1a;2023年10月 ‌作者‌&#xff1a; 一、文档概述 1.1 背景与目标 ‌行业背景‌&#xff1a;全球光伏装机量年增长20%&#xff0c;数字化运维需求迫切‌用户痛点‌&#xff1a;现有系统存在数据延…

Eyecare-100K:首个覆盖多模态、多任务的高质量眼科视觉指令数据集

2025-04-18 , 由浙江大学、哈尔滨工业大学、郴州市第一人民医院、新加坡国立大学等机构合作创建了 Eyecare-100K数据集&#xff0c;这是首个涵盖多种模态、任务和疾病的高质量眼科视觉指令数据集&#xff0c;为眼科智能诊断领域提供了关键资源&#xff0c;推动了医学视觉语言模…

CoT-Drive:利用 LLM 和思维链提示实现自动驾驶的高效运动预测

25年3月来自澳门大学和 MIT 的论文“CoT-Drive: Efficient Motion Forecasting for Autonomous Driving with LLMs and Chain-of-Thought Prompting”。 准确的运动预测对于安全的自动驾驶 (AD) 至关重要。本研究提出 CoT-Drive&#xff0c;这是一种利用大语言模型 (LLM) 和思…

[FPGA基础] RAM篇

Xilinx FPGA RAM 使用指南 1. 引言 随机存取存储器&#xff08;RAM&#xff09;是 Xilinx FPGA 设计中用于存储和快速访问数据的重要资源。Xilinx FPGA 提供多种 RAM 类型&#xff0c;包括块 RAM&#xff08;Block RAM&#xff09;和分布式 RAM&#xff08;Distributed RAM&a…

Elasticsearch内核探秘:从Shard分配到网络通信的深度实践指南

#作者&#xff1a;孙德新 文章目录 一、底层模块深入解析之shard allocation1、shard allocation的介绍2、cluster level shard allocation介绍3、disk-based shard allocation介绍4、shard allocation awareness5、shard allocation filtering6、node下线时的shard延迟分配7、…

SQL Server 2022 常见问题解答:从安装到优化的全场景指南

SQL Server 2022 作为微软最新的数据库管理系统&#xff0c;在性能、安全性和云集成方面带来了多项革新。然而&#xff0c;用户在实际使用中仍可能遇到各类问题。本文将围绕安装配置、性能优化、备份恢复、安全设置、高可用性方案、兼容性问题及错误代码解析等核心场景&#xf…

57、Spring Boot 最佳实践

Spring Boot 最佳实践 一. 开发规范与代码风格 编写高质量的代码不仅需要功能的实现,还需要遵循一定的规范和代码风格,以提高代码的可读性、可维护性和协作效率。以下是 Spring Boot 开发中的一些关键规范和代码风格建议。 1. 代码命名规范 在编写代码时,命名是非常重要的…

​​OSPF核心机制精要:选路、防环与设计原理​

一、OSPF选路规则解析 OSPF作为经典的链路状态路由协议&#xff0c;其选路规则采用层次化优先级机制&#xff0c;不同路由类型遵循严格比较顺序&#xff1a; 1. 路由类型优先级 优先级路由类型描述1域内路由通过1类、2类LSA生成2域间路由通过3类LSA生成3域外路由通过5类/7类…