springboot整合alidayu傳送簡訊工具類---rabbitmq
阿新 • • 發佈：2018-12-21
1.java專案引入maven依賴
<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-amqp</artifactId> </dependency> <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: LTAIFI9CoiM9x16W
accessKeySecret: LtJWjfh72KFZee6cnr3kUukIM4Lohh
template_code: SMS_151060165
sign_name: ########需要在alidayu上面上傳公司的營業執照和委託書3.傳送簡訊和接受簡訊工具類
package com.tensquare.sms.util; import com.aliyuncs.DefaultAcsClient; 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 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; /** * @program: tensquare_parent * @description: 傳送簡訊工具類 * @author: liumiao * @create: 2018-11-14 11:59 **/ @Component public class SmsUtil { //產品名稱 static final String product = "Dysmsapi"; //產品域名 static final String domain = "dysmsapi.aliyuncs.com"; @Autowired private Environment env; //傳送簡訊 public SendSmsResponse sendSms(String mobile, String template_code, String sign_name, String param) throws ClientException { String accessKeyId = env.getProperty("aliyun.sms.accessKeyId");//accessKeyId String accessKeySecret = env.getProperty("aliyun.sms.accessKeySecret");//accessKeySecret System.setProperty("sun.net.client.defaultConnectTimeout", "10000");//設定超時時間 System.setProperty("sun.net.client.defaultReadTimeout", "10000"); //初始化acsclient 暫不支援region化 DefaultProfile profile = DefaultProfile.getProfile("cn-hangzhou", accessKeyId, accessKeySecret); DefaultProfile.addEndpoint("cn-hangzhou", "cn-hangzhou", product, domain); DefaultAcsClient acsClient = new DefaultAcsClient(profile); //組裝請求物件 SendSmsRequest request = new SendSmsRequest(); //必填:待發送手機號。支援以逗號分隔的形式進行批量呼叫，批量上限為1000個手機號碼,批量呼叫相對於單條呼叫及時性稍有延遲,驗證碼型別的簡訊推薦使用單條呼叫的方式；傳送國際/港澳臺訊息時，接收號碼格式為國際區號+號碼，如“85200000000” request.setPhoneNumbers(mobile); //必填:簡訊簽名-可在簡訊控制檯中找到 request.setSignName(sign_name); //必填:簡訊模板-可在簡訊控制檯中找到，傳送國際/港澳臺訊息時，請使用國際/港澳臺簡訊模版 request.setTemplateCode(template_code); //可選:模板中的變數替換JSON串,如模板內容為"親愛的${name},您的驗證碼為${code}"時,此處的值為 //友情提示:如果JSON中需要帶換行符,請參照標準的JSON協議對換行符的要求,比如簡訊內容中包含\r\n的情況在JSON中需要表示成\\r\\n,否則會導致JSON在服務端解析失敗 //"{\"name\":\"Tom\", \"code\":\"123\"}" request.setTemplateParam(param); //可選-上行簡訊擴充套件碼(擴充套件碼欄位控制在7位或以下，無特殊需求使用者請忽略此欄位) //request.setSmsUpExtendCode("90997"); //可選:outId為提供給業務方擴充套件欄位,最終在簡訊回執訊息中將此值帶回給呼叫者 request.setOutId("yourOutId"); //請求失敗這裡會拋ClientException異常 SendSmsResponse sendSmsResponse = acsClient.getAcsResponse(request); return sendSmsResponse; } //接受簡訊 public QuerySendDetailsResponse querySendDetails(String mobile, String bizId) throws ClientException { String accessKeyId = env.getProperty("aliyun.sms.accessKeyId");//accessKeyId String accessKeySecret = env.getProperty("aliyun.sms.accessKeySecret");//accessKeySecret System.setProperty("sun.net.client.defaultConnectTimeout", "10000");//設定超時時間 System.setProperty("sun.net.client.defaultReadTimeout", "10000"); //初始化acsclient 暫不支援region化 DefaultProfile profile = DefaultProfile.getProfile("cn-hangzhou", accessKeyId, accessKeySecret); DefaultProfile.addEndpoint("cn-hangzhou", "cn-hangzhou", product, domain); DefaultAcsClient acsClient = new DefaultAcsClient(profile); //組裝請求物件 QuerySendDetailsRequest request = new QuerySendDetailsRequest(); //必填-號碼 request.setPhoneNumber(mobile); //可選-呼叫傳送簡訊介面時返回的BizId 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.rabbitmq接收到訊息後傳送短息
package com.tensquare.sms.listener; import com.aliyuncs.dysmsapi.model.v20170525.SendSmsResponse; import com.aliyuncs.exceptions.ClientException; import com.tensquare.sms.util.SmsUtil; import org.springframework.amqp.rabbit.annotation.RabbitHandler; import org.springframework.amqp.rabbit.annotation.RabbitListener; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.core.env.Environment; import org.springframework.stereotype.Component; import java.util.Map; /** * @program: tensquare_parent * @description: * @author: liumiao * @create: 2018-11-14 10:45 **/ @Component @RabbitListener(queues = "sms") public class SmsListener { @Autowired private SmsUtil smsUtil; @Autowired private Environment env; /** * 傳送簡訊 * * @param message */ @RabbitHandler public void sendSms(Map<String, String> message) { System.out.println("手機號：" + message.get("mobile")); System.out.println("手機號：" + message.get("code")); String template_code = env.getProperty("aliyun.sms.template_code");//模板程式碼 String sign_name = env.getProperty("aliyun.sms.sign_name");//簽名 try { SendSmsResponse response = smsUtil.sendSms(message.get("mobile"), template_code, sign_name, "{\"number\":\"" + message.get("code") + "\"}"); System.out.println("簡訊傳送結果：" + response.getCode() + "----" + response.getMessage()); } catch (ClientException e) { e.printStackTrace(); } } }