手助けの為のQuarkus Superheroes!

ただ面白いだけではなく、いくつかの条件が必要でした:

Heroサービスは、完全にリアクティブでノンブロッキングなHTTPマイクロサービスで、 Hero データモデルに対するCRUD操作を公開しています。REST層は、 RESTEasy Reactiveを使用してリアクティブなエンドポイントを実装しています。データは、 Quarkus Hibernate Reactive with Panacheの リポジトリパターンを使用して PostgreSQLデータベースに永続化されます。さらに、Heroサービスは、 フィールドインジェクションよりもビーンの コンストラクタインジェクションを優先します。Heroサービスには、ユニットテストと統合テストの完全なスイートが含まれており、 モッキング、 スパイ、 隔離されたトランザクション内でのテストを使用しています。

Villainサービスは、 Villain データモデルに対するCRUD操作を公開するブロッキングHTTPマイクロサービスです。実際、 Villain データモデルは、 Heroサービスの Hero データモデルと同一です（テーブルの名前以外は）。また、Heroサービスと同じユースケースをすべて実装しています。唯一の違いは、Villainサービスがブロッキングであることと、 Quarkus Hibernate ORM with Panacheの active recordパターンを使用していることです。

REST層は、 RESTEasy Reactiveを使って、ブロック型のエンドポイントで実装されています。データは PostgreSQLデータベースに保存されます。Villainサービスはまた、いくつかのカスタム設定を作成して、どのように ConfigMappingオブジェクトを使うかを示すカスタム設定も作成します。さらに、Villainサービスは コンストラクタ・インジェクションよりもビーンの フィールド・インジェクションを好みます。Villainサービスはユニットテストと統合テストの完全なスイートを含み、 モッキング、 スパイ、 隔離されたトランザクション内でのテストを用います。

Fightサービスは、完全にリアクティブでノンブロッキングなHTTPマイクロサービスで、ヒーローとヴィランの間で戦いを実行するためのRESTful APIを公開しています。REST層は RESTEasy Reactiveを使用して実装されており、リアクティブなエンドポイントを備えています。戦いのデータは、 Quarkus Hibernate Reactive with Panacheの active recordパターンを使用してPostgreSQLデータベースに永続化されます。また、Fightサービスでは、 フィールド・インジェクションよりも コンストラクタ・インジェクションを採用しています。

Fightサービスは、HeroサービスとVillainサービスの両方にREST呼び出しを行います。Heroサービスへの呼び出しは reactive rest clientを使用し、Villainサービスへの呼び出しは RESTEasy Reactive clientを使用します。RESTEasy Reactive clientは、 JAX-RSクライアントAPIの MicroProfile Rest Client実装であり、そのコアはノンブロッキングです。すべての発信コールは、 リトライ、 タイムアウト、 フォールバック、 サーキットブレーキングなどの レジリエンスパターンを使用しています。

さらに、Fightサービスは、 Apache Avro形式のファイトイベントをKafkaに エミットします。Fightスキーマは、 QuarkusのApicurio Avroエクステンションによって、 Apicurio Schema Registryに自動的に登録されます。

Fightサービスには、ユニットテストとインテグレーションテストの完全なスイートが含まれており、 モッキング、 スパイ、 隔離されたトランザクション内でのテストを使用しています。また、下流のRESTエンドポイントをモックするための Wiremockや、ユニット・テスト内でメッセージの検証を行うための インメモリKafkaコネクタを多用しています。また、 Dev Servicesの情報を注入して、 KafkaConsumer.NETなどのテスト・リソースを設定する方法も紹介しています。

Event Statistics サービスは、 WebSocketHTTPレイヤーを公開するイベント駆動型のマイクロサービスです。 SmallRye Reactive Messagingを利用したKafkaトピック上で、 Apache Avroフォーマットの試合イベントをリッスンします。戦いのスキーマは、 Quarkus Apicurio Avro extensionによって Apicurio Schema Registryに自動的に登録されます。

統計情報は、上の図2に示すように、ブラウザベースのユーザーインターフェースで表示されます。チームの統計は、ヒーローとヴィランの勝利数の割合で表示されます。勝者の統計は、ヒーローとヴィランのそれぞれの勝利数で蓄積され、上位10人の勝利数が保持されます。統計情報は、WebSocketを介してUIにプッシュされます。

Event Statistics サービスには、 モッキングと スパイを使用したユニット・テストと統合テストの完全なスイートが含まれています。また、 Dev Services の情報を注入して、 KafkaProducer のようなテスト・リソースを構成する方法も紹介しています。

上の図1に示されているSuper Hero UIアプリケーションは、Node.jsを介してデプロイされた Angularシングルページアプリケーションです。このアプリケーションは、RESTを介してFightサービスと通信します。サンプルアプリケーションでは、Angular UIではなくQuarkusアプリケーションに焦点を当てています。

アプリケーション全体またはそのサブセットを、1つのDocker Composeコマンドで起動することができます。

各サービスは、 Quarkus Dev Modeを介して同時に実行することもできます。各Quarkusサービス（ event-statistics, rest-fights, rest-heroes, rest-villains ）について、ターミナルを開き、 cd をプロジェクトディレクトリに入れて、 ./mvnw quarkus:dev を実行してください。

Super Heroes UIは ソースからビルドして実行することができますが、この記事の焦点はQuarkusなので、コンテナイメージとして実行します。新しいターミナルを開き、 docker run -p 8080:8080 -e API_BASE_URL=http://localhost:8082 quay.io/quarkus-super-heroes/ui-super-heroes:latest を実行します。

準備が整い次第、以下のURLで利用可能になります。

これで、アプリケーション全体で Quarkus Dev Modeと Quarkus Continuous Testingのすべてのメリットを一度に得られるようになりました。すべてのバッキングインフラ（データベース、Kafka、Apicurio）は、 Quarkus Dev Servicesによって自動的にプロビジョニングされます。