廢話不多說直接上代碼:
驗(yàn)證碼生成代碼:
String code = KeyGenerater.getRandomNumberKey(6);
String data = FastJsonUtil.of("code", code, "product", "網(wǎng)").toJSONString();
if (sendSms(phoneNum, data, codeModel)) {
redisService.set(cacheKey, code, GlobalCacheManageEnum.PHONE_SMS_KEY.getExpireTime());
resultVo.setData(total);
return resultVo;
}
調(diào)用發(fā)送消息:
配置:
image.png
遠(yuǎn)程調(diào)用:
private Boolean sendSms(String phoneNum, String data, String codeModel) {
if (StringUtils.isBlank(phoneNum) || StringUtils.isBlank(data) || StringUtils.isBlank(codeModel)) {
throw new OpBusinessException(PublicExceptionCodeEnum.EX_PARAM_NOT_NULL.getCode(), PublicExceptionCodeEnum.EX_PARAM_NOT_NULL.getMsg());
}
if (redisService.exists(GlobalCacheManageEnum.PHONE_SMS_KEY.getCacheKey(codeModel, phoneNum))) {
throw new OpBusinessException(ExceptionCodeEnum.EX_PHONE_CODE_IS_USING.getCode(), ExceptionCodeEnum.EX_PHONE_CODE_IS_USING.getMsg());
}
// 1:組裝發(fā)送信息
String randomKey = KeyGenerater.getRandomKey(32);
Map<String, String> param = new HashMap<String, String>();
param.put("appId", phoneSmsAppId);
param.put("mobile", phoneNum);
param.put("data", data);
param.put("codeModel", codeModel);
param.put("randomKey", randomKey);
String sign = MD5Facade.getFormDataParamMD5(param, phoneSmsSecretKey, null);
param.put("sign", sign);
// 4:獲取驗(yàn)證碼
String result;
try {
result = HttpClientUtil.doGet(phoneSmsUrl, param);
} catch (Exception e) {
throw new RpcInvokeException("sendSms-------" + phoneSmsUrl, e);
}
if (StringUtils.isEmpty(result)) {
// 短信服務(wù)器異常
throw new OpBusinessException(ExceptionCodeEnum.EX_PHONE_SMS_SERVICE_ERROR.getCode(), ExceptionCodeEnum.EX_PHONE_SMS_SERVICE_ERROR.getMsg());
}
// 5:解析結(jié)果
ResultVo<Object> stringResultVo = JSONObject.parseObject(result, new TypeReference<ResultVo<Object>>() {
});
if (stringResultVo == null || !PublicExceptionCodeEnum.SUCCESS.getCode().equals(stringResultVo.getCode())) {
throw new OpBusinessException(ExceptionCodeEnum.EX_PHONE_SMS_SERVICE_ERROR.getCode(), ExceptionCodeEnum.EX_PHONE_SMS_SERVICE_ERROR.getMsg(), FastJsonUtil.of("stringResultVo", stringResultVo));
}
return true;
}
遠(yuǎn)程代碼:
@RequestMapping(value = "/sendSms", method = RequestMethod.GET)
@ResponseBody
public ResultVo<Object> sendSms(@RequestParam("appId") String appId, @RequestParam("mobile") String mobile,
@RequestParam("data") String data, @RequestParam("codeModel") String codeModel,
@RequestParam("randomKey") String randomKey, @RequestParam("sign") String sign) {
if (!RegExUtil.isPhoneLegal(mobile)) {
throw new SmsBusinessException(SmsExceptionCodeEnum.EX_PHONE_IS_ERROR.getCode());
}
Map<String, String> param = new HashMap<String, String>(5);
param.put("appId", appId);
param.put("mobile", mobile);
param.put("data", data);
param.put("codeModel", codeModel);
param.put("randomKey", randomKey);
if (!MD5Facade.validateFormDataParamMD5(param, secretKey, sign)) {
throw new SmsBusinessException(SmsExceptionCodeEnum.EX_SIGN_ERROR.getCode(), FastJsonUtil.of("param", param));
}
return aliSmsService.sendCode(mobile, SmsCodeModelEnum.eval(codeModel), data);
}
配置文件:
image.png
@Override
public ResultVo<Object> sendCode(String phoneNum, SmsCodeModelEnum codeModelEnum, String data) {
ResultVo<Object> resultVo = ResultFactory.success();
try {
if (StringUtils.isBlank(phoneNum) || null == codeModelEnum || StringUtils.isBlank(data)) {
throw new SmsBusinessException(PublicExceptionCodeEnum.Ex_PARAM_ERROR.getCode());
}
//設(shè)置超時(shí)時(shí)間-可自行調(diào)整
System.setProperty("sun.net.client.defaultConnectTimeout", timeOut);
System.setProperty("sun.net.client.defaultReadTimeout", timeOut);
//初始化ascClient需要的幾個(gè)參數(shù)
//初始化ascClient,暫時(shí)不支持多region(請(qǐng)勿修改)
IClientProfile profile = DefaultProfile.getProfile("cn-hangzhou", accessKey,
accessSecret);
try {
DefaultProfile.addEndpoint("cn-hangzhou", "cn-hangzhou", product, domain);
} catch (ClientException e) {
throw new RpcInvokeException("DefaultProfile.addEndpoint" + FastJsonUtil.of("product", product, "domain", domain), e);
}
IAcsClient acsClient = new DefaultAcsClient(profile);
//組裝請(qǐng)求對(duì)象
SendSmsRequest request = new SendSmsRequest();
//使用post提交
request.setMethod(MethodType.POST);
//必填:待發(fā)送手機(jī)號(hào)。支持以逗號(hào)分隔的形式進(jìn)行批量調(diào)用,批量上限為1000個(gè)手機(jī)號(hào)碼,批量調(diào)用相對(duì)于單條調(diào)用及時(shí)性稍有延遲,驗(yàn)證碼類型的短信推薦使用單條調(diào)用的方式赤屋;發(fā)送國際/港澳臺(tái)消息時(shí),接收號(hào)碼格式為00+國際區(qū)號(hào)+號(hào)碼荧恍,如“0085200000000”
request.setPhoneNumbers(phoneNum);
//修改數(shù)據(jù)交互方式
request.setAcceptFormat(FormatType.JSON);
//必填:短信簽名-可在短信控制臺(tái)中找到
request.setSignName("資明網(wǎng)");
//必填:短信模板-可在短信控制臺(tái)中找到和屎,發(fā)送國際/港澳臺(tái)消息時(shí)妄辩,請(qǐng)使用國際/港澳臺(tái)短信模版
request.setTemplateCode(codeModelEnum.getCode());
//可選:模板中的變量替換JSON串,如模板內(nèi)容為"親愛的${name},您的驗(yàn)證碼為${code}"時(shí),此處的值為
//友情提示:如果JSON中需要帶換行符,請(qǐng)參照標(biāo)準(zhǔn)的JSON協(xié)議對(duì)換行符的要求,比如短信內(nèi)容中包含\r\n的情況在JSON中需要表示成\\r\\n,否則會(huì)導(dǎo)致JSON在服務(wù)端解析失敗
request.setTemplateParam(data);
//請(qǐng)求失敗這里會(huì)拋ClientException異常
SendSmsResponse sendSmsResponse = null;
try {
sendSmsResponse = acsClient.getAcsResponse(request);
} catch (ClientException e) {
throw new RpcInvokeException("acsClient.getAcsResponse-----" + request, e);
}
String responseOk = "OK";
if (sendSmsResponse.getCode() == null || !responseOk.equals(sendSmsResponse.getCode())) {
//請(qǐng)求成功
throw new SmsBusinessException(SmsExceptionCodeEnum.EX_HTTP_INVOKE_ERROR.getCode(), FastJsonUtil.of("sendSmsResponse", sendSmsResponse));
}
} catch (BusinessBaseException e) {
LogUtils.logInfoBusinessErrorService(log, "sendCode", e);
resultVo = ResultFactory.failure(e.getCode(), e.getMsg());
}
return resultVo;
}
短信模板類:
public enum SmsCodeModelEnum {
VERIFICATION_MODEL("SMS_********","********通驗(yàn)證碼模版"),
SERVER_ALARM_MODEL("SMS_********","服務(wù)器監(jiān)控報(bào)警模板"),
BASE_VERIFICATION_MODEL("SMS_********","驗(yàn)證碼模版"),
IDENTITY_MODEL("SMS_1********","身份驗(yàn)證模版"),
LOGIN_CONFIRMATION("SMS_********","登錄確認(rèn)模版"),
USER_REGISTER("SMS_********","用戶注冊(cè)模版"),
;
private String code;
private String description;
SmsCodeModelEnum(String code, String description) {
this.code = code;
this.description = description;
}
public String getCode() {
return code;
}
public void setCode(String code) {
this.code = code;
}
public String getDescription() {
return description;
}
public void setDescription(String description) {
this.description = description;
}
public static SmsCodeModelEnum eval(String code) {
for (SmsCodeModelEnum type : SmsCodeModelEnum.values()) {
if (type.getCode().equals(code)) {
return type;
}
}
return null;
}
public static boolean contains(String code) {
for (SmsCodeModelEnum type : SmsCodeModelEnum.values()) {
if (type.getCode().equals(code)) {
return true;
}
}
return false;
}
}