2.9. MicroProfile Reactive Messaging

JBoss EAP XP 4.0.0 にアップグレードする際に、リアクティブメッセージングエクステンションおよびサブシステムが含まれる最新バージョンの MicroProfile Reactive Messaging を有効化できます。

リアクティブストリームは、処理プロトコルと標準とともに一連のイベントデータであり、バッファリングなしで非同期境界 (スケジューラーなど) を超えてプッシュされます。イベントは、たとえば、天気予報アプリケーションでスケジュールされ、繰り返される温度チェックの場合があります。リアクティブストリームの主な利点は、さまざまなアプリケーションと実装のシームレスな相互運用性です。

リアクティブメッセージングは、イベント駆動型、データストリーミング、およびイベントソーシングアプリケーションをビルドするためのフレームワークを提供します。リアクティブメッセージングにより、あるアプリケーションから別のアプリケーションへのイベントデータ (リアクティブストリーム) の継続的かつスムーズな交換が実現します。MicroProfile Reactive Messaging を使用して、リアクティブストリームを介した非同期メッセージングを行うことができます。これにより、アプリケーションは、たとえば Apache Kafka などの他のアプリケーションと対話できます。

MicroProfile Reactive Messaging のインスタンスを最新バージョンにアップグレードした後、次の操作を実行できます。

コネクターを使用して、MicroProfile Reactive Messaging を多数の外部メッセージングシステムと統合できます。MicroProfile for JBoss EAP には、Apache Kafka コネクターが付属しています。Eclipse MicroProfile Config 仕様を使用して、コネクターを設定します。

Apache Kafka コネクターと組み込まれたレイヤー

MicroProfile Reactive Messaging には、MicroProfile Config で設定できる Kafka コネクターが含まれています。Kafka コネクターには、microprofile-reactive-messaging-kafka レイヤーと microprofile-reactive-messaging レイヤーが組み込まれています。microprofile-reactive-messaging レイヤーは、コアの MicroProfile Reactive Messaging 機能を提供します。

Apache Kafka は、レコードのストリームをリアルタイムでパブリッシュ、登録、保存、および処理できるオープンソースの分散イベント (データ) ストリーミングプラットフォームです。複数のソースからのイベントストリームを処理し、それらを複数のコンシューマーに配信して、大量のデータをポイント A から Z、およびその他の場所にすべて同時に移動します。MicroProfile Reactive Messaging は、Apache Kafka を使用して、これらのイベントレコードをわずか 2 マイクロ秒で配信し、分散したフォールトトレラントクラスターに安全に保存し、チーム定義のゾーンまたは地理的地域全体で利用できるようにします。