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>

   重要

   serverless ApsaraMQ for RocketMQインスタンスを使用している場合は、インターネット経由でインスタンスにアクセスするときに、SDK for Javaのバージョンに注意してください。 インターネット経由でサーバーレスApsaraMQ for RocketMQインスタンスにアクセスできるのは、特定のバージョンのSDK for Javaのみです。 詳細については、「インターネット経由でサーバーレスインスタンスにアクセスするためのバージョンの説明」をご参照ください。

メッセージを生成する

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

package doc;

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 {
        /**
         * The endpoint of the instance. You can view the endpoint on the Endpoints tab of the Instance Details page in the ApsaraMQ for RocketMQ console. 
         * If the client of the ApsaraMQ for RocketMQ instance is deployed on an Elastic Compute Service (ECS) instance and you want to access the ApsaraMQ for RocketMQ instance in an internal network, we recommend that you specify the virtual private cloud (VPC) endpoint. 
         * If you access the instance over the Internet or from a data center, you can specify the public endpoint. If you access the instance over the Internet, you must enable the Internet access feature for the instance. 
         */
        String endpoints = "rmq-cn-xxx.{regionId}.rmq.aliyuncs.com:8080";
        // The name of the topic to which the message is sent. Before you use a topic to receive a message, you must create the topic in the ApsaraMQ for RocketMQ console. Otherwise, an error is returned. 
        String topic = "Your Topic";
        ClientServiceProvider provider = ClientServiceProvider.loadService();
        ClientConfigurationBuilder builder = ClientConfiguration.newBuilder().setEndpoints(endpoints);
        /**
         * If you access the instance by using the public endpoint, you must specify the username and password of the instance. You can obtain the username and password on the Intelligent Authentication tab of the Access Control page corresponding to the instance in the ApsaraMQ for RocketMQ console. 
         * If the client of the ApsaraMQ for RocketMQ instance is deployed on an ECS instance and you want to access the ApsaraMQ for RocketMQ instance in an internal network, you do not need to specify the username or password. The broker automatically obtains the username and password based on the VPC information. 
         * If the instance is a serverless ApsaraMQ for RocketMQ instance, you must specify the username and password to access the instance over the Internet. If you enable the authentication-free in VPCs feature for the serverless instance and access the instance in a VPC, you do not need to specify the username or password. 
         */
        //builder.setCredentialProvider(new StaticSessionCredentialsProvider("Instance UserName", "Instance Password"));
        ClientConfiguration configuration = builder.build();
        /**
         * When you initialize a producer, you can specify the topics that you want to use to check whether the topic settings are valid and prevent invalid topics from being started. 
         * You do not need to specify the topics for non-transactional messages. The broker dynamically checks whether the topics are valid. 
         * Note: To prevent the API operation that is called to query transactional messages from failing, you must specify topics for transactional messages in advance. 
         */
        Producer producer = provider.newProducerBuilder()
                .setTopics(topic)
                .setClientConfiguration(configuration)
                .build();
        // Send a normal message. 
        Message message = provider.newMessageBuilder()
                .setTopic(topic)
                // The message key. You can use a keyword to accurately find the message. 
                .setKeys("messageKey")
                // The message tag. The consumer can use the tag to filter messages. 
                .setTag("messageTag")
                // The message body. 
                .setBody("messageBody".getBytes())
                .build();
        try {
            // Send the message. Take note of the result and capture exceptions such as failures. 
            SendReceipt sendReceipt = producer.send(message);
            System.out.println(sendReceipt.getMessageId());
        } catch (ClientException e) {
            e.printStackTrace();
        }
    }
}

メッセージを消費する

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

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

SDKパラメーター

メッセージ消費の確認

メッセージを消費した後、ApsaraMQ for RocketMQコンソールでメッセージの消費ステータスを確認できます。

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

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

SDK参照

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