Java を使用して Spring Cloud Stream に基づくメッセージ駆動型アプリケーションを開発する方法

Java を使用して Spring Cloud Stream に基づくメッセージ駆動型アプリケーションを開発する方法

クラウド コンピューティングとビッグ データ テクノロジの急速な発展により、メッセージ駆動型アプリケーションが登場しました。建物流通システムの重要な部分となっています。 Spring Cloud Stream は Spring エコシステムの重要なコンポーネントであり、スケーラブルな分散アプリケーションを迅速に構築するのに役立つ、シンプルかつ強力なメッセージ駆動型モデルを提供します。

この記事では、読者がこのテクノロジーをよりよく理解し、使用できるように、Java を使用して Spring Cloud Stream に基づくメッセージ駆動型アプリケーションを開発する方法を紹介します。

まず、メッセージ ブローカーを準備する必要があります。 Spring Cloud Stream は、Kafka、RabbitMQ などのさまざまなメッセージ ブローカーと統合できます。この記事では、RabbitMQ をメッセージ ブローカーとして使用します。

1. 開発環境を構築する
   まず、Java 開発環境 (JDK) と IDE (IntelliJ IDEA や Eclipse など) をインストールする必要があります。次に、RabbitMQ をダウンロードしてインストールし、RabbitMQ が正常に実行できることを確認します。
2. Spring Boot プロジェクトを作成する
   IDE を使用して空の Spring Boot プロジェクトを作成し、次の依存関係を pom.xml ファイルに追加します。メッセージ プロデューサー
メッセージを送信するための MessageProducer という名前の Java クラスを作成します。次のコード例を使用します。

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-stream-rabbit</artifactId>
</dependency>

3. 上記のコードでは、@EnableBinding アノテーションを使用してメッセージ ブローカーへの接続を有効にし、@Autowired アノテーションを通じて Source を MessageProducer クラスにバインドします。 sendMessage メソッドはメッセージの送信に使用されます。
   

メッセージ コンシューマーの作成

メッセージを受信するための MessageConsumer という名前の Java クラスを作成します。次のコード例を使用します。

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.messaging.Source;
import org.springframework.integration.support.MessageBuilder;

@EnableBinding(Source.class)
public class MessageProducer {

    @Autowired
    private Source source;

    public void sendMessage(String message) {
        source.output().send(MessageBuilder.withPayload(message).build());
    }
}

4. 上記のコードでは、@EnableBinding アノテーションを使用してメッセージ ブローカーへの接続を有効にし、@StreamListener アノテーションを使用してメッセージをリッスンします。 handleMessage メソッドは、受信したメッセージを処理するために使用されます。
   

アプリケーションの構成

application.yml という名前の構成ファイルを src/main/resources ディレクトリに作成し、次の内容を追加します。

import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.annotation.StreamListener;
import org.springframework.cloud.stream.messaging.Sink;

@EnableBinding(Sink.class)
public class MessageConsumer {

    @StreamListener(Sink.INPUT)
    public void handleMessage(String message) {
        System.out.println("Received message: " + message);
    }
}

5. 上記の構成メッセージの入出力先が my-topic であることを指定します。実際の条件に応じてこれらの構成を変更できます。
   

テスト コードを作成する

アプリケーションをテストするための MessageApplication という名前の Java クラスを作成します。次のコード例を使用します。

spring:
  cloud:
    stream:
      bindings:
        output:
          destination: my-topic
        input:
          destination: my-topic

6. 上記のコードでは、SpringApplication.run メソッドを使用してアプリケーションを起動し、context.getBean メソッドを通じて MessageProducer インスタンスを取得してから、sendMessage メソッドを呼び出します。メッセージを送信します。
   

アプリケーションの実行

MessageApplication クラスを実行し、コンソール出力を確認します。 「受信メッセージ: Hello, World!」のようなメッセージが表示されるはずです。

7. これまでのところ、Spring Cloud Stream に基づくメッセージ駆動型アプリケーションの開発に成功しています。メッセージパーティショニング、プロセッサチェーンなど、Spring Cloud Stream の強力な機能をさらに詳しく調べることができます。
   
概要

この記事では、Java を使用して Spring Cloud Stream に基づくメッセージ駆動型アプリケーションを開発する方法を紹介します。上記の手順を通じて、簡単なメッセージ プロデューサとコンシューマをすばやく構築し、メッセージ ブローカーと対話することができます。この記事が Spring Cloud Stream のメッセージ駆動モデルの理解と適用に役立つことを願っています。

以上がJava を使用して Spring Cloud Stream に基づくメッセージ駆動型アプリケーションを開発する方法の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。