I craft unique cereal names, stories, and ridiculously cute Cereal Baby images.

MQTTX-MCP-SSE-SERVER
Eine Implementierung des Modell-Kontext-Protokolls (MCP), mit dem MQTT-Operationen über Server-Sent-Ereignisse (SSE) -Transport (SSE) ermöglicht werden können.
1
Github Watches
1
Github Forks
1
Github Stars
MQTTX SSE Server
An implementation of the Model-Context Protocol (MCP) that enables MQTT operations over Server-Sent Events (SSE) transport.
About MCP
The Model-Context Protocol (MCP) is a standardized protocol that allows AI assistants to interact with external tools and services. This server implements the MCP specification using SSE (Server-Sent Events) as the transport layer, providing MQTT broker connectivity capabilities.
Features
- Implements MCP protocol version 2024-11-05
- Uses SSE (Server-Sent Events) as the transport layer
- Provides MQTT operations through MCP tools:
- Connect to MQTT brokers
- Subscribe to MQTT topics
- Publish messages to MQTT topics
- Real-time message delivery from subscribed topics
- Session management for multiple clients
Getting Started
Prerequisites
- Node.js (v14 or later)
- npm
Installation
# Clone the repository
git clone https://github.com/yourusername/mqttx-sse-server.git
cd mqttx-sse-server
# Install dependencies
npm install
Running the Server
npm start
The server will start on port 4000 by default.
Configuring MQTTX
To use this MCP server with MQTTX, add the following configuration to your MQTTX settings:
{
"mcpServers": {
"mqttx-server": {
"url": "http://localhost:4000/mqttx/sse"
}
}
}
MCP Protocol Implementation
This server implements the Model-Context Protocol with the following components:
- SSE Connection: Establishes persistent connection for real-time updates
- JSON-RPC API: Handles tool calls and responses according to MCP spec
- Tools Interface: Provides MQTT functionality through standardized MCP tools
- Session Management: Tracks client sessions and their MQTT connections
API Reference
SSE Connection
Establishes a persistent connection for receiving server events.
GET /mqttx/sse
Response events:
-
endpoint
: Contains the URL for making JSON-RPC calls -
heartbeat
: Regular ping to keep the connection alive -
message
: Contains JSON-RPC responses
JSON-RPC Commands
All commands are sent to the message endpoint with your session ID:
POST /mqttx/message?sessionId=xxx
Initialize
{
"jsonrpc": "2.0",
"id": 1,
"method": "initialize"
}
List Tools
{
"jsonrpc": "2.0",
"id": 2,
"method": "tools/list"
}
MQTT Connect
{
"jsonrpc": "2.0",
"id": 3,
"method": "tools/call",
"params": {
"name": "mqttConnect",
"arguments": {
"host": "broker.example.com",
"port": 1883,
"clientId": "mqttx-client"
}
}
}
MQTT Subscribe
{
"jsonrpc": "2.0",
"id": 4,
"method": "tools/call",
"params": {
"name": "mqttSubscribe",
"arguments": {
"topic": "test/topic",
"qos": 0
}
}
}
MQTT Publish
{
"jsonrpc": "2.0",
"id": 5,
"method": "tools/call",
"params": {
"name": "mqttPublish",
"arguments": {
"topic": "test/topic",
"payload": "Hello MQTT!",
"qos": 0,
"retain": false
}
}
}
相关推荐
Evaluator for marketplace product descriptions, checks for relevancy and keyword stuffing.
I find academic articles and books for research and literature reviews.
Confidential guide on numerology and astrology, based of GG33 Public information
Converts Figma frames into front-end code for various mobile frameworks.
Advanced software engineer GPT that excels through nailing the basics.
Take an adjectivised noun, and create images making it progressively more adjective!
Entdecken Sie die umfassendste und aktuellste Sammlung von MCP-Servern auf dem Markt. Dieses Repository dient als zentraler Hub und bietet einen umfangreichen Katalog von Open-Source- und Proprietary MCP-Servern mit Funktionen, Dokumentationslinks und Mitwirkenden.
Ein einheitliches API-Gateway zur Integration mehrerer Ethercan-ähnlicher Blockchain-Explorer-APIs mit Modellkontextprotokoll (MCP) für AI-Assistenten.
Die All-in-One-Desktop & Docker-AI-Anwendung mit integriertem Lappen, AI-Agenten, No-Code-Agent Builder, MCP-Kompatibilität und vielem mehr.
Reviews

user_AgfiunUu
I've been using mqttx-mcp-sse-server by ysfscream and I'm thoroughly impressed. It's a powerful server solution that's incredibly easy to set up, thanks to the clear documentation on its [GitHub](https://github.com/ysfscream/mqttx-mcp-sse-server) page. The seamless integration and performance of this server in handling MQTT and SSE make it an essential tool for any application requiring reliable real-time data streaming. Highly recommend!