MQTT アドバンスド
Retained Messages（保持メッセージ）
MQTTのRetained Messagesは、ブローカーが各トピックの最新メッセージを保存し、新たに接続したサブスクライバーが次のパブリッシュイベントを待つことなく即座に最新データを受信できる仕組みです。この機能は、スマートホームや産業用IoTのように、データ更新が稀でもリアルタイムの状態把握が重要なシナリオで特に有用です。
EMQXはMQTT 5.0に準拠した保持メッセージを完全にサポートしており、直感的なダッシュボードや管理APIを通じて保持メッセージの閲覧、管理、削除が可能です。メモリまたはディスクのストレージモード、メッセージの有効期限、最大保持件数などを設定し、システムの信頼性や永続化要件に合わせて調整できます。
試すには、docker run -d --name emqx -p 18083:18083 -p 1883:1883 emqx/emqx-enterprise を実行し、組み込みのダッシュボードから保持メッセージを簡単に管理してください。より高度なユースケースには、セッション永続化、ワイルドカードサブスクライブ、メッセージ有効期限などのMQTT機能もサポートしており、堅牢なMQTTベースのアプリケーション構築に最適です。
詳細はこちら: MQTT Retained Messages: Beginner's Guide with Example
Will Messages（遺言メッセージ）
MQTTのWill Messageは、クライアントが予期せず切断された場合に他のクライアントへの通知やバックアップ機器への切り替えなどの適切な処理を可能にする重要な機能です。クライアントが接続時にWill Messageを指定すると、クライアントが正常なDISCONNECTパケットを送信せずに切断された場合にサーバーがそのメッセージを送信します。この仕組みはクライアントの状態監視とIoTアプリケーションの信頼性確保に役立ちます。
MQTT 5.0ではWill Delay Intervalが導入され、一時的なネットワーク障害時の不要な通知を減らすためにWill Messageの送信を遅延可能です。メッセージはサーバーのセッションに保存され、セッションの有効期限切れまたは遅延時間のいずれか早い方で配信されます。EMQXはWill Messageの保持やセッション有効期限通知との連携をサポートし、クライアント状態の高度な監視を実現します。この機能は、レジリエントでリアルタイムなIoTアプリケーション構築に不可欠であり、システム運用者がデバイスやクライアントの状態変化を迅速に把握できるようにします。
詳細はこちら: MQTT Will Message (Last Will & Testament) Explained and Example | MQTT 5 Features
Request / Response（リクエスト／レスポンス）
MQTT 5.0はRequest/Responseパターンを3つの主要機能で改善しました。Response Topicはリクエスターがレスポンス用のユニークなトピックを指定でき、競合を減らします。Correlation Dataは非同期や複数レスポンダーのシナリオでもレスポンスとリクエストを紐付けるのに役立ちます。Response Informationはレスポンストピック構築のためにリクエスターがサーバー固有の情報を受け取れるようにし、トピック権限管理を容易にします。これらにより、特に複雑なIoT環境で信頼性と整理された通信が実現します。
詳細はこちら: MQTT Request / Response Explained and Example | MQTT 5 Features
User Properties（ユーザープロパティ）
MQTT 5.0のUser Propertiesは、HTTPヘッダーのようにクライアントがメッセージにキー・バリュー形式のカスタムメタデータを付加できる機能です。これにより、ファイル転送、リソース形式識別、インテリジェントなメッセージルーティングなどのユースケースでプロトコルの柔軟性が大幅に向上します。User Propertiesは接続時、パブリッシュ時、サブスクライブ時、切断時に追加可能で、クライアントとブローカー間のシームレスなメタデータ交換を実現します。例えばファイル情報、データ形式、地域タグなどを運び、サーバー側で効率的なメッセージ処理やトレーサブルなアプリケーションレベルルーティングを可能にします。EMQXはUser Propertiesを完全サポートし、MQTT.jsや今後リリース予定のMQTTXなどクライアントでも豊富な互換性を提供します。
詳細はこちら: User Properties - MQTT 5.0 new features
Topic Alias（トピックエイリアス）
Topic Aliasは、長く繰り返し使用されるトピック名を2バイトの整数に置き換え、パブリッシュ時の帯域幅消費を削減する機能です。
EMQXはTopic Aliasをサポートし、メッセージサイズの最適化と効率向上を実現、特に帯域幅が限られた環境で効果を発揮します。
詳細はこちら: Topic Alias - MQTT 5.0 new features
Payload Format Indicator & Content Type（ペイロードフォーマットインジケーターとコンテントタイプ）
Payload Format IndicatorとContent Typeは、MQTT 5.0の重要なプロパティで、メッセージ解析の透明性を高めます。前者はペイロードがバイナリかUTF-8テキストかを識別し、後者はMIMEタイプ（例：application/json）でペイロード形式を表します。
これらによりサブスクライバーは効率的にメッセージを解釈でき、トピック名に依存しない柔軟なコンテンツ処理が可能になります。EMQXは両プロパティをサポートし、多様なIoTおよびメッセージングアプリケーションでスマートなペイロード処理を実現します。
詳細はこちら: Introduction to MQTT Payload Format Indicator and Content Type | MQTT 5 Features
Shared Subscriptions（共有サブスクリプション）
MQTT 5.0のShared Subscriptionsは、複数のクライアントが単一トピックのメッセージ消費を共有し、負荷分散とシステムのスケーラビリティ向上を可能にします。EMQXはこの機能を完全サポートし、MQTT 3.1.1クライアントにも互換性を拡張しているため、既存デバイスはコード変更なしで$share/{group}/{topic}形式を使うだけで共有消費の恩恵を受けられます。
この仕組みはスループットを向上させ、単一クライアントのボトルネックを防ぎ、高可用性を確保します。ラウンドロビン、ハッシュ、ローカルファーストなど複数のロードバランシング戦略を内蔵し、クラスター環境でのトラフィック分散を柔軟に管理できます。
詳細はこちら: MQTT Shared Subscriptions: Practical Guidelines and Use Cases | MQTT 5 Features
Subscription Options（サブスクリプションオプション）
MQTTのSubscription Optionsは、クライアントがメッセージ受信方法をカスタマイズできる機能です。MQTT 5.0では、QoS、No Local、Retain As Published、Retain Handlingの4つの主要オプションが導入され、柔軟性と制御性を強化しています。これにより、メッセージ品質管理、ブリッジング時のメッセージループ回避、保持フラグの維持、保持メッセージの受信タイミングの制御が可能です。
EMQXはMQTT 5.0の全サブスクリプションオプションを完全サポートし、例えばNo Localでブリッジ設定時のメッセージ嵐を防止し、Retain As Publishedでブローカー間の保持メッセージ処理を一貫させるなど、細かなメッセージ配信制御を実現します。
詳細はこちら: MQTT Subscription Options Explained and Example | MQTT 5 Features
Subscription Identifier（サブスクリプション識別子）
MQTT 5.0のSubscription Identifierは、各サブスクリプションに一意の識別子を割り当て、クライアントが複数のサブスクリプションを効率的に管理・追跡できる機能です。多数のサブスクリプションを持つ複雑なアプリケーションで特に有用です。
EMQXはこの機能を完全サポートし、ワイルドカードや重複するサブスクリプションでもメッセージの発信元を正確に特定可能です。PUBLISHパケットにSubscription Identifierを含めることで、クライアント側でのトピックフィルター照合を不要にし、メッセージ処理効率を大幅に向上させ、正確なコールバック実行を可能にします。
詳細はこちら: MQTT Subscription Identifier Explained and Example | MQTT 5 Features
Keep Alive（キープアライブ）
MQTTのKeep Alive機構は、クライアントが一定間隔内に定期的なパケットを送信することで、半開きTCP接続を防止します。データ送信がない場合はPINGREQで接続確認を行います。EMQXはクライアント指定およびサーバー強制のKeep Alive値を完全サポートし、MQTT 5.0のServer Keep Alive機能も対応しています。server_keepaliveやkeepalive_backoffなどの設定項目により、接続タイムアウトを細かく制御でき、IoT環境での信頼性向上やクライアントの予期せぬ切断時のWill Message送信を確実にします。
詳細はこちら: What is the MQTT Keep Alive parameter for?
Message Expiry Interval（メッセージ有効期限間隔）
MQTT 5.0のMessage Expiry Intervalは、メッセージが即時配信できない場合にブローカーが保持する最大時間を設定できる機能です。期限切れ後はメッセージが破棄され、古い情報の送信を防止します。
EMQXはこの機能を完全サポートし、メッセージ転送やブリッジング時に有効期限を減算し、分散環境全体でメッセージの鮮度を保ちます。
詳細はこちら: Introduction to MQTT Message Expiry Interval | MQTT 5 Features
Maximum Packet Size（最大パケットサイズ）
MQTT 5.0のMaximum Packet Sizeプロパティは、クライアントとサーバーが安全なパケットサイズ上限を交渉し、リソース制約のあるデバイスの過負荷を防ぐ機能です。クライアントはCONNECTパケットで受信可能サイズを宣言し、サーバーはCONNACKパケットで応答します。EMQXは双方向の制約を適用し、規定サイズを超えるメッセージは破棄したり、レスポンスパケットから低優先度のメタデータ（User Propertiesなど）を削除して接続安定性を維持します。共有サブスクリプションでは、EMQXがサイズ超過メッセージを適格なグループメンバーにリダイレクトすることも可能です。
詳細はこちら: MQTT Maximum Packet Size Explained and Example | MQTT 5 Features
Reason Codes（理由コード）
MQTT 5.0は、MQTT 3.1.1の限定的なステータス応答に比べて大幅に強化された包括的なReason Codeシステムを導入しました。これにより接続、パブリッシュ、サブスクライブなどの操作結果を詳細に示し、開発者が問題を迅速に診断し、デバイス管理やメッセージ処理を最適化できます。
EMQXはMQTT 5.0のReason Codesを完全サポートし、正確なエラーハンドリングとインテリジェントな運用管理を可能にして、IoTシステムの安定性と応答性を向上させます。
詳細はこちら: MQTT Reason Code Introduction and Quick Reference
Enhanced Authentication（拡張認証）
MQTT 5.0は、単純なパスワード認証の脆弱性（平文パスワード送信や相互認証の欠如）を克服するため、より安全な拡張認証フレームワークを導入しました。AUTHパケットを利用し、複数回のメッセージ交換やDIGEST-MD5、SCRAM、KerberosなどのSASLメカニズムをサポートします。
EMQXはSCRAMをサポートし、ユーザーが強力かつ柔軟な認証方式を選択してIoTインフラを保護できるようにします。
詳細はこちら: Leveraging Enhanced Authentication for MQTT Security
Control Packets（コントロールパケット）
MQTTのコントロールパケットは、クライアントとブローカー間の通信方法を定義し、接続、パブリッシュ、サブスクライブなど15種類の操作を含みます。各パケットは固定ヘッダー、オプションの可変ヘッダー、オプションのペイロードで構成され、軽量かつ効率的なデータ交換を実現します。MQTT 5.0ではプロパティの追加や認証の強化によりさらに柔軟性が向上しています。
詳細はこちら: MQTT Control Packets: A Beginner's Guide
MQTTに関する詳細は以下をご覧ください: MQTT Guide 2025: Beginner to Advanced