ApsaraMQ for RocketMQ：步驟三：調用SDK收發訊息

安裝Java依賴庫

1. 在IDEA中建立一個Java工程。

2. 在pom.xml檔案中添加以下依賴引入Java依賴庫。

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

   重要

   如果您使用的執行個體類型為Serverless，在公網訪問的時候需要注意SDK的版本等資訊，詳情請參見Serverless版執行個體公網訪問版本說明。

生產訊息

在已建立的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 {
        /**
         * 執行個體存取點，從控制台執行個體詳情頁的存取點頁簽中擷取。
         * 如果是在阿里雲ECS內網訪問，建議填寫VPC存取點。
         * 如果是在本地公網訪問，或者是線下IDC環境訪問，可以使用公網存取點。使用公網存取點訪問，必須開啟執行個體的公網訪問功能。
         */
        String endpoints = "rmq-cn-xxx.{regionId}.rmq.aliyuncs.com:8080";
        //訊息發送的目標Topic名稱，需要提前在控制台建立，如果不建立直接使用會返回報錯。
        String topic = "Your Topic";
        ClientServiceProvider provider = ClientServiceProvider.loadService();
        ClientConfigurationBuilder builder = ClientConfiguration.newBuilder().setEndpoints(endpoints);
        /**
         * 如果是使用公網存取點訪問，configuration還需要設定執行個體的使用者名稱和密碼。使用者名稱和密碼在控制台存取控制的智能身份識別頁簽中擷取。
         * 如果是在阿里雲ECS內網訪問，無需填寫該配置，服務端會根據內網VPC資訊智能擷取。
         * 如果執行個體類型為Serverless執行個體，公網訪問必須設定執行個體的使用者名稱密碼，當開啟內網免身份識別時,內網訪問可以不設定使用者名稱和密碼。
         */
        //builder.setCredentialProvider(new StaticSessionCredentialsProvider("Instance UserName", "Instance Password"));
        ClientConfiguration configuration = builder.build();
        /**
         * 初始化Producer時直接配置需要使用的Topic列表（這個參數可以配置多個Topic），實現提前檢查錯誤配置、攔截非法配置啟動。
         * 針對非事務訊息 Topic，也可以不配置，服務端會動態檢查訊息的Topic是否合法。
         * 注意！！！事務訊息Topic必須提前配置，以免事務訊息回查介面失敗，具體原理請參見事務訊息。
         */
        Producer producer = provider.newProducerBuilder()
                .setTopics(topic)
                .setClientConfiguration(configuration)
                .build();
        //普通訊息發送。
        Message message = provider.newMessageBuilder()
                .setTopic(topic)
                //設定訊息索引鍵，可根據關鍵字精確尋找某條訊息。
                .setKeys("messageKey")
                //設定訊息Tag，用於消費端根據指定Tag過濾訊息。
                .setTag("messageTag")
                //訊息體。
                .setBody("messageBody".getBytes())
                .build();
        try {
            //發送訊息，需要關注發送結果，並捕獲失敗等異常。
            SendReceipt sendReceipt = producer.send(message);
            System.out.println(sendReceipt.getMessageId());
        } catch (ClientException e) {
            e.printStackTrace();
        }
    }
}

消費訊息

Serverless版執行個體公網訪問版本說明

Serverless版執行個體的公網訪問功能，僅部分版本的SDK用戶端支援，具體限制如下：

SDK參數填寫說明

驗證訊息

訊息收發完成後，您可以通過控制台查看訊息消費情況。

1. 登入控制台，在執行個體列表頁面單擊目標執行個體名稱。

2. 在左側導覽列單擊訊息軌跡。

SDK參考

本文以Java SDK為例介紹收發普通訊息流程程，其他語言SDK和其他類型訊息的範例程式碼，請參見SDK參考概述。