• 全网最详细SpringBoot、SpringCloud整合阿里云短信服务

    1、进入阿里云官网

    https://www.aliyun.com/

    2、搜索短信服务 

    3、进入短信控制台

    4、选择国内消息

    5、点击添加签名

    6、输入相关信息，点击提交

    7、点击模块管理，选择添加模块

    8、输入相关信息，点击提交

     

    9、鼠标放在头像上，点击下拉框中的AccessKey管理

    10、点击创建AccessKey

    11、输入验证码

    12、创建成功，两串字符串复制一下

    13、pom.xml中引入阿里云相关依赖，还有redis的依赖

    1. <dependency>
    2.     <groupId>com.aliyungroupId>
    3.     <artifactId>aliyun-java-sdk-coreartifactId>
    4.     <version>4.5.16version>
    5. dependency>
    6.  
    7. <dependency>
    8.     <groupId>org.springframework.bootgroupId>
    9.     <artifactId>spring-boot-starter-data-redisartifactId>
    10. dependency>

    14、配置application.properties（不是微服务项目就不要加nacos了）

    1. # 服务端口
    2. server.port=8204
    3. # 服务名
    4. spring.application.name=service-msm
    5.  
    6. #返回json的全局时间格式
    7. spring.jackson.date-format=yyyy-MM-dd HH:mm:ss
    8. spring.jackson.time-zone=GMT+8
    9.  
    10. # redis配置
    11. spring.redis.host=192.168.44.165
    12. spring.redis.port=6379
    13. spring.redis.database= 0
    14. spring.redis.timeout=1800000
    15. spring.redis.lettuce.pool.max-active=20
    16. spring.redis.lettuce.pool.max-wait=-1
    17. # 最大阻塞等待时间(负数表示没限制)
    18. spring.redis.lettuce.pool.max-idle=5
    19. spring.redis.lettuce.pool.min-idle=0
    20.  
    21. # nacos服务地址
    22. spring.cloud.nacos.discovery.server-addr=127.0.0.1:8848
    23.  
    24. aliyun.sms.regionId=default
    25. # 第12步复制的两串字符串
    26. aliyun.sms.accessKeyId=LT6I0Y5633pX89qC
    27. aliyun.sms.secret=jX8D04Dm12I3gGKj345FYSzu0fq8mT

    15、添加启动类

    1. //取消数据源自动配置，因为application.properties配置文件中没有配置数据库
    2. //如果application.properties配置文件中配置了数据库，“(exclude = DataSourceAutoConfiguration.class)”就不用加了
    3. @SpringBootApplication(exclude = DataSourceAutoConfiguration.class)
    4. @EnableDiscoveryClient
    5. public class ServiceMsmApplication {
    6.    public static void main(String[] args) {
    7.       SpringApplication.run(ServiceMsmApplication.class, args);
    8.    }
    9. }

    16、配置网关（不是微服务项目就不用写这一步）

    1. spring.cloud.gateway.routes[3].id=service-msm
    2. #设置路由的uri
    3. spring.cloud.gateway.routes[3].uri=lb://service-msm
    4. #设置路由断言,代理servicerId为auth-service的/auth/路径
    5. spring.cloud.gateway.routes[3].predicates= Path=/*/msm/**

    17、添加阿里云短信服务配置类

    1. import org.springframework.beans.factory.InitializingBean;
    2. import org.springframework.beans.factory.annotation.Value;
    3. import org.springframework.stereotype.Component;
    4.  
    5. @Component
    6. public class ConstantPropertiesUtils implements InitializingBean {
    7.  
    8.     //对应application.properties配置文件中的aliyun.sms.regionId=default
    9.     @Value("${aliyun.sms.regionId}")
    10.     private String regionId;
    11.  
    12.     //对应application.properties配置文件中的aliyun.sms.accessKeyId=LT6I0Y5633pX89qC
    13.     @Value("${aliyun.sms.accessKeyId}")
    14.     private String accessKeyId;
    15.  
    16.     //对应application.properties配置文件中的aliyun.sms.secret=jX8D04Dm12I3gGKj345FYSzu0fq8mT
    17.     @Value("${aliyun.sms.secret}")
    18.     private String secret;
    19.  
    20.     public static String REGION_Id;
    21.     public static String ACCESS_KEY_ID;
    22.     public static String SECRECT;
    23.  
    24.     @Override
    25.     public void afterPropertiesSet() throws Exception {
    26.         REGION_Id=regionId;
    27.         ACCESS_KEY_ID=accessKeyId;
    28.         SECRECT=secret;
    29.     }
    30. }

    18、添加redis配置类（如果项目中redis已经有配置类了，就不用再添加了）

    1. import com.fasterxml.jackson.annotation.JsonAutoDetect;
    2. import com.fasterxml.jackson.annotation.PropertyAccessor;
    3. import com.fasterxml.jackson.databind.ObjectMapper;
    4. import org.springframework.cache.CacheManager;
    5. import org.springframework.cache.annotation.EnableCaching;
    6. import org.springframework.cache.interceptor.KeyGenerator;
    7. import org.springframework.context.annotation.Bean;
    8. import org.springframework.context.annotation.Configuration;
    9. import org.springframework.data.redis.cache.RedisCacheConfiguration;
    10. import org.springframework.data.redis.cache.RedisCacheManager;
    11. import org.springframework.data.redis.connection.RedisConnectionFactory;
    12. import org.springframework.data.redis.core.RedisTemplate;
    13. import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;
    14. import org.springframework.data.redis.serializer.RedisSerializationContext;
    15. import org.springframework.data.redis.serializer.RedisSerializer;
    16. import org.springframework.data.redis.serializer.StringRedisSerializer;
    17.  
    18. import java.lang.reflect.Method;
    19. import java.time.Duration;
    20.  
    21. @Configuration
    22. @EnableCaching
    23. public class RedisConfig {
    24.  
    25.     /**
    26.      * 自定义key规则
    27.      * @return
    28.      */
    29.     @Bean
    30.     public KeyGenerator keyGenerator() {
    31.         return new KeyGenerator() {
    32.             @Override
    33.             public Object generate(Object target, Method method, Object... params) {
    34.                 StringBuilder sb = new StringBuilder();
    35.                 sb.append(target.getClass().getName());
    36.                 sb.append(method.getName());
    37.                 for (Object obj : params) {
    38.                     sb.append(obj.toString());
    39.                 }
    40.                 return sb.toString();
    41.             }
    42.         };
    43.     }
    44.  
    45.     /**
    46.      * 设置RedisTemplate规则
    47.      * @param redisConnectionFactory
    48.      * @return
    49.      */
    50.     @Bean
    51.     public RedisTemplate redisTemplate(RedisConnectionFactory redisConnectionFactory) {
    52.         RedisTemplate redisTemplate = new RedisTemplate<>();
    53.         redisTemplate.setConnectionFactory(redisConnectionFactory);
    54.         Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);
    55.  
    56.         //解决查询缓存转换异常的问题
    57.         ObjectMapper om = new ObjectMapper();
    58.         // 指定要序列化的域，field,get和set,以及修饰符范围，ANY是都有包括private和public
    59.         om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
    60.         // 指定序列化输入的类型，类必须是非final修饰的，final修饰的类，比如String,Integer等会跑出异常
    61.         om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
    62.         jackson2JsonRedisSerializer.setObjectMapper(om);
    63.  
    64.         //序列号key value
    65.         redisTemplate.setKeySerializer(new StringRedisSerializer());
    66.         redisTemplate.setValueSerializer(jackson2JsonRedisSerializer);
    67.         redisTemplate.setHashKeySerializer(new StringRedisSerializer());
    68.         redisTemplate.setHashValueSerializer(jackson2JsonRedisSerializer);
    69.  
    70.         redisTemplate.afterPropertiesSet();
    71.         return redisTemplate;
    72.     }
    73.  
    74.     /**
    75.      * 设置CacheManager缓存规则
    76.      * @param factory
    77.      * @return
    78.      */
    79.     @Bean
    80.     public CacheManager cacheManager(RedisConnectionFactory factory) {
    81.         RedisSerializer redisSerializer = new StringRedisSerializer();
    82.         Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);
    83.  
    84.         //解决查询缓存转换异常的问题
    85.         ObjectMapper om = new ObjectMapper();
    86.         om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
    87.         om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
    88.         jackson2JsonRedisSerializer.setObjectMapper(om);
    89.  
    90.         // 配置序列化（解决乱码的问题）,过期时间600秒
    91.         RedisCacheConfiguration config = RedisCacheConfiguration.defaultCacheConfig()
    92.                 .entryTtl(Duration.ofSeconds(600))
    93.                 .serializeKeysWith(RedisSerializationContext.SerializationPair.fromSerializer(redisSerializer))
    94.                 .serializeValuesWith(RedisSerializationContext.SerializationPair.fromSerializer(jackson2JsonRedisSerializer))
    95.                 .disableCachingNullValues();
    96.  
    97.         RedisCacheManager cacheManager = RedisCacheManager.builder(factory)
    98.                 .cacheDefaults(config)
    99.                 .build();
    100.         return cacheManager;
    101.     }
    102. }

    19、添加验证码自动生成工具类

    1. import java.text.DecimalFormat;
    2. import java.util.ArrayList;
    3. import java.util.HashMap;
    4. import java.util.List;
    5. import java.util.Random;
    6.  
    7. public class RandomUtil {
    8.  
    9.     private static final Random random = new Random();
    10.  
    11.     private static final DecimalFormat fourdf = new DecimalFormat("0000");
    12.  
    13.     private static final DecimalFormat sixdf = new DecimalFormat("000000");
    14.  
    15.     public static String getFourBitRandom() {
    16.         return fourdf.format(random.nextInt(10000));
    17.     }
    18.  
    19.     public static String getSixBitRandom() {
    20.         return sixdf.format(random.nextInt(1000000));
    21.     }
    22.  
    23.     /**
    24.      * 给定数组，抽取n个数据
    25.      * @param list
    26.      * @param n
    27.      * @return
    28.      */
    29.     public static ArrayList getRandom(List list, int n) {
    30.  
    31.         Random random = new Random();
    32.  
    33.         HashMap hashMap = new HashMap();
    34.  
    35.         // 生成随机数字并存入HashMap
    36.         for (int i = 0; i < list.size(); i++) {
    37.  
    38.             int number = random.nextInt(100) + 1;
    39.  
    40.             hashMap.put(number, i);
    41.         }
    42.  
    43.         // 从HashMap导入数组
    44.         Object[] robjs = hashMap.values().toArray();
    45.  
    46.         ArrayList r = new ArrayList();
    47.  
    48.         // 遍历数组并打印数据
    49.         for (int i = 0; i < n; i++) {
    50.             r.add(list.get((int) robjs[i]));
    51.             System.out.print(list.get((int) robjs[i]) + "\t");
    52.         }
    53.         System.out.print("\n");
    54.         return r;
    55.     }
    56. }

    20、开发阿里云发送短信接口

    20.1、Controller层：

    1. import com.hospital.common.result.Result;
    2. import com.hospital.msm.service.MsmService;
    3. import com.hospital.msm.utils.RandomUtil;
    4. import org.apache.commons.lang.StringUtils;
    5. import org.springframework.beans.factory.annotation.Autowired;
    6. import org.springframework.data.redis.core.RedisTemplate;
    7. import org.springframework.web.bind.annotation.GetMapping;
    8. import org.springframework.web.bind.annotation.PathVariable;
    9. import org.springframework.web.bind.annotation.RequestMapping;
    10. import org.springframework.web.bind.annotation.RestController;
    11.  
    12. import java.util.concurrent.TimeUnit;
    13.  
    14. @RestController
    15. @RequestMapping("/api/msm")
    16. public class MsmApiController {
    17.  
    18.     @Autowired
    19.     private MsmService msmService;
    20.  
    21.     @Autowired
    22.     private RedisTemplate redisTemplate;
    23.  
    24.     /**
    25.      * 发送手机验证码
    26.      * @param phone
    27.      * @return
    28.      */
    29.     @GetMapping("/send/{phone}")
    30.     public Result sendCode(@PathVariable String phone){
    31.         //从redis中获取验证码，如果获取到，返回ok
    32.         //key：手机号，value：验证码
    33.         String code = redisTemplate.opsForValue().get(phone);
    34.         if (!StringUtils.isEmpty(code)){
    35.             return Result.ok();
    36.         }
    37.  
    38.         //如果从redis中获取不到，就自己生成验证码
    39.         code = RandomUtil.getSixBitRandom();
    40.  
    41.         //通过调用service方法，整合阿里云短信服务进行发送
    42.         boolean isSend = msmService.send(phone,code);
    43.  
    44.         //如果阿里云短信服务发送成功就给isSend返回为true
    45.         //然后把生成的验证码放到redis里面，并设置过期时间
    46.         if(isSend){
    47.             //超过两分钟，验证码就失效了
    48.             redisTemplate.opsForValue().set(phone,code,2, TimeUnit.MINUTES);
    49.             return Result.ok();
    50.         }else {
    51.             return Result.fail().message("发送短信失败！！！");
    52.         }
    53.     }
    54. }

    20.2、Service层：

    1. public interface MsmService {
    2.     //阿里云短信服务发送手机验证码
    3.     boolean send(String phone, String code);
    4. }

    20.3、Service实现层：

    1. import com.alibaba.fastjson.JSONObject;
    2. import com.aliyuncs.CommonRequest;
    3. import com.aliyuncs.CommonResponse;
    4. import com.aliyuncs.DefaultAcsClient;
    5. import com.aliyuncs.IAcsClient;
    6. import com.aliyuncs.exceptions.ClientException;
    7. import com.aliyuncs.exceptions.ServerException;
    8. import com.aliyuncs.http.MethodType;
    9. import com.aliyuncs.profile.DefaultProfile;
    10. import com.hospital.msm.service.MsmService;
    11. import com.hospital.msm.utils.ConstantPropertiesUtils;
    12. import org.apache.commons.lang.StringUtils;
    13. import org.springframework.stereotype.Service;
    14.  
    15. import java.util.HashMap;
    16. import java.util.Map;
    17.  
    18. @Service
    19. public class MsmServiceImpl implements MsmService {
    20.  
    21.     /**
    22.      * 阿里云短信服务发送手机验证码
    23.      * @param phone
    24.      * @param code
    25.      * @return
    26.      */
    27.     @Override
    28.     public boolean send(String phone, String code) {
    29.         //判断手机号是否为空
    30.         if (StringUtils.isEmpty(phone)){
    31.             return false;
    32.         }
    33.  
    34.         //传入ConstantPropertiesUtils配置类中从application.properties配置文件中获取的三个值
    35.         DefaultProfile profile = DefaultProfile.
    36.                 getProfile(ConstantPropertiesUtils.REGION_Id,
    37.                         ConstantPropertiesUtils.ACCESS_KEY_ID,
    38.                         ConstantPropertiesUtils.SECRECT);
    39.         IAcsClient client = new DefaultAcsClient(profile);
    40.         CommonRequest request = new CommonRequest();
    41.         //request.setProtocol(ProtocolType.HTTPS);  //发送的协议如果是https就不注释
    42.         request.setMethod(MethodType.POST); //这一行是固定的
    43.         request.setDomain("dysmsapi.aliyuncs.com"); //这一行是固定的
    44.         request.setVersion("2017-05-25");   //这一行是固定的
    45.         request.setAction("SendSms");   //这一行是固定的
    46.  
    47.         //手机号
    48.         request.putQueryParameter("PhoneNumbers", phone);
    49.         //签名名称
    50.         request.putQueryParameter("SignName", "我的谷粒在线教育网站");
    51.         //模板code
    52.         request.putQueryParameter("TemplateCode", "SMS_257677932");
    53.         //验证码  使用json格式   {"code":"123456"}
    54.         Map param = new HashMap();
    55.         param.put("code",code);
    56.         request.putQueryParameter("TemplateParam", JSONObject.toJSONString(param));
    57.  
    58.         //调用方法进行短信发送
    59.         try {
    60.             CommonResponse response = client.getCommonResponse(request);
    61.             System.out.println(response.getData());
    62.             return response.getHttpResponse().isSuccess();
    63.         } catch (ServerException e) {
    64.             e.printStackTrace();
    65.         } catch (ClientException e) {
    66.             e.printStackTrace();
    67.         }
    68.  
    69.         //失败就返回false
    70.         return false;
    71.     }
    72. }

    21、登录接口判断用户输入的验证码和阿里云服务发送的验证码是否相同

  • 相关阅读:
    【论文笔记】An Image Patch is a Wave: Phase-Aware Vision MLP
    MySQL 学习笔记②
    Go语言的100个错误使用场景（30-40）｜数据类型与字符串使用
    RunApi在发送请求的时候添加Token
    服务器动态/静态/住宅/原生IP都是什么意思
    2023秋招大厂经典面试题及答案整理归纳（341-360）校招必看【Linux篇】
    js数据过滤算法搭建
    现货白银的价格如何变动
    如何进行列间排序
    Bias and Debias in Recommender System: A Survey and Future Directions学习笔记
  • 原文地址：https://blog.csdn.net/weixin_55076626/article/details/127853987