EMQX

by benniu

25 stars
211 downloads
Not rated
GitHub

About

Integrates with EMQX MQTT broker to enable real-time IoT device management, client monitoring, and message publishing for MQTT-enabled systems.

Details

Author
benniu
Repository
Benniu/emqx-mcp-server
GitHub stars
25
Downloads
211
License
Apache License 2.0
Categories
Communication, Productivity, Design, Developer Tools, AI, Infrastructure, Community, Other

Jump to

- List, inspect, and disconnect MQTT clients
- Publish messages with QoS and retention control
- Subscribe to topics via SSE with duration and message limits
- Flexible client filtering by node, username, client ID
- Support for EMQX Cloud and self-hosted clusters

Setting up with Highlight

This MCP is not yet compatible with Highlight’s one-click setup. However, you can still use it with Highlight by following these steps:

  1. Download and install Highlight from highlightai.com/download
  2. Navigate to the plugins tab and select "Add Custom Plugin"
  3. Configure the plugin with the settings below
    Plugin Name EMQX
    Command (node, npx, python, etc.) docker
    Arguments
    • Argument 1 run
    • Argument 2 -i
    • Argument 3 --rm
    • Argument 4 -e
    • Argument 5 EMQX_API_URL=https://your-emqx-cloud-instance.com:8443/api/v5
    • Argument 6 -e
    • Argument 7 EMQX_API_KEY=<YOUR-API-KEY>
    • Argument 8 -e
    • Argument 9 EMQX_API_SECRET=<YOUR-API-SECRET>
    • Argument 10 benniuji/emqx-mcp-server

    Please refer to the README for specific instructions on how to obtain API keys or other required environment variables.

  4. Enable "Start Automatically" if you want the plugin to start when Highlight launches

From the repository

Running Locally With The Claude Desktop App

To install emqx-mcp-server for Claude Desktop automatically via](https://www.emqx.com/en/try?tab=self-managed)Smithery:

npx -y @smithery/cli install @Benniu/emqx-mcp-server --client claude

-

InstallClaude Desktop Appif you haven't done so yet.

Add the following to yourclaude_desktop_config.jsonfile:

- On MacOS:~/Library/Application\ Support/Claude/claude_desktop_config.json
- On Windows:%APPDATA%/Claude/claude_desktop_config.json

{ "mcpServers": { "EMQX_MCP_Server": { "command": "docker", "args": [ "run", "-i", "--rm", "-e", "EMQX_API_URL=https://your-emqx-cloud-instance.com:8443/api/v5", "-e", "EMQX_API_KEY=<YOUR-API-KEY>", "-e", "EMQX_API_SECRET=<YOUR-API-SECRET>", "benniuji/emqx-mcp-server" ] } } }

Note: Update the env variables:EMQX_API_URL,EMQX_API_KEY,EMQX_API_SECRET

Try asking Claude to do something with the MQTT broker (e.g. ask it to publish an MQTT message to a topic).

First, ensure you have theuvexecutable installed. If not, you can install it by following the instructionshere.
- InstallClaude Desktop Appif you haven't done so yet.
- Clone this repository.
- Add the following to yourclaude_desktop_config.jsonfile:

- On MacOS:~/Library/Application\ Support/Claude/claude_desktop_config.json
- On Windows:%APPDATA%/Claude/claude_desktop_config.json

{ "mcpServers": { "EMQX_MCP_Server": { "command": "uv", "args": [ "--directory", "path/to/repo/src/emqx_mcp_server", "run", "emqx-mcp-server" ], "env":{ "EMQX_API_URL":"https://your-emqx-cloud-instance.com:8443/api/v5", "EMQX_API_KEY":"<YOUR-API-KEY>", "EMQX_API_SECRET":"<YOUR-API-SECRET>" } } } }

Please list the clients connected to the MQTT broker.

Here are the clients currently connected to your MQTT broker: Connected Client: - Client ID: mqttx_2232bdb1 - Username: test - Protocol: MQTT v5 ... There is currently 1 client connected to your MQTT broker. Would you like more detailed information about this specific client or would you like to perform another action with your MQTT broker?

Yes, please provide the detail info of this client.

I'll retrieve the detailed information for this client for you. ... Here's the detailed information for client "mqttx_2232bdb1": Basic Information: - Client ID: mqttx_2232bdb1 - Username: test ... Connection Details: - Connected: Yes - Created At: 2025-03-02T05:29:51.103+00:00 ... Would you like to perform any actions with this client, such as publishing a message to a topic or disconnecting the client?

Please write a poem and send it to the topic '/poem' with QoS 1.

I'll create a poem and publish it to the topic '/poem' with QoS 1. Let me do that for you. ... I've successfully published the poem to the topic '/poem' with QoS 1. The message has been delivered with ID: 00062F55A1EFB1156ABC481240B30000. The poem I sent was: - Signals in the ether, - Invisible threads that bind, - Devices speak in whispers, - Across the digital divide. - Messages like leaves falling, - From cloud to waiting ground, - Connected yet untethered, - Where silence makes no sound. - Brokers of the modern age, - Routing dreams from here to there, - In this web of connections, - We find ourselves everywhere. - Like stars in constellation, - Each point of light has worth, - The language of machines, - Redefining our Earth. Is there anything else you'd like to do with your MQTT broker?

Please kick out the client mqttx_2232bdb1

I'll disconnect the client from the MQTT broker for you. ... The client has been successfully disconnected. The system returned: > Client mqttx_2232bdb1 has been disconnected The MQTT client with ID "mqttx_2232bdb1" is now disconnected from your broker. Is there anything else you would like to do with your MQTT broker?

This project is licensed under the Apache License Version 2.0 - see theLICENSEfile for details.

Manage your WhatsApp, SMS and Phone Calls using a single MCP connector

Connect to any function, any language, across network boundaries using AgentRPC.

Access your meeting transcripts, summaries, and action items from any AI assistant.

Connect Claude, ChatGPT, and other AI tools to your Granola meeting notes via MCP. Query your notes, search transcripts, and get meeting insights in your favorite AI assistants.

Build with the Kudosity API to send SMS and MMS. Access developer docs, API references and live testing tools to send messages, manage contact lists, configure webhooks and more.

Send SMS, WhatsApp, and RCS messages programmatically with DLT compliance. Manage contacts, schedule campaigns, and track delivery reports.

Interact with Twilio APIs to send messages, manage phone numbers, configure your account, and more.

The VoIPstudio MCP server gives compatible AI assistants secure access to authorised VoIPstudio account data, including recordings, call detail records, live calls and voicemails in order to query call activity, analyse patterns, identify agent performance issues and generate QA or operations reports in plain English.

A bridge server connecting Agent Communication Protocol (ACP) agents with Model Context Protocol (MCP) clients.

list_mqtt_clients

List MQTT clients connected to your EMQX Cluster. Inputs: page (number, optional), limit (number, optional), node (string, optional), clientid (string, optional), username (string, optional), ip_address (string, optional), conn_state (string, optional), clean_start (boolean, optional), proto_ver (string, optional), like_clientid (string, optional), like_username (string, optional), like_ip_address (string, optional).

get_mqtt_client

Get detailed information about a specific MQTT client by client ID. Inputs: clientid (string, required).

kick_mqtt_client

Disconnect a client from the MQTT broker by client ID. Inputs: clientid (string, required).

publish_mqtt_message

Publish an MQTT Message to Your EMQX Cluster on EMQX Cloud or Self-Managed Deployment. Inputs: topic (string, required), payload (string, required), qos (number, optional), retain (boolean, optional).

subscribe_mqtt_topic

Subscribe to an MQTT topic via SSE on EMQX Cloud and collect messages for a specified duration. Inputs: topic (string, required), duration (number, optional), max_messages (number, optional). Returns: Object containing topic, message_count, and messages array.

Claude Desktop / Cursor

Paste into your MCP client config file to install this server.

{
    "mcpServers": {
        "emqx": {
            "env": {},
            "args": [
                "run",
                "-i",
                "--rm",
                "-e",
                "EMQX_API_URL=https://your-emqx-cloud-instance.com:8443/api/v5",
                "-e",
                "EMQX_API_KEY=<YOUR-API-KEY>",
                "-e",
                "EMQX_API_SECRET=<YOUR-API-SECRET>",
                "benniuji/emqx-mcp-server"
            ],
            "command": "docker"
        }
    }
}

Linux

{
    "env": [],
    "args": [
        "run",
        "-i",
        "--rm",
        "-e",
        "EMQX_API_URL=https://your-emqx-cloud-instance.com:8443/api/v5",
        "-e",
        "EMQX_API_KEY=<YOUR-API-KEY>",
        "-e",
        "EMQX_API_SECRET=<YOUR-API-SECRET>",
        "benniuji/emqx-mcp-server"
    ],
    "command": "docker"
}

Macos

{
    "env": [],
    "args": [
        "run",
        "-i",
        "--rm",
        "-e",
        "EMQX_API_URL=https://your-emqx-cloud-instance.com:8443/api/v5",
        "-e",
        "EMQX_API_KEY=<YOUR-API-KEY>",
        "-e",
        "EMQX_API_SECRET=<YOUR-API-SECRET>",
        "benniuji/emqx-mcp-server"
    ],
    "command": "docker"
}

Windows

{
    "env": [],
    "args": [
        "run",
        "-i",
        "--rm",
        "-e",
        "EMQX_API_URL=https://your-emqx-cloud-instance.com:8443/api/v5",
        "-e",
        "EMQX_API_KEY=<YOUR-API-KEY>",
        "-e",
        "EMQX_API_SECRET=<YOUR-API-SECRET>",
        "benniuji/emqx-mcp-server"
    ],
    "command": "docker"
}

EMQX MCP Server

smithery badge

<a href="https://glama.ai/mcp/servers/m7zgbcr053">
emqx-mcp-server MCP server
</a>

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 serverless deployment from EMQX Cloud
- Sign up at EMQX Cloud Serverless

2. EMQX Cloud Dedicated Deployment:
- Provides dedicated resources for production workloads
- Offers enhanced performance, reliability, and customization options
- Supports various cloud providers (AWS, GCP, Azure)
- Includes professional SLA and support
- Create a deployment at EMQX Cloud Dedicated

3. Self-hosted EMQX Platform:
- Download and deploy EMQX Platform locally
- Follow installation instructions at EMQX Platform

> Note: The subscribe_mqtt_topic tool uses the SSE (Server-Sent Events) endpoint, which is available on EMQX Cloud deployments. Not all self-hosted EMQX deployments support the SSE subscribe endpoint.

Running locally with the Claude Desktop App

Option 1: Installing via Smithery

To install emqx-mcp-server for Claude Desktop automatically via Smithery:

npx -y @smithery/cli install @Benniu/emqx-mcp-server --client claude

Option 2: Docker

1. Install Claude Desktop App if you haven't done so yet.
2. Pull the image:

   docker pull benniuji/emqx-mcp-server

3. Add the following to your claude_desktop_config.json file:
- On MacOS: ~/Library/Application\ Support/Claude/claude_desktop_config.json
- On Windows: %APPDATA%/Claude/claude_desktop_config.json

    {
      "mcpServers": {
        "EMQX_MCP_Server": {
          "command": "docker",
          "args": [
            "run",
            "-i",
            "--rm",
            "-e", "EMQX_API_URL=https://your-emqx-cloud-instance.com:8443/api/v5",
            "-e", "EMQX_API_KEY=<YOUR-API-KEY>",
            "-e", "EMQX_API_SECRET=<YOUR-API-SECRET>",
            "benniuji/emqx-mcp-server"
          ]
        }
      }
    }
Note: Update the env variables:``EMQX_API_URL`, `EMQX_API_KEY`, `EMQX_API_SECRET
4. Open or Restart Claude Desktop App
5. Try asking Claude to do something with the MQTT broker (e.g. ask it to publish an MQTT message to a topic).

Option 3: Manual Installation


First, ensure you have the uv executable installed. If not, you can install it by following the instructions here.


1. Install Claude Desktop App if you haven't done so yet.

2. Clone this repository.

3. Add the following to your claude_desktop_config.json file:

    - On MacOS: ~/Library/Application\ Support/Claude/claude_desktop_config.json

    - On Windows: %APPDATA%/Claude/claude_desktop_config.json

{
"mcpServers": {
"EMQX_MCP_Server": {
"command": "uv",
"args": [
"--directory",
"path/to/repo/src/emqx_mcp_server",
"run",
"emqx-mcp-server"
],
"env":{
"EMQX_API_URL":"https://your-emqx-cloud-instance.com:8443/api/v5",
"EMQX_API_KEY":"<YOUR-API-KEY>",
"EMQX_API_SECRET":"<YOUR-API-SECRET>"
}
}
}
}
    Note: Make sure to update
path/to/repo/src/emqx_mcp_server` to the actual path and modify the environment variables `EMQX_API_URL`, `EMQX_API_KEY`, and `EMQX_API_SECRET`` to match your EMQX instance.
4. Open or Restart Claude Desktop App
5. Try asking Claude to do something with the MQTT broker (e.g. ask it to publish an MQTT message to a topic).

Example Prompts

No reviews yet — be the first

Sign in to leave a review

Use Google, GitHub, or an email account so ratings stay tied to real people.

Email sign in

No reviews posted yet.

Install

Add to Claude Desktop or Cursor

{
    "mcpServers": {
        "emqx": {
            "env": {},
            "args": [
                "run",
                "-i",
                "--rm",
                "-e",
                "EMQX_API_URL=https://your-emqx-cloud-instance.com:8443/api/v5",
                "-e",
                "EMQX_API_KEY=<YOUR-API-KEY>",
                "-e",
                "EMQX_API_SECRET=<YOUR-API-SECRET>",
                "benniuji/emqx-mcp-server"
            ],
            "command": "docker"
        }
    }
}

More like this

Similar MCP servers you might find useful

Browse category

Time

A Model Context Protocol server that provides time and timezone conversion capabilities. It enables LLMs to get current time information and perform timezone…

88.2k
Productivity
SSE

Github SSE

The GitHub MCP Server allows AI tools like GitHub Copilot in VS Code and Visual Studio, Claude Desktop, and others to seamlessly access live GitHub context and…

5.0 15.8k
Developer Tools

BlenderMCP

BlenderMCP connects Blender to Claude AI through the Model Context Protocol (MCP), allowing Claude to directly interact with and control Blender. This…

10.1k
Developer Tools