ApsaraMQ for RocketMQ:スプリングとの統合

準備

• JDK 1.8以降がインストールされます。 詳細については、「Javaダウンロード」をご参照ください。

• Maven 2.5以降がインストールされています。 詳細については、「Apache Mavenのダウンロード」をご参照ください。

• IntelliJ IDEAがインストールされています。 IntelliJ IDEAをダウンロードするには、ダウンロードページをご覧ください。

ステップ1: デモプロジェクトをダウンロードする

ApsaraMQ for RocketMQには、Spring BootとSpringの2つのデモがあります。 このトピックでは、例としてSpringBootのデモを使用します。 Springのデモを使用する操作も同様です。

• springboot/java-springboot-demo

• spring/java-spring-demo

ステップ2: リソースの作成

ApsaraMQ for RocketMQコンソールで必要なリソースを作成します。 以下の項目は、対応するセクションへのリンクを提供します。

• インスタンスの作成

• トピックの作成

  トピックを作成する場合、トピックのメッセージタイプは、送信するメッセージのタイプと同じである必要があります。 たとえば、通常のメッセージを送信する場合は、通常のメッセージタイプのトピックを作成する必要があります。 順序付きメッセージを送信する場合は、順序付きメッセージタイプのトピックを作成する必要があります。

• グループの作成

  グループのプロトコルタイプは、SDKのプロトコルタイプと同じである必要があります。 Sping統合ApsaraMQ for RocketMQ Java SDKはTCPプロトコルを使用します。 したがって、グループIDを作成するときは、TCPプロトコルを選択する必要があります。

• エンドポイントの取得

  Spring統合ApsaraMQ for RocketMQ Java SDKはTCPプロトコルを使用します。 したがって、TCPエンドポイントを取得する必要があります。

• AccessKeyペアの作成

手順3: デモプロジェクトの設定

IntelliJ IDEAでJavaプロジェクトを作成し、手順1: デモプロジェクトのダウンロードで取得したデモファイルをインポートして、次の操作を実行します。

pom.xmlファイルの変更

次のコードスニペットは、pom.xmlファイルに追加される依存関係を示しています。 ons-clientのバージョンを最新バージョンに変更することを推奨します。 バージョンの詳細については、「リリースノート」をご参照ください。

<dependencies>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

        <dependency>
            <groupId>com.aliyun.openservices</groupId>
            <artifactId>ons-client</artifactId>
            <version>1.8.8.8.Final</version>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
    </dependencies>

パラメーターの設定

手順2: リソースの作成のリソース情報に基づいて、java-springboot-demo/src/main/resourcesパスのapplication.propertiesファイルを変更します。

ステップ4: main() メソッドを呼び出してデモプロジェクトを実行する

サンプルコードを実行するときは、java-springboot-demo/src/main/java/com/aliyun/openservices/springboot/exampleパスのクラスがプロジェクトにインポートされていることを確認してください。