ApsaraMQ for RocketMQ:ステップ 3: SDK を使用してメッセージを送受信する

Java 依存関係ライブラリをインストールする

1. IntelliJ IDEA で Java プロジェクトを作成します。

2. pom.xml ファイルに次の依存関係を追加して、Java 依存関係ライブラリをインポートします。

   <dependency>
       <groupId>org.apache.rocketmq</groupId>
       <artifactId>rocketmq-client-java</artifactId>
       <version>5.0.7</version>
   </dependency>

メッセージを生成する

作成した Java プロジェクトで、通常のメッセージを送信するプログラムを作成し、実行します。サンプルコード:

import org.apache.rocketmq.client.apis.*;
import org.apache.rocketmq.client.apis.message.Message;
import org.apache.rocketmq.client.apis.producer.Producer;
import org.apache.rocketmq.client.apis.producer.SendReceipt;

public class ProducerExample {
    public static void main(String[] args) throws ClientException {
        /**
         * インスタンスのエンドポイント。エンドポイントは、ApsaraMQ for RocketMQ コンソールの [インスタンスの詳細] ページの [エンドポイント] タブで確認できます。
         * ApsaraMQ for RocketMQ インスタンスのクライアントが Elastic Compute Service (ECS) インスタンスにデプロイされていて、内部ネットワークの ApsaraMQ for RocketMQ インスタンスにアクセスする場合、VPC エンドポイントを指定することをお勧めします。
         * インターネットまたはデータセンターからインスタンスにアクセスする場合は、パブリックエンドポイントを指定できます。インターネット経由でインスタンスにアクセスする場合は、インスタンスのインターネットアクセス機能を有効にする必要があります。
         */
        String endpoints = "rmq-cn-xxx.{regionId}.rmq.aliyuncs.com:8080";
        // メッセージの送信先のトピックの名前。メッセージを受信するためにトピックを使用する前に、ApsaraMQ for RocketMQ コンソールでトピックを作成する必要があります。そうしないと、エラーが返されます。
        String topic = "Your Topic";
        ClientServiceProvider provider = ClientServiceProvider.loadService();
        ClientConfiguration clientConfiguration = ClientConfiguration.newBuilder()
                .setEndpoints(endpoints)
                /**
                 * ApsaraMQ for RocketMQ インスタンスがサーバーレスインスタンスで、パブリックエンドポイントを使用してインスタンスにアクセスする場合は、インスタンス ID を指定する必要があります。
                 */
                //.setNamespace("InstanceId")
                /**
                 * パブリックエンドポイントを使用して ApsaraMQ for RocketMQ インスタンスにアクセスする場合は、インスタンスのユーザー名とパスワードを指定する必要があります。ユーザー名とパスワードは、ApsaraMQ for RocketMQ コンソールのインスタンスに対応する [アクセス制御] ページの [インテリジェント認証] タブで取得できます。
         * ApsaraMQ for RocketMQ インスタンスのクライアントが ECS インスタンスにデプロイされていて、内部ネットワークの ApsaraMQ for RocketMQ インスタンスにアクセスする場合、ユーザー名またはパスワードを指定する必要はありません。ブローカーは、VPC 情報に基づいてユーザー名とパスワードを自動的に取得します。
         * インスタンスがサーバーレス ApsaraMQ for RocketMQ インスタンスの場合、インターネット経由でインスタンスにアクセスするには、ユーザー名とパスワードを指定する必要があります。サーバーレスインスタンスの VPC で認証なし機能を有効にして、VPC 内のインスタンスにアクセスする場合、ユーザー名またはパスワードを指定する必要はありません。
                 */
                //.setCredentialProvider(new StaticSessionCredentialsProvider("Instance UserName", "Instance Password"))
                .build();
        /**
         * プロデューサーを初期化するときに、使用するトピックを指定して、トピック設定が有効かどうかを確認し、無効なトピックが開始されないようにすることができます。
         * 非トランザクションメッセージのトピックを指定する必要はありません。ブローカーは、トピックが有効かどうかを動的にチェックします。
         * 注: 呼び出される API 操作でトランザクションメッセージのクエリが失敗しないようにするには、トランザクションメッセージのトピックを事前に指定する必要があります。
         */
        Producer producer = provider.newProducerBuilder()
                .setTopics(topic)
                .setClientConfiguration(clientConfiguration)
                .build();
        // 通常のメッセージを送信します。
        Message message = provider.newMessageBuilder()
                .setTopic(topic)
                // メッセージキー。キーを使用してメッセージを検索できます。
                .setKeys("messageKey")
                // メッセージタグ。コンシューマーはタグを使用してメッセージをフィルタリングできます。
                .setTag("messageTag")
                // メッセージ本文。
                .setBody("messageBody".getBytes())
                .build();
        try {
            // メッセージを送信します。結果をメモし、失敗などの例外をキャッチします。
            SendReceipt sendReceipt = producer.send(message);
            System.out.println(sendReceipt.getMessageId());
        } catch (ClientException e) {
            e.printStackTrace();
        }
    }
}

メッセージを使用する

インターネット経由でサーバーレスインスタンスにアクセスするためのバージョン説明

特定のバージョンの SDK のみ、インターネット経由でサーバーレス ApsaraMQ for RocketMQ インスタンスにアクセスできます。

SDK パラメーター

メッセージの使用状況を確認する

メッセージを使用した後、ApsaraMQ for RocketMQ コンソールでメッセージの使用状況を確認できます。

1. ApsaraMQ for RocketMQ コンソール にログインします。インスタンス数 ページで、管理するインスタンスの名前をクリックします。

2. 表示されるページの左側のナビゲーションウィンドウで、メッセージトレース をクリックします。

SDK リファレンス

他のプログラミング言語用 SDK を使用して他の種類のメッセージを送受信する方法については、「概要」をご参照ください。