Java整合騰訊云短信發(fā)送實例代碼
更新時間:2021年12月31日 15:36:26 作者:局外人Inside
大家好,本篇文章主要講的是Java整合騰訊云短信發(fā)送實例代碼,感興趣的同學趕快來看一看吧,對你有幫助的話記得收藏一下,方便下次瀏覽
1. 引入相關maven依賴
<dependency> <groupId>com.github.qcloudsms</groupId> <artifactId>qcloudsms</artifactId> <version>1.0.6</version> </dependency> <dependency> <groupId>com.qcloud</groupId> <artifactId>qcloud-java-sdk</artifactId> <version>2.0.1</version> </dependency> <dependency> <groupId>com.tencentcloudapi</groupId> <artifactId>tencentcloud-sdk-java</artifactId> <version>3.1.270</version><!-- 注:這里只是示例版本號(可直接使用),可獲取并替換為 最新的版本號,注意不要使用4.0.x版本(非最新版本) --> </dependency> <dependency> <groupId>cn.hutool</groupId> <artifactId>hutool-all</artifactId> <version>5.4.2</version> </dependency>
2. 編寫短信發(fā)送工具類
package com.cloud.system.common.utils; import ch.qos.logback.core.net.server.Client; import cn.hutool.core.util.RandomUtil; import com.cloud.system.api.enums.SmsLengthEnum; import com.cloud.system.api.enums.SmsTypeEnum; import com.tencentcloudapi.common.Credential; import com.tencentcloudapi.common.exception.TencentCloudSDKException; import com.tencentcloudapi.common.profile.ClientProfile; import com.tencentcloudapi.common.profile.HttpProfile; import com.tencentcloudapi.sms.v20210111.SmsClient; import com.tencentcloudapi.sms.v20210111.models.SendSmsRequest; import com.tencentcloudapi.sms.v20210111.models.SendSmsResponse; import com.tencentcloudapi.sms.v20210111.models.SendStatus; import lombok.extern.slf4j.Slf4j; import org.springframework.stereotype.Component; import java.io.BufferedInputStream; import java.io.FileInputStream; import java.io.InputStream; import java.io.InputStreamReader; import java.util.Properties; /** * @program: server-master * @description: * @author: hjq * @create: 2021/12/17 */ @Component @Slf4j public class SmsUtil { /** 騰訊云賬戶密鑰對secretId(在訪問管理中配置) */ private static String secretId; /** 騰訊云賬戶密鑰對secretKey(在訪問管理中配置) */ private static String secretKey; /** 短信應用appId */ private static String appId; /** 短信應用appKey */ private static String appKey; /** 簽名 */ private static String smsSign; /** 過期時間 */ private static String expireTime; /** 登錄驗證模板 */ private static String loginTemplateId; /** 修改密碼驗證模板 */ private static String pwdTemplateId; static { try { Properties prop=new Properties(); prop.load(new InputStreamReader( Client.class.getClassLoader().getResourceAsStream("sms.properties"), "gbk")); secretId = prop.get("secretId").toString(); secretKey = prop.get("secretKey").toString(); appId = prop.get("appId").toString(); appKey = prop.get("appKey").toString(); smsSign = prop.get("smsSign").toString(); expireTime = prop.get("expireTime").toString(); loginTemplateId = prop.get("loginTemplateId").toString(); pwdTemplateId = prop.get("pwdTemplateId").toString(); } catch(Exception e) { e.printStackTrace(); } } /** * 短信發(fā)送工具類 * @param phoneNumbers 下發(fā)手機號碼 * @param templateParamSet 模板參數 */ public static SendStatus sendMessage(String[] phoneNumbers, String[] templateParamSet,Integer type) throws TencentCloudSDKException { // 實例化一個認證對象,入參需要傳入騰訊云賬戶密鑰對secretId,secretKey Credential cred = new Credential(secretId, secretKey); // 實例化一個http選項 HttpProfile httpProfile = new HttpProfile(); httpProfile.setReqMethod("POST"); httpProfile.setConnTimeout(60); //實例化一個客戶端配置對象,指定超時時間等配置 ClientProfile clientProfile = new ClientProfile(); /* SDK默認用TC3-HMAC-SHA256進行簽名 * 非必要請不要修改這個字段 */ clientProfile.setSignMethod("HmacSHA256"); clientProfile.setHttpProfile(httpProfile); SmsClient client = new SmsClient(cred, "ap-guangzhou",clientProfile); SendSmsRequest req = new SendSmsRequest(); //短信應用ID req.setSmsSdkAppId(appId); //短信簽名內容 req.setSignName(smsSign); /* 模板 ID: 必須填寫已審核通過的模板 ID。模板ID可登錄 [短信控制臺] 查看 */ //根據不同業(yè)務使用不同的模板 switch (type){ case 1: req.setTemplateId(pwdTemplateId); break; case 2: req.setTemplateId(loginTemplateId); break; } //下發(fā)手機號碼 req.setPhoneNumberSet(phoneNumbers); /* 模板參數: 若無模板參數,則設置為空 */ req.setTemplateParamSet(templateParamSet); SendSmsResponse res = client.SendSms(req); return res.getSendStatusSet()[0]; } /** * 隨機生成指定長度的短信的驗證碼 * * @param smsLengthEnum 短信驗證碼長度枚舉 * @return 隨機驗證碼 */ public static String createSmsRandomCode(SmsLengthEnum smsLengthEnum) { return RandomUtil.randomNumbers(smsLengthEnum.getLength()); } /** * 創(chuàng)建短信驗證碼,緩存鍵策略 * 策略:前綴_業(yè)務名_手機號 * * @param prefix 前綴 * @param phone 手機號 * @param businessStr 業(yè)務名 * @return 短信驗證碼,緩存鍵策略 */ public static String createSmsCacheKey(String prefix, String phone, String businessStr) { return prefix + "_" + businessStr + "_" + phone; } }
3. 業(yè)務層
使用redis存儲隨機生成的驗證碼,并在使用后銷毀
package com.cloud.system.api.service.impl; import com.cloud.system.api.bean.SmsPwdBean; import com.cloud.system.api.bean.SmsResult; import com.cloud.system.api.entity.HumanInfo; import com.cloud.system.api.entity.SmsRecord; import com.cloud.system.api.enums.SmsLengthEnum; import com.cloud.system.api.enums.SmsTypeEnum; import com.cloud.system.api.mapper.HumanInfoMapper; import com.cloud.system.api.mapper.SmsRecordMapper; import com.cloud.system.api.service.SmsRecordService; import com.cloud.system.common.utils.RedisUtil; import com.cloud.system.common.utils.RegUtils; import com.cloud.system.common.utils.SmsUtil; import com.tencentcloudapi.common.exception.TencentCloudSDKException; import com.tencentcloudapi.sms.v20210111.models.SendStatus; import lombok.extern.slf4j.Slf4j; import org.apache.commons.codec.digest.DigestUtils; import org.apache.commons.collections.CollectionUtils; import org.apache.commons.lang.StringUtils; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import tk.mybatis.mapper.entity.Example; import javax.annotation.Resource; import java.util.Date; import java.util.List; import java.util.Objects; /** * @program: server-master * @description: * @author: hjq * @create: 2021/12/20 */ @Service("smsRecordService") @Transactional @Slf4j public class SmsRecordServiceImpl implements SmsRecordService { @Resource private SmsRecordMapper smsRecordMapper; @Resource private HumanInfoMapper humanInfoMapper; @Resource private RedisUtil redisUtil; @Override public SmsResult getModPwdVcode(String humanName, String phoneNumber) { //首先校驗手機號碼 if (!RegUtils.isMoblie(phoneNumber)) return new SmsResult(500,"手機號格式不正確!",null); //然后校驗輸入手機號是否和該用戶名綁定 if (humanInfoMapper.existByNameAndPhone(humanName, phoneNumber) <= 0){ return new SmsResult(500,"該用戶不存在,請聯系管理員注冊!",null); } //生成六位的隨機驗證碼 return sendSms(phoneNumber, SmsTypeEnum.SMS_TYPE_1, humanName); } /** * 修改密碼 */ @Override public SmsResult updatePwdByHuman(SmsPwdBean bean) { //創(chuàng)建相同的緩存鍵 String cacheKey = SmsUtil.createSmsCacheKey(String.valueOf(bean.getUsername().hashCode()),bean.getPhoneNumber(), SmsTypeEnum.SMS_TYPE_1.getTypeName()); //驗證碼校驗,若返回500,則直接返回 SmsResult result = vCodeCheck(cacheKey, bean.getCaptcha()); if (500 == result.getCode()){ return result; } //獲取人員id與密碼進行加密,然后修改密碼 Long humanId = humanInfoMapper.existByNameAndPhone(bean.getUsername(),bean.getPhoneNumber()); String code = DigestUtils.md5Hex(bean.getRepassword().concat(String.valueOf(humanId))).toUpperCase(); humanInfoMapper.modifyPwdByNameAndPhone(bean.getUsername(),bean.getPhoneNumber(),code); //清除已使用的驗證碼 redisUtil.del(cacheKey); return new SmsResult(200,"密碼已重置!",null); } /** * 用戶登錄獲取驗證碼 * @param humanName 用戶名 * @return */ @Override public SmsResult getLoginCode(String humanName){ //獲取用戶信息 Example example = new Example(HumanInfo.class); Example.Criteria criteria = example.createCriteria(); criteria.andEqualTo("deleteFlag", 0); criteria.andEqualTo("userName", humanName); List<HumanInfo> humanInfoList = humanInfoMapper.selectByExample(example); //校驗用戶手機號 if (CollectionUtils.isEmpty(humanInfoList) || humanInfoList.size() != 1 || StringUtils.isBlank(humanInfoList.get(0).getTelephone()) || !RegUtils.isMoblie(humanInfoList.get(0).getTelephone())) { return new SmsResult(500,"手機號格式不正確!",null); } return sendSms(humanInfoList.get(0).getTelephone(), SmsTypeEnum.SMS_TYPE_2, humanInfoList.get(0).getHumanName()); } /** * 校驗用戶登錄驗證碼 * @return */ @Override public SmsResult checkLoginCode(HumanInfo info,String captCha){ //創(chuàng)建相同的緩存鍵 String cacheKey = SmsUtil.createSmsCacheKey(String.valueOf(info.getHumanName().hashCode()),info.getTelephone(), SmsTypeEnum.SMS_TYPE_2.getTypeName()); //驗證碼校驗,若返回500,則直接返回 SmsResult result = vCodeCheck(cacheKey, captCha); if (200 == result.getCode()){ //清除已使用的驗證碼 redisUtil.del(cacheKey); } return result; } /** * 發(fā)送短信 * @param telephone 手機號 * @param smsType2 短信類型 * @param humanName 用戶名 * @return */ private SmsResult sendSms(String telephone, SmsTypeEnum smsType2, String humanName) { //生成六位的隨機驗證碼 String randomCode = SmsUtil.createSmsRandomCode(SmsLengthEnum.SMS_LENGTH_6); //構建參數,發(fā)送短信 SendStatus sendStatus = null; try { sendStatus = SmsUtil.sendMessage(new String[]{telephone}, new String[]{randomCode}, smsType2.getType()); } catch (TencentCloudSDKException e) { log.error("********短信發(fā)送失敗" + e.getMessage() + "*********"); e.printStackTrace(); } if (Objects.nonNull(sendStatus) && "Ok".equals(sendStatus.getCode())) { //發(fā)送成功后往記錄表插值同時將驗證碼存儲至redis,300s過期 insertSmsRecord(telephone,smsType2.getType()); //創(chuàng)建緩存鍵 String cacheKey = SmsUtil.createSmsCacheKey(String.valueOf(humanName.hashCode()), telephone, smsType2.getTypeName()); redisUtil.set(cacheKey, randomCode, 300); return new SmsResult(200, "驗證碼發(fā)送成功!", null); } else { return new SmsResult(500, "驗證碼發(fā)送失敗!", null); } } /** * 插入短信發(fā)送記錄 * @param phoneNumber */ private void insertSmsRecord(String phoneNumber, int type) { SmsRecord smsRecord = new SmsRecord(); smsRecord.setRecipient(phoneNumber); smsRecord.setSendTime(new Date()); smsRecord.setSmsType(type); smsRecordMapper.insert(smsRecord); } /** * 驗證碼校驗 */ private SmsResult vCodeCheck(String cacheKey,String captcha){ if (!redisUtil.hasKey(cacheKey)){ return new SmsResult(500,"驗證碼已過期,請重新獲?。?,null); } if (!captcha.equals(redisUtil.get(cacheKey))){ return new SmsResult(500,"驗證碼錯誤!",null); } return new SmsResult(200,"驗證碼正確!",null); } }
3. 相關工具類
package com.cloud.system.common.utils; /** * @author: hjq * @create: 2021-01-07 09:54 **/ import java.util.regex.Matcher; import java.util.regex.Pattern; import org.apache.commons.lang.StringUtils; /** * 正則表達式工具類 * */ public class RegUtils { /** * 郵箱 */ public static final String EMAIL = "^\\w+((-\\w+)|(\\.\\w+))*\\@[A-Za-z0-9]+((\\.|-)[A-Za-z0-9]+)*\\.[A-Za-z0-9]+$"; /** * 手機號碼 */ public static final String PHONE = "^(1[3-9]([0-9]{9}))$"; /** * 僅中文 */ public static final String CHINESE = "^[\\u4E00-\\u9FA5\\uF900-\\uFA2D]+$"; /** * 整數 */ public static final String INTEGER = "^-?[1-9]\\d*$"; /** * 數字 */ public static final String NUMBER = "^([+-]?)\\d*\\.?\\d+$"; /** * 正整數 */ public static final String INTEGER_POS = "^[1-9]\\d*$"; /** * 浮點數 */ public static final String FLOAT = "^([+-]?)\\d*\\.\\d+$"; /** * 正浮點數 */ public static final String FLOAT_POS = "^[1-9]\\d*.\\d*|0.\\d*[1-9]\\d*$"; /** * 是否為正整數數字,包括0(00,01非數字) */ public static final String INTEGER_WITH_ZERO_POS = "^(([0-9])|([1-9]([0-9]+)))$"; /** * 是否為整數數字,包括正、負整數,包括0(00,01非數字) */ public static final String NUMBER_WITH_ZERO = "^((-)?(([0-9])|([1-9]([0-9]+))))$"; /** * 是否為數字字符串 */ public static final String NUMBER_TEXT = "^([0-9]+)$"; /** * 數字(整數、0、浮點數),可以判斷是否金額,也可以是負數 */ public static final String NUMBER_ALL = "^((-)?(([0-9])|([1-9][0-9]+))(\\.([0-9]+))?)$"; /** * QQ,5-14位 */ public static final String QQ = "^[1-9][0-9]{4,13}$"; /** * IP地址 */ public static final String IP = "((?:(?:25[0-5]|2[0-4]\\d|[01]?\\d?\\d)\\.){3}(?:25[0-5]|2[0-4]\\d|[01]?\\d?\\d))"; /** * 郵編 */ public static final String POST_CODE = "[1-9]\\d{5}(?!\\d)"; /** * 普通日期 */ public static final String DATE = "^[1-9]\\d{3}-((0[1-9])|(1[0-2]))-((0[1-9])|([1-2][0-9])|(3[0-1]))$"; /** * 復雜日期,不區(qū)分閏年的2月 * 日期格式:2017-10-19 * 或2017/10/19 * 或2017.10.19 * 或2017年10月19日 * 最大31天的月份:(((01|03|05|07|08|10|12))-((0[1-9])|([1-2][0-9])|(3[0-1]))) * 最大30天的月份:(((04|06|11))-((0[1-9])|([1-2][0-9])|(30))) * 最大29天的月份:(02-((0[1-9])|([1-2][0-9]))) */ public static final String DATE_COMPLEX = "^(([1-2]\\d{3})(-|/|.|年)((((01|03|05|07|08|10|12))(-|/|.|月)((0[1-9])|([1-2][0-9])|(3[0-1])))|(((04|06|11))(-|/|.|月)((0[1-9])|([1-2][0-9])|(30)))|(02-((0[1-9])|([1-2][0-9]))))(日)?)$"; /** * 復雜的日期,區(qū)分閏年的2月 * 這個日期校驗能區(qū)分閏年的2月,格式如下:2017-10-19 * (見://www.dbjr.com.cn/article/50905.htm) * ^((?!0000)[0-9]{4}-((0[1-9]|1[0-2])-(0[1-9]|1[0-9]|2[0-8])|(0[13-9]|1[0-2])-(29|30)|(0[13578]|1[02])-31)|([0-9]{2}(0[48]|[2468][048]|[13579][26])|(0[48]|[2468][048]|[13579][26])00)-02-29)$ */ public static final String DATE_COMPLEX_LEAP_YEAR = "^(?:(?!0000)[0-9]{4}-(?:(?:0[1-9]|1[0-2])-(?:0[1-9]|1[0-9]|2[0-8])|(?:0[13-9]|1[0-2])-(?:29|30)|(?:0[13578]|1[02])-31)|(?:[0-9]{2}(?:0[48]|[2468][048]|[13579][26])|(?:0[48]|[2468][048]|[13579][26])00)-02-29)$"; /** * 正則表達式校驗,符合返回True * @param regex 正則表達式 * @param content 校驗的內容 * @return */ public static boolean isMatch(String regex, CharSequence content){ return Pattern.matches(regex, content); } /** * 校驗手機號碼 * @param mobile * @return */ public static final boolean isMoblie(String mobile){ boolean flag = false; if (null != mobile && !mobile.trim().equals("") && mobile.trim().length() == 11) { Pattern pattern = Pattern.compile(PHONE); Matcher matcher = pattern.matcher(mobile.trim()); flag = matcher.matches(); } return flag; } /** * 校驗郵箱 * @param value * @return */ public static final boolean isEmail(String value){ boolean flag = false; if (null != value && !value.trim().equals("")) { Pattern pattern = Pattern.compile(EMAIL); Matcher matcher = pattern.matcher(value.trim()); flag = matcher.matches(); } return flag; } /** * 校驗密碼 * @param password * @return 長度符合返回true,否則為false */ public static final boolean isPassword(String password){ boolean flag = false; if (null != password && !password.trim().equals("")) { password = password.trim(); if(password.length() >= 6 && password.length() <= 30){ return true; } } return flag; } /** * 校驗手機驗證碼 * @param value * @return 符合正則表達式返回true,否則返回false */ public static final boolean isPhoneValidateCode(String value){ boolean flag = false; if (null != value && !value.trim().equals("")) { Pattern pattern = Pattern.compile("^8\\d{5}$"); Matcher matcher = pattern.matcher(value.trim()); flag = matcher.matches(); } return flag; } /** * 判斷是否全部大寫字母 * @param str * @return */ public static boolean isUpperCase(String str){ if(StringUtils.isEmpty(str)){ return false; } String reg = "^[A-Z]$"; return isMatch(reg,str); } /** * 判斷是否全部小寫字母 * @param str * @return */ public static boolean isLowercase(String str){ if(StringUtils.isEmpty(str)){ return false; } String reg = "^[a-z]$"; return isMatch(reg,str); } /** * 是否ip地址 * @param str * @return */ public static boolean isIP(String str){ if(StringUtils.isEmpty(str)){ return false; } return isMatch(IP, str); } /** * 符合返回true,區(qū)分30、31天和閏年的2月份(最嚴格的校驗),格式為2017-10-19 * @param str * @return */ public static boolean isDate(String str){ if(StringUtils.isEmpty(str)){ return false; } return isMatch(DATE_COMPLEX_LEAP_YEAR, str); } /** * 簡單日期校驗,不那么嚴格 * @param str * @return */ public static boolean isDateSimple(String str){ if(StringUtils.isEmpty(str)){ return false; } return isMatch(DATE, str); } /** * 區(qū)分30、31天,但沒有區(qū)分閏年的2月份 * @param str * @return */ public static boolean isDateComplex(String str){ if(StringUtils.isEmpty(str)){ return false; } return isMatch(DATE_COMPLEX, str); } /** * 判斷是否為數字字符串,如0011,10101,01 * @param str * @return */ public static boolean isNumberText(String str){ if(StringUtils.isEmpty(str)){ return false; } return isMatch(NUMBER_TEXT, str); } /** * 判斷所有類型的數字,數字(整數、0、浮點數),可以判斷是否金額,也可以是負數 * @param str * @return */ public static boolean isNumberAll(String str){ if(StringUtils.isEmpty(str)){ return false; } return isMatch(NUMBER_ALL, str); } /** * 是否為正整數數字,包括0(00,01非數字) * @param str * @return */ public static boolean isIntegerWithZeroPos(String str){ if(StringUtils.isEmpty(str)){ return false; } return isMatch(INTEGER_WITH_ZERO_POS, str); } /** * 是否為整數,包括正、負整數,包括0(00,01非數字) * @param str * @return */ public static boolean isIntegerWithZero(String str){ if(StringUtils.isEmpty(str)){ return false; } return isMatch(NUMBER_WITH_ZERO, str); } /** * 符合返回true,QQ,5-14位 * @param str * @return */ public static boolean isQQ(String str){ if(StringUtils.isEmpty(str)){ return false; } return isMatch(QQ, str); } public static void main(String[] args) { System.out.println(isMoblie("13430800244")); System.out.println(isMoblie("17730800244")); System.out.println(isMoblie("17630800244")); System.out.println(isMoblie("14730800244")); System.out.println(isMoblie("18330800244")); System.out.println(isMoblie("19330800244")); System.out.println(isMoblie("1333000244")); } }
到此這篇關于Java整合騰訊云短信發(fā)送實例代碼的文章就介紹到這了,更多相關Java騰訊云短信發(fā)送內容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家!
相關文章
SpringBoot+Shiro+LayUI權限管理系統(tǒng)項目源碼
本項目旨在打造一個基于RBAC架構模式的通用的、并不復雜但易用的權限管理系統(tǒng),通過SpringBoot+Shiro+LayUI權限管理系統(tǒng)項目可以更好的幫助我們掌握springboot知識點,感興趣的朋友一起看看吧2021-04-04解決mybatis-plus動態(tài)數據源切換不生效的問題
本文主要介紹了解決mybatis-plus動態(tài)數據源切換不生效的問題,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友們下面隨著小編來一起學習學習吧2023-01-01校驗非空的注解@NotNull如何取得自定義的message
這篇文章主要介紹了校驗非空的注解@NotNull如何取得自定義的message,具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教2021-09-09