十次方項目第五天（消息中間件RabbitMQ）

學習目標：

1. 可以說出消息隊列的應用場景以及RabbitMQ的主要概念

2. 完成RabbitMQ安裝以及RabbitMQ三種模式的入門案例

3. 完成用戶註冊，可以將消息發送給RabbitMQ

4. 完成短信微服務，可以接收消息並調用阿里雲通訊完成短信發送

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：消息消費者，如圖一、二、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設定的長度限制爲255 bytes。

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）從新啓動服務 （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.184.134: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 建立隊列

作下面的例子前，咱們先創建一個叫itcast的隊列。

Durability：是否作持久化 Durable（持久） transient（臨時） Auto delete : 是否自動刪除

2.2.3 代碼實現-消息生產者

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

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

  spring:
    rabbitmq:
     host: 192.168.184.134

（3）編寫啓動類

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

（4）編寫測試類

  @RunWith(SpringRunner.class)
  @SpringBootTest(classes=Application.class)
 public class MqTest {
     @Autowired
     private RabbitTemplate rabbitTemplate;
     @Test
     public void testSend(){
         rabbitTemplate.convertAndSend("itcast","我要紅包");
     }
 }

運行測試方法 2.2.4 代碼實現-消息消費者 （1）編寫消息消費者類

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

（2）運行啓動類，能夠在控制檯看到剛纔發送的消息

2.2.5 測試

開啓多個消費者工程，測試運行消息生產者工程，會發現只有一個消費者工程能夠接收 到消息。 如何在IDEA中屢次啓動同一個程序呢？ （1）選擇IDEA右上角的類名稱按鈕

（2）選擇Edit Configurations

（3）在彈出窗口中取消單例模式 ，點擊OK

（4）每次運行前修改application.yml，指定不一樣的端口

server: port: 9202

運行後在控制檯能夠看到多個窗口

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中添加隊列itheima 和kudingyu （2）新建交換器chuanzhi

（3）將itcast 和itheima兩個隊列綁定到交換器chuanzhi

點擊chuanzhi進入交換器管理界面

點擊Bindings添加綁定 itheima和kudingyu

2.3.3 代碼實現-消息生產者

  @Test    
  public void testSendFanout(){    
 rabbitTemplate.convertAndSend("chuanzhi","", "分列模式走起");        
 } 

2.3.4 代碼實現-消息消費者 建立消息監聽類，用於監聽itheima的消息

  @Component
  @RabbitListener(queues="itheima" )
 public class Customer2 {
     @RabbitHandler
     public void showMessage(String message){
         System.out.println("itheima接收到消息："+message);
     }
 }

建立消息監聽類，用於監聽kudingyu的消息

  @Component
  @RabbitListener(queues="kudingyu" )
 public class Customer3 {
     @RabbitHandler
     public void showMessage(String message){
         System.out.println("kudingyu接收到消息："+message);
     }
 }

2.3.5 測試

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

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 testSendTopic1(){
         rabbitTemplate.convertAndSend("topictest","goods.aaa","主題模式");
     }

輸出結果：itcast接收到消息：主題模式

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

輸出結果：itheima接收到消息：主題模式

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

輸出結果：

itheima接收到消息：主題模式 itcast接收到消息：主題模式 kudingyu接收到消息：主題模式

3 用戶微服務-用戶註冊

3.1 需求分析

註冊帳號，用手機號註冊，填寫後發送短信驗證碼，填寫短信驗證碼正確方可註冊成 功。

咱們這裏所作的實際上就是消息生產者。

3.2 代碼生成

（1）使用代碼生成器生成用戶微服務代碼 tensquare_user （2）拷貝到當前工程，並在父工程引入。

（3）修改Application類名稱爲UserApplication （4）修改application.yml 中的端口爲9008 ,url 爲

jdbc:mysql://192.168.184.134:3306/tensquare_user?characterEncoding=UTF8

（5）進行瀏覽器測試

3.3 發送短信驗證碼

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

3.3.1 準備工做

（1）由於要用到緩存和消息隊列，因此在用戶微服務（tensquare_user）引入依賴 redis和amqp的起步依賴。

  <dependency>        
  <groupId>org.springframework.boot</groupId>            
 <artifactId>spring‐boot‐starter‐data‐redis</artifactId>            
 </dependency>        
 <dependency>          
 <groupId>org.springframework.boot</groupId>              
 <artifactId>spring‐boot‐starter‐amqp</artifactId>              
 </dependency>

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

redis: host: 192.168.184.134 rabbitmq: host: 192.168.184.134

3.3.2 代碼實現

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

  @Autowired    
  private RedisTemplate redisTemplate;    
 @Autowired    
 private RabbitTemplate rabbitTemplate;    
 /**    
 ​
 - 發送短信驗證碼    
 - @param mobile 手機號    
  */    
  public void sendSms(String mobile){    
  //1.生成6位短信驗證碼        
  Random random=new Random();        
  int max=999999;//最大數        
  int min=100000;//最小數        
  int code = random.nextInt(max);//隨機生成        
  if(code<min){        
  code=code+min;            
  }        
  System.out.println(mobile+"收到驗證碼是："+code);        
  //2.將驗證碼放入redis        
  redisTemplate.opsForValue().set("smscode_"+mobile, code+"" ,5,
  TimeUnit.MINUTES );//五分鐘過時
 ​
 //3.將驗證碼和手機號發動到rabbitMQ中        
 Map<String,String> map=new HashMap();        
 map.put("mobile",mobile);        
 map.put("code",code+"");        
 rabbitTemplate.convertAndSend("sms",map);        
 }

（2）UserController新增方法

  /**    
   * 發送短信驗證碼    
  * @param mobile    
  */    
 @RequestMapping(value="/sendsms/{mobile}",method=RequestMethod.POST)    
 public Result sendsms(@PathVariable String mobile ){    
 userService.sendSms(mobile);        
 return new Result(true,StatusCode.OK,"發送成功");        
 } 

（3）啓動微服務，在rabbitMQ中建立名爲sms的隊列，測試API

3.3 用戶註冊

（1）UserService增長方法

  /**    
   * 增長    
  * @param user 用戶    
  * @param code 用戶填寫的驗證碼    
  */    
 public void add(User user,String code) {    
 //判斷驗證碼是否正確        
 String syscode =
 (String)redisTemplate.opsForValue().get("smscode_" + user.getMobile());
 //提取系統正確的驗證碼
        
 if(syscode==null){        
 throw new RuntimeException("請點擊獲取短信驗證碼");            
 }        
 if(!syscode.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增長方法

  /**    
  * 用戶註冊    
  * @param user    
  */    
 @RequestMapping(value="/register/{code}",method=RequestMethod.POST)    
 public Result register( @RequestBody User user  ,@PathVariable String
 code){
    
 userService.add(user,code);        
 return new Result(true,StatusCode.OK,"註冊成功");        
 } 

4 短信微服務

4.1 需求分析

開發短信發送微服務，從rabbitMQ中提取消息，調用阿里大於短信接口實現短信發 送 。（關於短信阿里大於，咱們在前面的電商項目中已經講解過，故帳號申請等環節略 過） 咱們這裏實際作的就是消息的消費者.

4.2 提取隊列中的消息

4.2.1 工程搭建

（1）建立工程模塊：tensquare_sms，pom.xml引入依賴

  <dependency>    
  <groupId>org.springframework.boot</groupId>          
 <artifactId>spring‐boot‐starter‐amqp</artifactId>          
 </dependency>  

（2）建立application.yml

server: port: 9009 spring: application: name: tensquare‐sms #指定服務名 rabbitmq: host: 192.168.184.134

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

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

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 註冊帳號 （2）手機下載」阿里雲「APP，完成實名認證 （3）登錄阿里雲，產品中選擇」短信服務「 （4）申請簽名 （5）申請模板 （6）建立 accessKey （注意保密！） （7）充值 （不必充太多，1至2元足矣，土豪請隨意~）

4.3.3 代碼編寫

（1）建立工程模塊tensquare_sms，pom.xml引入依賴

  <dependency>    
      <groupId>com.aliyun</groupId>     
     <artifactId>aliyun‐java‐sdk‐dysmsapi</artifactId>     
     <version>1.0.0‐SNAPSHOT</version>     
    </dependency> 
    <dependency>  
     <groupId>com.aliyun</groupId>     
     <artifactId>aliyun‐java‐sdk‐core</artifactId>     
     <version>3.2.5</version>     
    </dependency>   

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

aliyun: sms: accessKeyId: 不告訴你 accessKeySecret: 不告訴你 template_code: SMS_85735065 sign_name: 黑馬

（3）建立短信工具類SmsUtil （資源已提供，直接拷貝便可）

  package com.tensquare.sms;
  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 java.text.SimpleDateFormat;
 import java.util.Date;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.core.env.Environment;
 import org.springframework.stereotype.Component;
 /**
  * 短信工具類
  * @author Administrator
  *
  */
 @Component
 public class SmsUtil {
     //產品名稱:雲通訊短信API產品,開發者無需替換
     static final String product = "Dysmsapi";
     //產品域名,開發者無需替換
     static final String domain = "dysmsapi.aliyuncs.com";
    
     @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);
         //可選:模板中的變量替換JSON串,如模板內容爲"親愛的${name},您的驗證碼爲
 ${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 = "sms")
 public class SmsListener {
     @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(Map<String,String> map){
         System.out.println("手機號："+map.get("mobile"));
         System.out.println("驗證碼："+map.get("code"));
         try {
             smsUtil.sendSms(map.get("mobile"),template_code,sign_name,"
 {\"number\":\""+ map.get("code") +"\"}");
         } catch (ClientException e) {
             e.printStackTrace();
         }
     }
 ​