What is Mqttx Mcp Sse Server

mqttx-mcp-sse-server is an implementation of the Model-Context Protocol (MCP) that facilitates MQTT operations over Server-Sent Events (SSE) transport, enabling real-time communication between AI assistants and external tools.

Use cases

Use cases include connecting AI assistants to MQTT brokers for IoT device management, real-time data streaming in smart environments, and enabling interactive applications that require immediate updates.

How to use

To use mqttx-mcp-sse-server, clone the repository, install the dependencies using npm, and start the server. Configure your MQTTX settings to connect to the server’s SSE endpoint.

Key features

Key features include implementation of MCP protocol version 2024-11-05, real-time message delivery, session management for multiple clients, and MQTT operations such as connecting, subscribing, and publishing messages.

Where to use

mqttx-mcp-sse-server can be used in applications that require real-time data exchange between AI assistants and MQTT brokers, such as IoT applications, smart home systems, and real-time monitoring solutions.

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
    }
  }
}