EMQX MQTT 브로커 상호 작용을 제공하는 모델 Context Protocol (MCP) 서버 구현. MCP 클라이언트가 EMQX Cloud 또는 자체 호스팅 클러스터에 MQTT 클러스터와 상호 작용

특징

MQTT 클라이언트 관리

• Client Listing: 유연한 필터링 옵션으로 모든 연결된 MQTT 클라이언트 보기
• 고객 정보 : 특정 고객에 대한 자세한 정보를 검색
• 연결 통제: 브로커에서 문제 또는 stale 클라이언트를 분리하십시오
• Flexible Filtering : 노드, 사용자 이름, 클라이언트 ID, 연결 상태 등 필터 클라이언트

MQTT 메시지 출판

• 토픽 기반 출판 : 모든 MQTT 주제로 메시지를 전송
• QoS 통제: 믿을 수 있는 납품을 위한 서비스 수준 (0, 1, 또는 2)의 질을 선정하십시오
• Message Retention: 새로운 가입자 메시지에 대한 옵션
• Custom Payloads: 모든 메시지 내용 형식 지원

MQTT 주제 구독 (SSE)

• 실시간 구독 : Server-Sent Events (SSE)를 통해 MQTT 주제에 가입하십시오.
• 지속 시간 제어 : 메시지를 듣는 데 얼마나 오래 형성 (1-300 초)
• Message Limiting: 구독 당 수집하는 메시지의 최대 번호 설정

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