MQTT for AI

MQTT for AI は、インテリジェント IoT アプリケーション向けに特別に設計された次世代 MQTT プロトコル拡張を表します。4 つの主要なイノベーションが含まれます：モバイルシナリオでの信頼性の高い接続を実現する MQTT over QUIC、AI エージェント通信のための MCP over MQTT、リアルタイム産業オートメーションのための MQTT/RT、そして永続データストレージとリプレイのための MQTT Streams です。これらの拡張により、EMQX はインテリジェント IoT の統一神経システムとして機能し、自動運転車から工場ロボットまですべてをエッジ AI 機能で接続できます。

MCP over MQTT は、モデルコンテキストプロトコル（MCP）のトランスポートとして MQTT を使用し、MQTT が既にメッセージングバックボーンとなっている IoT、エッジコンピューティング、クラウドからエッジへの展開において、MCP をより適したものにします。組み込みのサービスレジストリと検出機能（クライアントはブローカーを介して利用可能な MCP サーバーを見つけることができます）を追加し、サーバーインスタンスを追加することでスケーラブルな展開をサポートします。これは既存の MCP トランスポート（stdio / HTTP SSE）を置き換えるためのものではなく、リモート MCP サーバーとエッジ AI エージェントシナリオのための代替手段を提供します。

大規模化と効率化を目的としています。MQTT Streams/Queues は、ブローカー内部にネイティブな永続化ストレージ、データ保持（リテンション）、リプレイ/オフセットベースの消費、およびバッファリング機能（セマンティクス）を導入します。これらは、データパイプラインの構築、オフライン処理、そしてエッジ・クラウド間のバックプレッシャー制御において非常に有用です。また、「バッチパブリッシュ」機能により、複数の論理メッセージを単一の MQTT 5.0 PUBLISH パケットにまとめて送信できます。これにより、ヘッダーやトピックのオーバーヘッドを削減し、スループットを大幅に向上させます。さらに、「サブスクリプションフィルター」は、サブスクライブ時に第2のフィルタリング層を追加します。これにより、サブスクライバーは実際に必要なメッセージのみを受信できるため、帯域幅の節約とダウンストリームシステムの処理負荷軽減につながります。