MQ Telemetry Transport

MQ Telemetry Transport(Message Queue Telemetry Transport、略称 MQTT)は、メッセージ指向ミドルウェアのアプリケーション層で使用される、TCP/IPによるPub/Sub型データ配信モデルの軽量なメッセージキュープロトコルである。

非力なデバイスやネットワークが不安定な場所でも動作しやすい様にメッセージ通信電文が軽量に設計されている事が特徴。

Pub/Sub型メッセージング·パターンには、メッセージブローカーが必要である。

ブローカーは、メッセージのTopicに基づいて、それを必要としているクライアントにメッセージ配信をしている。

アンディー·スタンフォード·クラークとシーラスリンクソリューションのアーレンニッパーは1999年に、プロトコルの最初のバージョンを執筆している。

仕様

仕様はロイヤリティフリーで公開されていて、現在の仕様は3.1となっている。

特徴

次の様な特徴を持っている。

軽量なプロトコル

プロトコル電文仕様が軽量で且つシンプルになっている。

• ヘッダーサイズが最小で 2 byte
• シンプルなプロトコルシーケンス

柔軟性の高いメッセージ配布(Sub：購読)

配布先条件が"/"区切りの階層構造になっていて、且つワイルドカードによる指定ができる。
配布先はそのパターンにマッチした宛先になる。

• TopicベースでのPub/Sub
• 1対1、1対N、N対Nのメッセージ配布

メッセージ配布の品質

アプリケーションの特性に合わせて三種類のQoS(Quality of Service)レベルの指定ができる。

• QoS0：最高１回
  • メッセージが確実に届く保証はない
  • メッセージ配布に失敗しても再送をしない
• QoS1：最低１回
  • 必ずメッセージ配布するが、重複する可能性がある
• QoS2：正確に１回
  • 必ずメッセージを配布して、重複も発生しない

メッセージ再配布機能

メッセージ再配布機能(Durable subscribe)は、次のフローで処理がされる。

1. 意図せずにSubscriber(メッセージ配布)通信が切断
2. その後、当該のSubscriberが再接続
3. 切断から再接続までに発生したメッセージを再送処理
4. QoS1,2のメッセージを再配布する

Retain

• ブローカーが最後に配布したメッセージは必ず保存する

ブローカー

MQTTをサポートするブローカー(MQサーバ)は数多くある。

それぞれのサーバがサポートする機能には、基本機能の他，サーバ特有の機能を持っている。

主なMQTTブローカーは以下の通り。

• IBM MessageSight (商用、ハードウェア)
• IBM WebSphere MQ Telemetry (商用)
• 時雨堂 Akane (商用)
• Mosquitto (OSS)
• RabbitMQ (OSS) _{※Pluginが必要}
• Apache_ActiveMQ (OSS)

使用しているプロジェクト

現実の世界では、MQTTを実装するプロジェクトの数がある。

Facebook Messenger

FacebookのメッセンジャーにMQTTを使用している。

IECC Scalable

IECCシグナリング制御システムのDeltaRailの最新バージョンでは、システムとシグナリングシステムの他の構成要素のさまざまな部分内の通信のためのMQTTを使用している。