Реализация сервера Model Context Protocol (MCP), обеспечивающего взаимодействие брокера EMQX MQTT. Взаимодействие MCP-клиентов с кластерами MQTT в облаке EMQX или в автономных кластерах

Особенности

###Управление клиентами MQTT

Просмотр всех подключенных клиентов MQTT с гибкими вариантами фильтрации Информация о клиентах: Получите подробную информацию о конкретных клиентах Контроль подключения: Отключите проблемных или устаревших клиентов от брокера Гибкая фильтрация: клиенты фильтра по узлу, имени пользователя, идентификатору клиента, состоянию соединения и многим другим

MQTT Message

Тематическая публикация: отправляйте сообщения на любые темы MQTT QoS Control: Выберите уровень качества обслуживания (0, 1, или 2) для надежной доставки Сохранение сообщений: возможность сохранения сообщений для новых подписчиков Пользовательские полезные нагрузки: поддержка любого формата содержимого сообщения

Тематическая подписка MQTT (SSE)

Подписка в режиме реального времени: Подпишитесь на темы MQTT через события, отправленные сервером (SSE) Управление продолжительностью: Настройка продолжительности прослушивания сообщений (1-300 секунд) Ограничение сообщений: Установите максимальное количество сообщений для сбора за подписку

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