十次方專案第五天（訊息中介軟體RabbitMQ）
-
能夠說出訊息佇列的應用場景以及RabbitMQ的主要概念
-
-
完成使用者註冊，能夠將訊息傳送給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設定的長度限制為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
*/
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();
}
}