メインコンテンツまでスキップ

Pulsarの使用

機能​

Pulsarは人気のあるパブリッシュ/サブスクライブメッセージングシステムで、ストリーミングとキューイングの両方のユースケースをサポートしています。JHipsterはPulsarをオプションでサポートしており、次のことを実現します。

  • PulsarクライアントをJHipsterで構成します。
  • Docker Compose設定ファイルを生成します。これによりPulsarがdocker-compose -f src/main/docker/pulsar.yml up -dで使用可能となります。
  • Spring Cloud Stream PulsarバインダーとTestcontainersを使用して統合テストを生成します。

前提条件​

新しいアプリケーションを生成し、使用したいテクノロジのプロンプトが表示されたら、必ずAsynchronous messages using Apache Pulsarを選択してください。Docker Compose設定ファイルが生成され、次のコマンドでPulsarを起動できます。

docker-compose -f src/main/docker/pulsar.yml up -d

Usage​

JHipsterでPulsarを使用する方法については、Spring for Apache Pulsar documentationのドキュメントを確認してください（アプリケーションのREADME.mdに生成されたバージョン管理されたpulsarドキュメントリンクをお勧めします）。 Pulsarと対話するには、抽象化の最低レベルから最高レベルまで、いくつかの方法があります。

  • Producer/Consumer/ReaderをそれぞれPulsarProducerFactory/PulsarConsumerFactory/PulsarReaderFactoryから生成します。
  • PulsarTemplateを注入してPulsarListener Beanを作ります。
  • application.ymlおよびSupplier/Consumer/Function BeanでSpring Cloud Streamsバインダーを構成します（例については生成されたテストを参照してください）。