MQTTX SSE Server
2025.03.20
1
JavaScriptMQTT 服务实时消息传递其它
MQTTX SSE Server 是一个实现了 Model-Context Protocol (MCP) 的服务，通过 Server-Sent Events (SSE) 传输层提供 MQTT 代理连接能力。该服务允许 AI 助手与外部工具和服务进行交互，特别适用于需要实时消息传递的场景。
View on GitHub
Overview
基本能力
产品定位
MQTTX SSE Server 是一个基于 MCP 协议的服务，通过 SSE 传输层提供 MQTT 代理连接能力，适用于需要实时消息传递和 MQTT 操作的场景。
核心功能
- 实现 MCP 协议版本 2024-11-05
- 使用 SSE (Server-Sent Events) 作为传输层
- 提供 MQTT 操作工具：
- 连接到 MQTT 代理
- 订阅 MQTT 主题
- 发布消息到 MQTT 主题
- 实时传递订阅主题的消息
- 多客户端会话管理
适用场景
- 需要实时消息传递的应用
- MQTT 代理连接和操作
- AI 助手与外部服务的交互
工具列表
mqttConnect: 连接到 MQTT 代理mqttSubscribe: 订阅 MQTT 主题mqttPublish: 发布消息到 MQTT 主题
常见问题解答
- 如何配置 MQTTX 使用此服务？
在 MQTTX 设置中添加配置：
json { "mcpServers": { "mqttx-server": { "url": "http://localhost:4000/mqttx/sse" } } }
使用教程
使用依赖
- Node.js (v14 或更高版本)
- npm
安装教程
# 克隆仓库
git clone https://github.com/yourusername/mqttx-sse-server.git
cd mqttx-sse-server
# 安装依赖
npm install
运行服务器
npm start
默认情况下，服务器将在端口 4000 上启动。
调试方式
- 使用 JSON-RPC 命令进行调试，例如：
json { "jsonrpc": "2.0", "id": 1, "method": "initialize" }发送到/mqttx/message?sessionId=xxx端点。