消息中間件RabbitMQ淺入

1 RabbitMQ簡介

1.1消息隊列中間件簡介

消息隊列中間件是分布式系統中重要的元件，主要解決應用耦合，異步消息，流量削鋒等問題實作高性能，高可用，可伸縮和最終一緻性[架構] 使用較多的消息隊列有ActiveMQ，RabbitMQ，ZeroMQ，Kafka，MetaMQ，RocketMQ以下介紹消息隊列在實際應用中常用的使用場景：異步處理，應用解耦，流量削鋒和消息通訊四個場景。

1.2什麼是RabbitMQ

RabbitMQ 是一個由 Erlang 語言開發的 AMQP 的開源實作。

AMQP ：Advanced Message Queue，進階消息隊列協定。它是應用層協定的一個開放标準，為面向消息的中間件設計，基于此協定的用戶端與消息中間件可傳遞消息，并不受産品、開發語言等條件的限制。RabbitMQ 最初起源于金融系統，用于在分布式系統中存儲轉發消息，在易用性、擴充性、高可用性等方面表現不俗。具體特點包括：

1.可靠性（Reliability）

RabbitMQ 使用一些機制來保證可靠性，如持久化、傳輸确認、釋出确認。

2.靈活的路由（Flexible Routing）

在消息進入隊列之前，通過 Exchange 來路由消息的。對于典型的路由功能，RabbitMQ已經提供了一些内置的 Exchange 來實作。針對更複雜的路由功能，可以将多個Exchange 綁定在一起，也通過插件機制實作自己的 Exchange 。

3.消息叢集（Clustering）

多個 RabbitMQ 伺服器可以組成一個叢集，形成一個邏輯 Broker 。

4.高可用（Highly Available Queues）

隊列可以在叢集中的機器上進行鏡像，使得在部分節點出問題的情況下隊列仍然可用。

5.多種協定（Multi-protocol）

RabbitMQ 支援多種消息隊列協定，比如 STOMP、MQTT 等等。

6.多語言用戶端（Many Clients）

RabbitMQ 幾乎支援所有常用語言，比如 Java、.NET、Ruby 等等。

7.管理界面（Management UI）

RabbitMQ 提供了一個易用的使用者界面，使得使用者可以監控和管理消息 Broker 的許多方面。

8.跟蹤機制（Tracing）

如果消息異常，RabbitMQ 提供了消息跟蹤機制，使用者可以找出發生了什麼。

9.插件機制（Plugin System）

RabbitMQ 提供了許多插件，來從多方面進行擴充，也可以編寫自己的插件。

1.3架構圖與主要概念

1.3.1架構圖

1.3.2主要概念

RabbitMQ Server： 也叫broker server，它是一種傳輸服務。 他的角色就是維護一條從Producer到Consumer的路線，保證資料能夠按照指定的方式進行傳輸。

Producer： 消息生産者，如圖A、B、C，資料的發送方。消息生産者連接配接RabbitMQ伺服器然後将消息投遞到Exchange。

Consumer：消息消費者，如圖1、2、3，資料的接收方。消息消費者訂閱隊列，RabbitMQ将Queue中的消息發送到消息消費者。

Exchange：生産者将消息發送到Exchange（交換器），由Exchange将消息路由到一個或多個Queue中（或者丢棄），Exchange并不存儲消息。RabbitMQ中的Exchange有direct、fanout、topic、headers四種類型，每種類型對應不同的路由規則。

Queue：（隊列）是RabbitMQ的内部對象，用于存儲消息。消息消費者就是通過訂閱隊列來擷取消息的，RabbitMQ中的消息都隻能存儲在Queue中，生産者生産消息并最終投遞到Queue中，消費者可以從Queue中擷取消息并消費。多個消費者可以訂閱同一個Queue，這時Queue中的消息會被平均分攤給多個消費者進行處理，而不是每個消費者都收到所有的消息并處理。

RoutingKey：生産者在将消息發送給Exchange的時候，一般會指定一個routing key，來指定這個消息的路由規則，而這個routing key需要與Exchange Type及binding key聯合使用才能最終生效。在Exchange Type與binding key固定的情況下（在正常使用時一般這些内容都是固定配置好的），我們的生産者就可以在發送消息給Exchange時，通過指定routing key來決定消息流向哪裡。RabbitMQ為routing key設定的長度限制為255bytes。

Connection： （連接配接）：Producer和Consumer都是通過TCP連接配接到RabbitMQ Server的。以後我們可以看到，程式的起始處就是建立這個TCP連接配接。

Channels： （信道）：它建立在上述的TCP連接配接中。資料流動都是在Channel中進行的。也就是說，一般情況是程式起始建立TCP連接配接，第二步就是建立這個Channel。

VirtualHost：權限控制的基本機關，一個VirtualHost裡面有若幹Exchange和MessageQueue，以及指定被哪些user使用

2 走進RabbitMQ

2.1 RabbitMQ安裝與啟動

2.1.1 windows環境下的安裝

（1）下載下傳并安裝 Eralng  :  otp_win64_20.2.exe （以管理者身份運作安裝）

（2）下載下傳并安裝rabbitmq：下載下傳 rabbitmq-server-3.7.4.exe。輕按兩下安裝，注意不要安裝在包含中文空格的目錄下！安裝後window服務中就存在rabbitMQ了，并且是啟動狀态。

（3）安裝管理界面（插件）：進入rabbitMQ安裝目錄的sbin目錄，輸入指令rabbitmq‐plugins enable rabbitmq_management。

（4）重新啟動服務:在window服務中找到RabbitMQ,重新啟動即可

（5）打開浏覽器，位址欄輸入http://127.0.0.1:15672 ,即可看到管理界面的登陸頁

輸入使用者名和密碼，都為guest 進入主界面：

最上側的導航以此是：概覽、連接配接、信道、交換器、隊列、使用者管理

2.1.2 docker環境下的安裝

（1）下載下傳鏡像：docker pull rabbitmq:management

（2）建立容器，rabbitmq需要有映射以下端口: 5671 5672 4369 15671 15672 25672

• 15672 (if management plugin is enabled)
• 15671 management監聽端口
• 5672, 5671 (AMQP 0-9-1 without and with TLS)
• 4369 (epmd) epmd 代表 Erlang 端口映射守護程序
• 25672 (Erlang distribution)

docker run -di --name=tensquare_rabbitmq -p 5671:5617 -p 5672:5672 -p 4369:4369 -p 15671:15671 -p 15672:15672 -p 25672:25672 rabbitmq:management
           

浏覽器通路:  http://192.168.92.132:15672/#/

2.2 直接模式（Direct）

2.2.1 什麼是Direct模式

我們需要将消息發給唯一一個節點時使用這種模式，這是最簡單的一種形式。

任何發送到Direct Exchange的消息都會被轉發到RouteKey中指定的Queue。

1.一般情況可以使用rabbitMQ自帶的Exchange：”"(該Exchange的名字為空字元串，下文稱其為default Exchange)。

2.這種模式下不需要将Exchange進行任何綁定(binding)操作

3.消息傳遞時需要一個“RouteKey”，可以簡單的了解為要發送到的隊列名字。

4.如果vhost中不存在RouteKey中指定的隊列名，則該消息會被抛棄

2.2.2 建立隊列

我們先建立一個叫csii的隊列

 Durability：是否做持久化 Durable（持久） transient（臨時）

Auto delete : 是否自動删除

2.2.3 代碼實作-消息生産者

（1）建立工程rabbitmq_demo，引入amqp起步依賴 ，pom.xml如下:

<!--引入springboot起步依賴-->
<parent>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>2.0.1.RELEASE</version>
    <relativePath/>
</parent>
<properties>
    <project.build.sourceEncoding>UTF‐8</project.build.sourceEncoding>
    <project.reporting.outputEncoding>UTF‐8</project.reporting.outputEncoding>
    <java.version>1.8</java.version>
</properties>
<dependencies>
    <!--amqp起步依賴-->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-amqp</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-test</artifactId>
        <scope>test</scope>
    </dependency>
</dependencies>
           

（2）編寫配置檔案application.yml

server:
  port: 8082
spring:
  rabbitmq:
    host: 192.168.92.132
           

(3）編寫啟動類

@SpringBootApplication
public class RabbitApplication {
    public static void main(String[] args) {
        SpringApplication.run(RabbitApplication.class);
    }
}
           

（4）編寫測試類 （生産者）

@RunWith(SpringRunner.class)
@SpringBootTest(classes= RabbitApplication.class)
public class ProductDemo {
    @Autowired
    private RabbitTemplate rabbitTemplate;

    @Test
    public void send(){
        rabbitTemplate.convertAndSend("csii","hello everyone,this is rabbitmq");
    }
}
           

2.2.4 代碼實作-消息消費者

（1）編寫消息消費者類

@Component
@RabbitListener(queues="csii")
public class Customer1 {

    @RabbitHandler
    public void showMessage(String message){
        System.out.println("消費者收到的消息是:"+message);
    }
}
           

2.2.5 測試

開啟多個消費者工程，測試運作消息生産者工程，會發現隻有一個消費者工程可以接收到消息。如何在IDEA中多次啟動同一個程式呢？

（1）選擇IDEA右上角的類名稱按鈕，然後選擇Edit Configurations

（2）在彈出視窗中勾選平行模式 ，點選OK

（3）每次運作前修改application.yml，指定不同的端口

server:
  port: 8084
           

運作後在控制台可以看到多個視窗 

當多次運作生産者程式時，這多個消費者會依次收到消息（負載均衡政策）

 2.3 分列模式（Fanout）

2.3.1 什麼是分列（Fanout）模式

當我們需要将消息一次發給多個隊列時，需要使用這種模式。如下圖：

任何發送到Fanout Exchange的消息都會被轉發到與該Exchange綁定(Binding)的所有Queue上。

1.可以了解為路由表的模式

2.這種模式不需要RouteKey

3.這種模式需要提前将Exchange與Queue進行綁定，一個Exchange可以綁定多個Queue，一個Queue可以同多個Exchange進行綁定。

4.如果接受到消息的Exchange沒有與任何Queue綁定，則消息會被抛棄。

2.3.2 交換器綁定隊列

（1）在queue中添加隊列kelanxueyuan和vpsystem

（2）建立交換器kelan

（3）将kelanxueyuan、csii和vpsystem三個隊列綁定到交換器kelan，如下所示：

綁定後效果如下：

2.3.3 代碼實作-消息生産者

/**
 * 分裂模式
 */
@Test
public void sendFanout(){
	rabbitTemplate.convertAndSend("kelan","","分列模式的消息");

}
           

2.3.4 代碼實作-消息消費者

建立消息監聽類，用于監聽kelan的消息

@Component
@RabbitListener(queues = "vpsystem")
public class Customer2 {

    @RabbitHandler
    public void showMessage(String message){
        System.out.println("vpsystem收到的消息:"+message);
    }
}

@Component
@RabbitListener(queues = "kelanxueyuan")
public class Customer3 {

    @RabbitHandler
    public void showMessage(String message){
        System.out.println("kelanxueyuan收到的消息:"+message);
    }
}
@Component
@RabbitListener(queues="csii")
public class Customer1 {

    @RabbitHandler
    public void showMessage(String message){
        System.out.println("csii收到的消息:"+message);
    }
}
           

2.3.5 測試

啟動消費者工程，發送消息測試

exchange會将消息轉發給隊列上的三個消費者 

2.4 主題模式（Topic）

2.4.1 什麼是主題模式

任何發送到Topic Exchange的消息都會被轉發到所有關聯RouteKey中指定話題的Queue上

如上圖所示，此類交換器使得來自不同的源頭的消息可以到達一個對列，其實說的更明白一點就是模糊比對的意思，例如：上圖中紅色對列的routekey為usa.#，#代表比對任意字元，但是要想消息能到達此對列，usa.必須比對後面的#好可以随意。圖中usa.news、usa.weather,都能找到紅色隊列，符号 # 比對一個或多個詞，符号 * 比對不多不少一個詞。是以 usa.# 能夠比對到 usa.news.XXX ，但是 usa.* 隻會比對到 usa.XXX 。注：交換器說到底是一個名稱與隊列綁定的清單。當消息釋出到交換器時，實際上是由你所連接配接的信道，将消息路由鍵同交換器上綁定的清單進行比較，最後路由消息。

任何發送到Topic Exchange的消息都會被轉發到所有關聯RouteKey中指定話題的Queue上

1.這種模式較為複雜，簡單來說，就是每個隊列都有其關心的主題，所有的消息都帶有一個“标題”(RouteKey)，Exchange會将消息轉發到所有關注主題能與RouteKey模糊比對的隊列。

2.這種模式需要RouteKey，也許要提前綁定Exchange與Queue。

3.在進行綁定時，要提供一個該隊列關心的主題，如“#.log.#”表示該隊列關心所有涉及log的消息(一個RouteKey為”MQ.log.error”的消息會被轉發到該隊列)。

4.“#”表示0個或若幹個關鍵字，“*”表示一個關鍵字。如“log.*”能與“log.warn”比對，無法與“log.warn.timeout”比對；但是“log.#”能與上述兩者比對。

5.同樣，如果Exchange沒有發現能夠與RouteKey比對的Queue，則會抛棄此消息

2.4.2 建立隊列與綁定

（1）建立一個交換器 ，類型選擇topic

（2）點選建立的交換器topictest

添加比對規則，添加後清單如下：

2.4.3 代碼實作

編寫測試類方法：

@Test
public void sendTopic(){
	rabbitTemplate.convertAndSend("topictest","demo.log","主題模式的消息");
}
           

由于demo.log比對到了#.log， 輸出結果

編寫測試類方法：

@Test
public void sendTopic1(){
	rabbitTemplate.convertAndSend("toptest","goods.test.new","主題模式的消息");

}
           

由于goods.test.new比對到了goods.#， 輸出結果

 編寫測試類方法：

@Test
public void sendTopic2(){
	rabbitTemplate.convertAndSend("topictest","goods.log","主題模式");
}
           

由于goods.log比對到了goods.#,goods.log,#.log 輸出結果

3 使用者微服務-使用者注冊

3.1 需求分析

新增賬號，用手機号注冊，填寫後發送短信驗證碼，填寫短信驗證碼正确方可注冊成功。發起短信這個動作是發送到rabbitmq隊列中，也就是消息生産者，然後建立微服務監控這個隊列作為消費者，向使用者發出短信，達到異步處理的效果。

3.2 發送短信驗證碼

實作思路： 在使用者微服務編寫API ,生成手機驗證碼，存入Redis并發送到RabbitMQ

3.2.1 準備工作

（1）因為要用到緩存和消息隊列，是以在使用者微服務（tensquare_user）引入依賴redis和amqp的起步依賴。

<!--生成随機數的包-->
<dependency>
    <groupId>org.apache.commons</groupId>
    <artifactId>commons-lang3</artifactId>
</dependency>
<!--引入redis依賴-->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
<!--引入rabbitmq依賴-->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-amqp</artifactId>
</dependency>
           

（2）修改application.yml ,在spring 節點下添加配置

redis:
  host: 192.168.92.132
  port: 6379
rabbitmq:
  host: 192.168.92.132
           

3.2.2 代碼實作

（1）在UserService中新增方法，用于發送短信驗證碼

@Autowired
private RedisTemplate redisTemplate;

@Autowired
private RabbitTemplate rabbitTemplate;

/**
 * 發送短信
 */
public void sendSms(String mobile){
    //生産随機碼，随機6位資料
    String code = RandomStringUtils.randomNumeric(6);
    //存入到緩存中,5分鐘有效
    redisTemplate.opsForValue().set("tensquare_code"+mobile,code,5, TimeUnit.MINUTES);
    //發送消息到隊列,發送一個map
    HashMap map=new HashMap();
    map.put("code",code);
    map.put("mobile",mobile);
    //将手機号和驗證碼發送到rabbitmq上 直接模式
    rabbitTemplate.convertAndSend("tensquare_code",map);
}
           

（2）UserController新增方法

/**
 * 發送短信
 */
@PostMapping("/sendsms/{mobile}")
public  Result sendSms(@PathVariable String mobile){
    userService.sendSms(mobile);
    return new Result(StatusCode.SUCCESS,true,"發送成功");
}
           

（3） 在rabbitMQ中建立名為tensquare_code的隊列，啟動微服務

3.3 使用者注冊

（1）UserService增加方法

public void add(User user,String code) {
    if(redisTemplate.opsForValue().get("tensquare_code"+user.getMobile())==null||
    "".equals(redisTemplate.opsForValue().get("tensquare_code"+user.getMobile()))){
        throw new RuntimeException("請先填寫驗證碼");
    }
    if(!redisTemplate.opsForValue().get("tensquare_code"+user.getMobile()).equals(code)){
        throw new RuntimeException("請填寫正确的驗證碼");
    }
    user.setId( idWorker.nextId()+"" );
    user.setFollowcount(0);//關注數
    user.setFanscount(0);//粉絲數
    user.setOnline(0L);//線上時長
    user.setRegdate(new Date());//注冊日期
    user.setUpdatedate(new Date());//更新日期
    user.setLastdate(new Date());//最後登陸日期
    userDao.save(user);
}
           

（2）UserController增加方法

/**
 * 注冊功能
 */
@PostMapping("/register/{code}")
public Result register(@PathVariable String code,@RequestBody User user){
    userService.add(user,code);
    return new Result(StatusCode.SUCCESS,true,"注冊成功");
}
           

4 短信微服務

4.1 需求分析

開發短信發送微服務，從rabbitMQ中提取消息，調用阿裡雲短信接口實作短信發送 ，我們這裡實際做的就是消息的消費者。

4.2 提取隊列中的消息

4.2.1 工程搭建

（1）建立工程子產品：tensquare_sms，pom.xml引入依賴

<!--引入rabbitmq依賴-->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-amqp</artifactId>
</dependency>
           

（2）建立application.yml

server:
  port: 9009
spring:
  rabbitmq:
    host: 192.168.92.132
           

（3）com.tensquare.sms 包下建立啟動類

@SpringBootApplication
public class SmsApplication {
    public static void main(String[] args) {
        SpringApplication.run(SmsApplication.class);
    }
}
           

4.2.2 消息監聽類（測試）

（1）建立短信監聽類，擷取手機号和驗證碼

/**
* 短信監聽類
*/
@Component
@RabbitListener(queues = "sms")
public class SmsListener {
    /**
    * 發送短信
    * @param message
    */
    @RabbitHandler
    public void sendSms(Map<String,String> message){
        System.out.println("手機号："+message.get("mobile"));
        System.out.println("驗證碼："+message.get("code"));
    }
}
           

（2）運作SmsApplication類，啟動發送短信微服務，再啟動消息監聽類，發送短信測試，控制台顯示手機号和驗證碼。

4.3 發送短信(阿裡雲短信)

4.3.1 阿裡雲通信簡介

阿裡雲短信是阿裡雲旗下産品，融合了三大營運商的通信能力，通過将傳統通信業務和能力與網際網路相結合，創新融合阿裡巴巴生态内容，全力為中小企業和開發者提供優質服務阿裡大于提供包括短信、語音、流量直充、私密專線、店鋪手機号等個性化服務。通過阿裡大于打通三大營運商通信能力，全面融合阿裡巴巴生态，以開放API 及 SDK 的方式向開發者提供通信和資料服務，更好地支撐企業業務發展和創新服務。

4.3.2 準備工作

（1）在阿裡雲官網 www.alidayu.com 新增賬號，實名認證

（3）登陸阿裡雲，産品中選擇“短信服務”，然後進入管理控制台

（4）申請簽名

添加簽名時測試用的話，不要選擇通用場景，選擇驗證碼場景就行了，申請時名字可以是什麼管理系統或者實際的産品名，不能包含自己的姓名或者一些敏感字，不然很難申請成功。

（5）申請模闆，這個取個英文名就行了

（6）建立 accessKey （注意保密！），這個很重要，其他阿裡雲功能也需要。

（7）充值 

 點選費用充值就行了

4.3.3 代碼編寫

（1）修改pom.xml檔案，添加依賴

<!--引入阿裡雲短信依賴-->
<dependency>
    <groupId>com.aliyun</groupId>
    <artifactId>aliyun-java-sdk-core</artifactId>
    <version>4.0.6</version> <!-- 注：如提示報錯，先更新基礎包版，無法解決可聯系技術支援 -->
</dependency>
<dependency>
    <groupId>com.aliyun</groupId>
    <artifactId>aliyun-java-sdk-dysmsapi</artifactId>
    <version>1.1.0</version>
</dependency>
           

（2）修改application.yml ，增加配置

aliyun:
  sms:
    accessKeyId: secret
    accessKeySecret: secret
    template_code: SMS_233619083
    sign_name: xx系統
           

（3）建立短信工具類SmsUtil

package com.tensquare.sms.utils;
import com.aliyuncs.DefaultAcsClient;
import com.aliyuncs.IAcsClient;
import com.aliyuncs.dysmsapi.model.v20170525.QuerySendDetailsRequest;
import com.aliyuncs.dysmsapi.model.v20170525.QuerySendDetailsResponse;
import com.aliyuncs.dysmsapi.model.v20170525.SendSmsRequest;
import com.aliyuncs.dysmsapi.model.v20170525.SendSmsResponse;
import com.aliyuncs.exceptions.ClientException;
import com.aliyuncs.profile.DefaultProfile;
import com.aliyuncs.profile.IClientProfile;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.core.env.Environment;
import org.springframework.stereotype.Component;

import java.text.SimpleDateFormat;
import java.util.Date;
/**
 * 短信工具類
 * @author Administrator
 *
 */
@Component
public class SmsUtil {

    //産品名稱:雲通信短信API産品,開發者無需替換
    static final String product = "Dysmsapi";
    //産品域名,開發者無需替換
    static final String domain = "dysmsapi.aliyuncs.com";

    //這個為springboot的配置對象
    @Autowired
    private Environment env;

    // TODO 此處需要替換成開發者自己的AK(在阿裡雲通路控制台尋找)

    /**
     * 發送短信
     * @param mobile 手機号
     * @param template_code 模闆号
     * @param sign_name 簽名
     * @param param 參數
     * @return
     * @throws ClientException
     */
    public SendSmsResponse sendSms(String mobile,String template_code,String sign_name,String param) throws ClientException {
        String accessKeyId =env.getProperty("aliyun.sms.accessKeyId");
        String accessKeySecret = env.getProperty("aliyun.sms.accessKeySecret");
        //可自助調整逾時時間
        System.setProperty("sun.net.client.defaultConnectTimeout", "10000");
        System.setProperty("sun.net.client.defaultReadTimeout", "10000");
        //初始化acsClient,暫不支援region化
        IClientProfile profile = DefaultProfile.getProfile("cn-hangzhou", accessKeyId, accessKeySecret);
        DefaultProfile.addEndpoint("cn-hangzhou", "cn-hangzhou", product, domain);
        IAcsClient acsClient = new DefaultAcsClient(profile);
        //組裝請求對象-具體描述見控制台-文檔部分内容
        SendSmsRequest request = new SendSmsRequest();
        //必填:待發送手機号
        request.setPhoneNumbers(mobile);
        //必填:短信簽名-可在短信控制台中找到
        request.setSignName(sign_name);
        //必填:短信模闆-可在短信控制台中找到
        request.setTemplateCode(template_code);
        request.setTemplateParam(param);
        //選填-上行短信擴充碼(無特殊需求使用者請忽略此字段)
        //request.setSmsUpExtendCode("90997");
        //可選:outId為提供給業務方擴充字段,最終在短信回執消息中将此值帶回給調用者
        request.setOutId("yourOutId");
        //hint 此處可能會抛出異常，注意catch
        SendSmsResponse sendSmsResponse = acsClient.getAcsResponse(request);
        return sendSmsResponse;
    }

    public  QuerySendDetailsResponse querySendDetails(String mobile,String bizId) throws ClientException {
        String accessKeyId =env.getProperty("accessKeyId");
        String accessKeySecret = env.getProperty("accessKeySecret");
        //可自助調整逾時時間
        System.setProperty("sun.net.client.defaultConnectTimeout", "10000");
        System.setProperty("sun.net.client.defaultReadTimeout", "10000");
        //初始化acsClient,暫不支援region化
        IClientProfile profile = DefaultProfile.getProfile("cn-hangzhou", accessKeyId, accessKeySecret);
        DefaultProfile.addEndpoint("cn-hangzhou", "cn-hangzhou", product, domain);
        IAcsClient acsClient = new DefaultAcsClient(profile);
        //組裝請求對象
        QuerySendDetailsRequest request = new QuerySendDetailsRequest();
        //必填-号碼
        request.setPhoneNumber(mobile);
        //可選-流水号
        request.setBizId(bizId);
        //必填-發送日期 支援30天内記錄查詢，格式yyyyMMdd
        SimpleDateFormat ft = new SimpleDateFormat("yyyyMMdd");
        request.setSendDate(ft.format(new Date()));
        //必填-頁大小
        request.setPageSize(10L);
        //必填-目前頁碼從1開始計數
        request.setCurrentPage(1L);
        //hint 此處可能會抛出異常，注意catch
        QuerySendDetailsResponse querySendDetailsResponse = acsClient.getAcsResponse(request);
        return querySendDetailsResponse;
    }
}
           

（4）修改消息監聽類，完成短信發送

@Component
@RabbitListener(queues = "tensquare_code")
public class SmsController {

    @Autowired
    private SmsUtil smsUtil;

    @Value("${aliyun.sms.template_code}")
    private String template_code;

    @Value("${aliyun.sms.sign_name}")
    private String sign_name;

    @RabbitHandler
    public void sendSms(HashMap data){
        System.out.println("收到的手機号碼為："+data.get("mobile"));
        System.out.println("收到的驗證碼為："+data.get("code"));
        System.out.println("收到的模闆為："+template_code);
        System.out.println("收到的簽名為："+sign_name);
        String code=(String) data.get("code");
        String mobile=(String) data.get("mobile");

        //可選:模闆中的變量替換JSON串,如模闆内容為"您的驗證碼為${code}"時,此處的值為
        try {
            SendSmsResponse sr = smsUtil.sendSms(mobile, template_code, sign_name, "{\"code\":\"" + code + "\"}");
            if("OK".equals(sr.getCode())){
                System.out.println("短信發送成功");
            }else {
                System.out.println("短信發送失敗，請排查");
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

}