Vert.x for IoT: Reactive, Async, and JVM-Native

Vert.x は JVM 上でリアクティブで分散型のシステムを構築するためのツールキットです。その中核的な約束は、単一のイベントループ上での非同期・ノンブロッキング I/O であり、マルチスレッドの複雑さなしに毎秒数百万のイベントを処理します。デバイス数とメッセージ量が爆発的に増加する IoT にとって、このアーキテクチャは自然な適合です。

IoT 対応コンポーネント

Vert.x には IoT ワークロード向けに調整されたいくつかのコンポーネントが含まれています:

• HTTP サーバー (Core) — RESTful API 向けに HTTP/1.1 と HTTP/2 をサポート。IoT に参入する Web/モバイル開発者にとって馴染み深いものです。
• MQTT サーバー — 完全なブローカーではなく、MQTT 接続とメッセージを処理する API です。開発者はその上にビジネスロジックを構築します — プロトコル変換、イベントバスブリッジング、またはカスタムブローカーなど。
• Proton & AMQP ブリッジ — Apache Qpid Proton の薄いラッパーで AMQP 1.0 に対応。このブリッジは AMQP を Vert.x のイベントバスに接続し、vert icle が AMQP システムと透過的に通信できるようにします。
• Kafka クライアント — Kafka トピックへの送信・消費を行います。多くの IoT パイプラインは、毎秒数百万のメッセージを取り込むために Kafka に依存しています。

なぜ IoT に適しているのか

リアクティブマニフェストの原則 — 応答性、弾力性、回復力、メッセージ駆動 — は IoT の要件に直接対応します。デバイスは信頼性が低く、トラフィックの急増は過酷で、レイテンシの期待は厳しいものです。Vert.x のイベントループモデルはスレッドあたりの接続オーバーヘッドを回避し、スループットが拡大してもメモリをフラットに保ちます。

MQTT サーバーコンポーネントは特に実用的です: 完全なブローカースタックを強制するのではなく、接続とメッセージのイベントを公開します。ルーティング — Kafka へ、AMQP ブローカーへ、イベントバスへ、またはカスタム TCP エンドポイントへ — はあなたが決定します。この柔軟性は、アーキテクチャがプロトコルの寄せ集めである場合に重要です。

「開発者は、MQTT がワイヤ上でどのようにエンコード/デコードされるかを知る必要はありません。」 — Paolo Patierno, Red Hat

執筆時点 (Vert.x 3.3.3) では、Proton と AMQP ブリッジは安定していました。MQTT サーバーと Kafka クライアントは 3.4.0 向けに開発中でした。エコシステムはその後成熟しましたが、アーキテクチャの原則は変わりません。