Pulsarの使用 パーマリンク to " Pulsarの使用"

機能 パーマリンク to "機能"

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

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

前提条件 パーマリンク to "前提条件"

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

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

Usage パーマリンク to "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バインダーを構成します(例については生成されたテストを参照してください)。