EMQX MQTTブローカーの相互作用を提供するモデルコンテキストプロトコル(MCP)サーバーの実装。 MCP クライアントを EMQX クラウド上の MQTT クラスター または セルフホストクラスター と やり取り

##特徴

##MQTTクライアント管理

• クライアントリスト:柔軟なフィルタリングオプションで接続されているすべてのMQTTクライアントを見る
• クライアント情報:特定のクライアントに関する詳細情報を取得する
• 関係制御:ブローカーから問題のあるまたは屋台クライアントを切断
• 柔軟なフィルタリング:ノード、ユーザー名、クライアントID、接続状態などによるクライアントのフィルタリング

##MQTT メッセージ出版

• Topic-basedパブリッシング:あらゆるMQTTトピックにメッセージを送信する
• QoSの制御:信頼できる配達のためのサービス レベル(0、1、または2)の質を選んで下さい
• メッセージ保持:新しい加入者のための永続的なメッセージへのオプション
• カスタムペイロード:任意のメッセージコンテンツフォーマットのサポート

MQTT トピックサブスクリプション (SSE)

• リアルタイムサブスクリプション: Server-Sent Events(SSE) で MQTT トピックを購読
• 期間制御:メッセージ(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