EMQX MCP Server

A Model Context Protocol (MCP) server implementation that provides EMQX MQTT broker interaction. Enabling MCP clients to interact with the MQTT clusters on EMQX Cloud or self-hosted clusters

Features

MQTT Client Management

• Client Listing: View all connected MQTT clients with flexible filtering options
• Client Information: Retrieve detailed information about specific clients
• Connection Control: Disconnect problematic or stale clients from the broker
• Flexible Filtering: Filter clients by node, username, client ID, connection state, and more

MQTT Message Publishing

• Topic-based Publishing: Send messages to any MQTT topics
• QoS Control: Select Quality of Service level (0, 1, or 2) for reliable delivery
• Message Retention: Option to persist messages for new subscribers
• Custom Payloads: Support for any message content format

MQTT Topic Subscription (SSE)

• Real-time Subscription: Subscribe to MQTT topics via Server-Sent Events (SSE)
• Duration Control: Configure how long to listen for messages (1-300 seconds)
• Message Limiting: Set maximum number of messages to collect per subscription
• Automatic Parsing: Messages are automatically parsed from SSE event stream

Tools

list_mqtt_clients

• List MQTT clients connected to your EMQX Cluster
• Inputs:
  • page (number, optional): Page number (default: 1)
  • limit (number, optional): Results per page (default: 100, max 10000)
  • node (string, optional): Filter by specific node name
  • clientid (string, optional): Filter by specific client ID
  • username (string, optional): Filter by specific username
  • ip_address (string, optional): Filter by client IP address
  • conn_state (string, optional): Filter by connection state
  • clean_start (boolean, optional): Filter by clean start flag
  • proto_ver (string, optional): Filter by protocol version
  • like_clientid (string, optional): Fuzzy search by client ID pattern
  • like_username (string, optional): Fuzzy search by username pattern
  • like_ip_address (string, optional): Fuzzy search by IP address pattern

get_mqtt_client

• Get detailed information about a specific MQTT client by client ID
• Inputs:
  • clientid (string, required): The unique identifier of the client to retrieve

kick_mqtt_client

• Disconnect a client from the MQTT broker by client ID
• Inputs:
  • clientid (string, required): The unique identifier of the client to disconnect

publish_mqtt_message

• Publish an MQTT Message to Your EMQX Cluster on EMQX Cloud or Self-Managed Deployment
• Inputs:
  • topic (string, required): MQTT topic to publish to
  • payload (string, required): Message content to publish
  • qos (number, optional): Quality of Service level (0, 1, or 2) (default: 0)
  • retain (boolean, optional): Whether to retain the message (default: false)

subscribe_mqtt_topic

• Subscribe to an MQTT topic via SSE on EMQX Cloud and collect messages for a specified duration
• Inputs:
  • topic (string, required): MQTT topic to subscribe to
  • duration (number, optional): How long to listen in seconds (1-300, default: 30)
  • max_messages (number, optional): Maximum messages to collect (1-1000, default: 100)
• Returns: Object containing topic, message_count, and messages array

Setup EMQX Cluster

Before using the EMQX MCP Server tools, you need to set up an EMQX cluster with properly configured API Key and client authentication. There are several options:

1. EMQX Cloud Serverless Deployment:

• The easiest way to get started with.
• Obtain a free server

... View full README on GitHub