From eb2fe760867ca77d07489f5fbf98526f3be649bd Mon Sep 17 00:00:00 2001
From: interface_xiongtete <1144722582@qq.com>
Date: Thu, 6 Jan 2022 19:08:53 +0800
Subject: [PATCH] =?UTF-8?q?=E8=85=BE=E8=AE=AF=E4=BA=91=E7=9F=AD=E4=BF=A1?=
=?UTF-8?q?=E6=9C=8D=E5=8A=A1=E5=8F=91=E9=80=81=E9=AA=8C=E8=AF=81=E7=A0=81?=
=?UTF-8?q?=20=E9=98=BF=E9=87=8C=E4=BA=91=E7=9F=AD=E4=BF=A1=E7=AD=BE?=
=?UTF-8?q?=E5=90=8D=E7=94=B3=E8=AF=B7=E5=A4=B1=E8=B4=A5?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
service/service_msm/pom.xml | 9 +
.../yygh/msm/ServiceMsmApplication.java | 2 +
.../yygh/msm/controller/MsmApiController.java | 29 ++-
.../atguigu/yygh/msm/service/MsmService.java | 5 +
.../yygh/msm/service/impl/MsmServiceImpl.java | 177 ++++++++++++++++++
.../com/atguigu/yygh/msm/utils/Constants.java | 21 +++
.../atguigu/yygh/msm/utils/RandomUtil.java | 59 ++++++
.../src/main/resources/application.properties | 6 +-
8 files changed, 304 insertions(+), 4 deletions(-)
create mode 100644 service/service_msm/src/main/java/com/atguigu/yygh/msm/utils/Constants.java
create mode 100644 service/service_msm/src/main/java/com/atguigu/yygh/msm/utils/RandomUtil.java
diff --git a/service/service_msm/pom.xml b/service/service_msm/pom.xml
index d3dc51f..a3f4144 100644
--- a/service/service_msm/pom.xml
+++ b/service/service_msm/pom.xml
@@ -16,6 +16,15 @@
aliyun-java-sdk-core
+
+
+
+ com.tencentcloudapi
+ tencentcloud-sdk-java
+ 3.1.395
+
+
+
\ No newline at end of file
diff --git a/service/service_msm/src/main/java/com/atguigu/yygh/msm/ServiceMsmApplication.java b/service/service_msm/src/main/java/com/atguigu/yygh/msm/ServiceMsmApplication.java
index f00db0d..47aba2e 100644
--- a/service/service_msm/src/main/java/com/atguigu/yygh/msm/ServiceMsmApplication.java
+++ b/service/service_msm/src/main/java/com/atguigu/yygh/msm/ServiceMsmApplication.java
@@ -4,9 +4,11 @@ import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
+import org.springframework.context.annotation.ComponentScan;
@SpringBootApplication(exclude = DataSourceAutoConfiguration.class)//取消数据源自动配置
@EnableDiscoveryClient
+@ComponentScan(basePackages = {"com.atguigu"})
public class ServiceMsmApplication {
public static void main(String[] args) {
SpringApplication.run(ServiceMsmApplication.class, args);
diff --git a/service/service_msm/src/main/java/com/atguigu/yygh/msm/controller/MsmApiController.java b/service/service_msm/src/main/java/com/atguigu/yygh/msm/controller/MsmApiController.java
index ba3c3fd..1682e1a 100644
--- a/service/service_msm/src/main/java/com/atguigu/yygh/msm/controller/MsmApiController.java
+++ b/service/service_msm/src/main/java/com/atguigu/yygh/msm/controller/MsmApiController.java
@@ -1,13 +1,20 @@
package com.atguigu.yygh.msm.controller;
import com.atguigu.yygh.msm.service.MsmService;
+import com.atguigu.yygh.msm.utils.RandomUtil;
import com.atguigu.yygu.common.result.Result;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.util.StringUtils;
import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
+
+import java.util.concurrent.TimeUnit;
+
@Api(tags = "短信发送控制器")
@RestController
@RequestMapping("/api/msm")
@@ -16,10 +23,30 @@ public class MsmApiController {
@Autowired
private MsmService msmService;
+ @Autowired
+ private RedisTemplate redisTemplate;
+
//发送手机验证码
@ApiOperation(value = "发送手机验证码")
@GetMapping("send/{phone}")
- public Result sendCode(){
+ public Result sendCode(@PathVariable String phone){
+ //从redis获取验证码，如果可以获取到，返回ok
+ //key：手机号 value:验证码
+ String code = (String) redisTemplate.opsForValue().get(phone);
+ if(!StringUtils.isEmpty(code)){
+ return Result.ok();
+ }
+ //如果从redis获取不到，生成验证码
+ code= RandomUtil.getSixBitRandom();
+// boolean isSend=msmService.send(phone,code) //通过整合阿里云短信服务进行发送，调用service方法
+ boolean isSend=msmService.sendTencent(phone,code); //腾讯云发送
+ //生成验证码放到redis里面，设置有效时间
+ if(isSend){
+ redisTemplate.opsForValue().set(phone,code,5, TimeUnit.MINUTES);
+ return Result.ok();
+ }else{
+ return Result.fail().message("发送短信失败");
+ }
}
diff --git a/service/service_msm/src/main/java/com/atguigu/yygh/msm/service/MsmService.java b/service/service_msm/src/main/java/com/atguigu/yygh/msm/service/MsmService.java
index 38e0cc0..d37df60 100644
--- a/service/service_msm/src/main/java/com/atguigu/yygh/msm/service/MsmService.java
+++ b/service/service_msm/src/main/java/com/atguigu/yygh/msm/service/MsmService.java
@@ -1,4 +1,9 @@
package com.atguigu.yygh.msm.service;
public interface MsmService {
+ //阿里云发送手机验证码
+ boolean send(String phone, String code);
+
+ //腾讯云发送手机验证码
+ boolean sendTencent(String phone, String code);
}
diff --git a/service/service_msm/src/main/java/com/atguigu/yygh/msm/service/impl/MsmServiceImpl.java b/service/service_msm/src/main/java/com/atguigu/yygh/msm/service/impl/MsmServiceImpl.java
index 9c13a91..3d22392 100644
--- a/service/service_msm/src/main/java/com/atguigu/yygh/msm/service/impl/MsmServiceImpl.java
+++ b/service/service_msm/src/main/java/com/atguigu/yygh/msm/service/impl/MsmServiceImpl.java
@@ -1,8 +1,185 @@
package com.atguigu.yygh.msm.service.impl;
+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.yygh.msm.service.MsmService;
+import com.atguigu.yygh.msm.utils.ConstantPropertiesUtils;
+import com.atguigu.yygh.msm.utils.Constants;
+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.v20190711.SmsClient;
+import com.tencentcloudapi.sms.v20190711.models.SendSmsRequest;
+import com.tencentcloudapi.sms.v20190711.models.SendSmsResponse;
+import com.tencentcloudapi.sms.v20190711.models.SendStatus;
import org.springframework.stereotype.Service;
+import org.springframework.util.StringUtils;
+
+import java.util.HashMap;
+import java.util.Map;
@Service
public class MsmServiceImpl implements MsmService {
+ //发送手机验证码
+ @Override
+ public boolean send(String phone, String code) {
+ //判断手机号是否为空
+ if(StringUtils.isEmpty(phone)){
+ return false;
+ }
+ //整合阿里云短信服务
+ //设置相关参数
+ DefaultProfile profile = DefaultProfile.
+ getProfile(ConstantPropertiesUtils.REGION_Id,
+ ConstantPropertiesUtils.ACCESS_KEY_ID,
+ ConstantPropertiesUtils.SECRECT);
+ 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");
+
+ //手机号
+ request.putQueryParameter("PhoneNumbers", phone);
+ //签名名称
+ request.putQueryParameter("SignName", "我的谷粒在线教育网站");
+ //模板code
+ request.putQueryParameter("TemplateCode", "SMS_180051135");
+ //验证码 使用json格式 {"code":"123456"}
+ Map param = new HashMap();
+ param.put("code",code);
+ 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;
+ }
+
+ //腾讯云发送手机验证码
+ @Override
+ public boolean sendTencent(String phone, String code) {
+ //判断手机号是否为空
+ if(StringUtils.isEmpty(phone)) return false;
+
+ SendStatus[] returString= {};
+ try {
+ /* 必要步骤：
+ * 实例化一个认证对象，入参需要传入腾讯云账户密钥对secretId，secretKey。
+ * 这里采用的是从环境变量读取的方式，需要在环境变量中先设置这两个值。
+ * 你也可以直接在代码中写死密钥对，但是小心不要将代码复制、上传或者分享给他人，
+ * 以免泄露密钥对危及你的财产安全。
+ * CAM密匙查询: https://console.cloud.tencent.com/cam/capi*/
+ Credential cred = new Credential(Constants.SecretID, Constants.SecretKey);
+
+ // 实例化一个http选项，可选，没有特殊需求可以跳过
+ HttpProfile httpProfile = new HttpProfile();
+
+ // 设置代理
+// httpProfile.setProxyHost("host");
+// httpProfile.setProxyPort(port);
+ /* SDK默认使用POST方法。
+ * 如果你一定要使用GET方法，可以在这里设置。GET方法无法处理一些较大的请求 */
+ httpProfile.setReqMethod("POST");
+ /* SDK有默认的超时时间，非必要请不要进行调整
+ * 如有需要请在代码中查阅以获取最新的默认值 */
+ httpProfile.setConnTimeout(60);
+ /* SDK会自动指定域名。通常是不需要特地指定域名的，但是如果你访问的是金融区的服务
+ * 则必须手动指定域名，例如sms的上海金融区域名： sms.ap-shanghai-fsi.tencentcloudapi.com */
+ httpProfile.setEndpoint("sms.tencentcloudapi.com");
+
+ /* 非必要步骤:
+ * 实例化一个客户端配置对象，可以指定超时时间等配置 */
+ ClientProfile clientProfile = new ClientProfile();
+ /* SDK默认用TC3-HMAC-SHA256进行签名
+ * 非必要请不要修改这个字段 */
+ clientProfile.setSignMethod("HmacSHA256");
+ clientProfile.setHttpProfile(httpProfile);
+ /* 实例化要请求产品(以sms为例)的client对象
+ * 第二个参数是地域信息，可以直接填写字符串ap-guangzhou，或者引用预设的常量 */
+ SmsClient client = new SmsClient(cred, "ap-guangzhou", clientProfile);
+ /* 实例化一个请求对象，根据调用的接口和实际情况，可以进一步设置请求参数
+ * 你可以直接查询SDK源码确定接口有哪些属性可以设置
+ * 属性可能是基本类型，也可能引用了另一个数据结构
+ * 推荐使用IDE进行开发，可以方便的跳转查阅各个接口和数据结构的文档说明 */
+ SendSmsRequest req = new SendSmsRequest();
+
+ /* 填充请求参数,这里request对象的成员变量即对应接口的入参
+ * 你可以通过官网接口文档或跳转到request对象的定义处查看请求参数的定义
+ * 基本类型的设置:
+ * 帮助链接：
+ * 短信控制台: https://console.cloud.tencent.com/sms/smslist
+ * sms helper: https://cloud.tencent.com/document/product/382/3773 */
+
+ /* 短信应用ID: 短信SdkAppid在 [短信控制台] 添加应用后生成的实际SdkAppid，示例如1400006666 */
+ String sdkappid = Constants.SdkAppid;
+ req.setSmsSdkAppid(sdkappid);
+
+ /* 短信签名内容: 使用 UTF-8 编码，必须填写已审核通过的签名，签名信息可登录 [短信控制台] 查看 */
+ String sign = Constants.signName;
+ req.setSign(sign);
+
+ /* 国际/港澳台短信 senderid: 国内短信填空，默认未开通，如需开通请联系 [sms helper] */
+// String senderid = "";
+// req.setSenderId(senderid);
+
+ /* 用户的 session 内容: 可以携带用户侧 ID 等上下文信息，server 会原样返回 */
+// String session = "xxx";
+// req.setSessionContext(session);
+
+ /* 短信码号扩展号: 默认未开通，如需开通请联系 [sms helper] */
+// String extendcode = "xxx";
+// req.setExtendCode(extendcode);
+
+ /* 模板 ID: 必须填写已审核通过的模板 ID。模板ID可登录 [短信控制台] 查看 */
+ String templateID = Constants.templateId;
+ req.setTemplateID(templateID);
+
+ /* 下发手机号码，采用 e.164 标准，+[国家或地区码][手机号]
+ * 示例如：+8613711112222， 其中前面有一个+号 ，86为国家码，13711112222为手机号，最多不要超过200个手机号*/
+ String[] phoneNumbers = {"+86"+phone};
+ req.setPhoneNumberSet(phoneNumbers);
+
+
+ /* 模板参数: 若无模板参数，则设置为空*/
+ String[] templateParams = {code,"5".toString()};
+ req.setTemplateParamSet(templateParams);
+
+ /* 通过 client 对象调用 SendSms 方法发起请求。注意请求方法名与请求对象是对应的
+ * 返回的 res 是一个 SendSmsResponse 类的实例，与请求对象对应 */
+ SendSmsResponse res = client.SendSms(req);
+
+ // 输出json格式的字符串回包
+// System.out.println(SendSmsResponse.toJsonString(res));
+ // 也可以取出单个值，你可以通过官网接口文档或跳转到response对象的定义处查看返回字段的定义
+// System.out.println(res.getRequestId());
+ returString=res.getSendStatusSet();
+ if(!StringUtils.isEmpty(returString)){
+ return true;
+ }else{
+ return false;
+ }
+
+ } catch (TencentCloudSDKException e) {
+ e.printStackTrace();
+ return false;
+ }
+ }
}
diff --git a/service/service_msm/src/main/java/com/atguigu/yygh/msm/utils/Constants.java b/service/service_msm/src/main/java/com/atguigu/yygh/msm/utils/Constants.java
new file mode 100644
index 0000000..cb5704f
--- /dev/null
+++ b/service/service_msm/src/main/java/com/atguigu/yygh/msm/utils/Constants.java
@@ -0,0 +1,21 @@
+package com.atguigu.yygh.msm.utils;
+
+/**
+* 腾讯云短信服务参数的常量类
+*/
+public class Constants {
+
+ //腾讯云账户密钥对: SecretID
+ public static final String SecretID = "AKIDAC3ey1nIWT9YhY8RVIo42kBLDp9CyUif";
+ //腾讯云账户密钥对: SecretKey
+ public static final String SecretKey = "h7G8j36sNbYEdka9RRAcnNgiTxA5k7D2";
+ //SdkAppid
+ public static final String SdkAppid = "1400597291";
+ //signName :签名
+ public static final String signName = "全栈开发那些事公众号";
+ //短信模板id:
+ public static final String templateId ="1200980";
+
+ public static String voicode="";
+}
+
diff --git a/service/service_msm/src/main/java/com/atguigu/yygh/msm/utils/RandomUtil.java b/service/service_msm/src/main/java/com/atguigu/yygh/msm/utils/RandomUtil.java
new file mode 100644
index 0000000..6129070
--- /dev/null
+++ b/service/service_msm/src/main/java/com/atguigu/yygh/msm/utils/RandomUtil.java
@@ -0,0 +1,59 @@
+package com.atguigu.yygh.msm.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();
+
+ private static 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 hashMap = new HashMap();
+
+ // 生成随机数字并存入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;
+ }
+}
diff --git a/service/service_msm/src/main/resources/application.properties b/service/service_msm/src/main/resources/application.properties
index efbd823..c4f488f 100644
--- a/service/service_msm/src/main/resources/application.properties
+++ b/service/service_msm/src/main/resources/application.properties
@@ -7,7 +7,7 @@ spring.application.name=service-msm
spring.jackson.date-format=yyyy-MM-dd HH:mm:ss
spring.jackson.time-zone=GMT+8
-spring.redis.host=192.168.44.165
+spring.redis.host=192.168.159.33
spring.redis.port=6379
spring.redis.database= 0
spring.redis.timeout=1800000
@@ -21,5 +21,5 @@ spring.redis.lettuce.pool.min-idle=0
spring.cloud.nacos.discovery.server-addr=127.0.0.1:8848
aliyun.sms.regionId=default
-aliyun.sms.accessKeyId=LT6I0Y5633pX89qC
-aliyun.sms.secret=jX8D04Dm12I3gGKj345FYSzu0fq8mT
+aliyun.sms.accessKeyId=LTAI4G4SV6WtST7UYH776b64
+aliyun.sms.secret=X9KHNYgztNr9MI5Zp8JffQPZO4uJo5
--
GitLab