阿里雲 簡訊服務 +SpringBoot+Redis 設定過期時間
阿新 • • 發佈:2020-11-14
以前寫了一篇利用阿里雲 雲市場 買其它公司的服務發簡訊:https://www.cnblogs.com/mangoubiubiu/p/12860271.html,這篇code是存session裡的,用session讓 驗證碼限定過期
一、申請簽名 和模板 ,獲取accessKeyId 和secret
1、開通阿里雲簡訊服務
2、進入管理控制檯申請簽名和模板
拿到accessKeyId 和secret
二、程式碼編寫
1、引入依賴
<dependencies> <dependency> <groupId>com.alibaba</groupId> <artifactId>fastjson</artifactId> </dependency> <dependency> <groupId>com.aliyun</groupId> <artifactId>aliyun-java-sdk-core</artifactId> </dependency> </dependencies>
2、準備生成驗證碼的工具類
package com.atguigu.msmservice.utils; import java.text.DecimalFormat; import java.util.ArrayList; import java.util.HashMap; import java.util.List; import java.util.Random; /** * 獲取隨機數 * */ public class RandomUtil { private static final Random random = new Random(); privatestatic final DecimalFormat fourdf = new DecimalFormat("0000"); private static final DecimalFormat sixdf = new DecimalFormat("000000"); public static String getFourBitRandom() { return fourdf.format(random.nextInt(10000)); } public static String getSixBitRandom() { return sixdf.format(random.nextInt(1000000)); }/** * 給定陣列,抽取n個數據 * @param list * @param n * @return */ public static ArrayList getRandom(List list, int n) { Random random = new Random(); HashMap<Object, Object> hashMap = new HashMap<Object, Object>(); // 生成隨機數字並存入HashMap for (int i = 0; i < list.size(); i++) { int number = random.nextInt(100) + 1; hashMap.put(number, i); } // 從HashMap匯入陣列 Object[] robjs = hashMap.values().toArray(); ArrayList r = new ArrayList(); // 遍歷陣列並列印資料 for (int i = 0; i < n; i++) { r.add(list.get((int) robjs[i])); System.out.print(list.get((int) robjs[i]) + "\t"); } System.out.print("\n"); return r; } }
3、Controller
package com.atguigu.msmservice.controller; import com.atguigu.msmservice.service.MsmService; import com.atguigu.commonutils.R; import com.atguigu.msmservice.utils.RandomUtil; import org.apache.commons.lang.StringUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.data.redis.core.RedisTemplate; import org.springframework.web.bind.annotation.*; import java.util.HashMap; import java.util.Map; import java.util.concurrent.TimeUnit; @RestController @RequestMapping("/edumsm/msm") @CrossOrigin public class MsmController { @Autowired private MsmService msmService; @Autowired private RedisTemplate<String,String> redisTemplate; @GetMapping("send/{phone}") public R sendPhoneMsg(@PathVariable String phone){ String code=redisTemplate.opsForValue().get("phoneCode"); //如果從redis 取值 不為空 代表已經發生簡訊 if(!StringUtils.isEmpty(code)){ return R.ok(); } code= RandomUtil.getFourBitRandom(); Map<String,Object> param=new HashMap<String,Object>(); param.put("code",code); //呼叫service 傳送簡訊的方法 Boolean isSend= msmService.send(param,phone); if(isSend){ //傳送成功 後 發驗證碼 放到 redis 設定 有效時間 key value 5 分鐘 redisTemplate.opsForValue().set("phoneCode",code,5, TimeUnit.MINUTES); return R.ok(); }else{ return R.error().message("簡訊傳送失敗"); } } }
4、Service
package com.atguigu.msmservice.service.serviceImpl; import com.alibaba.fastjson.JSONObject; import com.aliyuncs.CommonRequest; import com.aliyuncs.CommonResponse; import com.aliyuncs.DefaultAcsClient; import com.aliyuncs.IAcsClient; import com.aliyuncs.exceptions.ClientException; import com.aliyuncs.exceptions.ServerException; import com.aliyuncs.http.MethodType; import com.aliyuncs.profile.DefaultProfile; import com.atguigu.msmservice.service.MsmService; import org.springframework.stereotype.Service; import org.springframework.util.StringUtils; import java.util.Map; @Service public class MsmServiceImpl implements MsmService { @Override public Boolean send(Map<String, Object> param, String phone) { if(StringUtils.isEmpty(phone)) return false; DefaultProfile profile = DefaultProfile.getProfile("default", "你的key", "你的secret"); IAcsClient client = new DefaultAcsClient(profile); //設定相關固定引數 這裡固定引數不需要做修改 CommonRequest request = new CommonRequest(); //request.setProtocol(ProtocolType.HTTPS); request.setMethod(MethodType.POST); request.setDomain("dysmsapi.aliyuncs.com"); request.setVersion("2017-05-25"); request.setAction("SendSms"); //設定傳送相關的引數 注意:key 定死 不能隨便寫 //手機號 request.putQueryParameter("PhoneNumbers", phone); //簽名名稱 request.putQueryParameter("SignName", "你的模板名"); request.putQueryParameter("TemplateCode", "你的TemplateCode"); //傳code 將map 轉成json request.putQueryParameter("TemplateParam", JSONObject.toJSONString(param)); //最終傳送 try { CommonResponse response = client.getCommonResponse(request); System.out.println(response.getData()); return response.getHttpResponse().isSuccess(); } catch (ServerException e) { e.printStackTrace(); } catch (ClientException e) { e.printStackTrace(); } return false; } }
4、Swagger UI測試