ApsaraMQ for RocketMQ：Spring整合

環境準備

• 安裝1.8或以上版本JDK
• 安裝2.5或以上版本Maven
• 安裝IDEA

步驟一：下載Demo工程

雲訊息佇列 RocketMQ 版提供SpringBoot和Spring兩種方式的Demo，本文以SpringBoot的工程為例為您介紹如何使用SDK收發訊息，Spring方式的Demo工程使用步驟和SpringBoot類似。

• springboot/java-springboot-demo
• spring/java-spring-demo

步驟二：建立資源

您需要先到雲訊息佇列 RocketMQ 版控制台建立所需資源。

• 建立雲訊息佇列 RocketMQ 版執行個體
• 建立Topic

  建立Topic時，Topic的訊息類型必須和發送的訊息類型一致，不能混用。例如您發送普通訊息，則需要建立普通訊息類型的Topic，發送順序訊息時，則建立順序訊息類型的Topic。

• 建立Group ID

  Group的協議類型需要和SDK的協議類型一致，雲訊息佇列 RocketMQ 版提供的Spring架構的Java SDK為TCP協議，因此您在建立Group ID時需要選擇TCP協議。

• 擷取執行個體的TCP協議存取點

  雲訊息佇列 RocketMQ 版提供的Spring架構的Java SDK為TCP協議，因此您需要擷取TCP協議的存取點。

• 建立AccessKey

步驟三：Demo工程配置

在IDEA中建立Java工程並匯入步驟一：下載Demo工程中擷取的Demo檔案，然後配置以下內容。

修改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>

參數配置

根據步驟二：建立資源中的資源資訊，修改java-springboot-demo/src/main/resources路徑下的application.properties設定檔。

步驟四：以Main方式運行Demo

運行範例程式碼時，請確保java-springboot-demo/src/main/java/com/aliyun/openservices/springboot/example路徑下的類已匯入到工程中。