阿里云短信认证-蒲公英云

阿里云短信认证

在这里插入图片描述
依赖

<dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>fastjson</artifactId>
            <version>1.2.62</version>
        </dependency>
        <dependency>
            <groupId>com.aliyun</groupId>
            <artifactId>aliyun-java-sdk-core</artifactId>
            <version>4.5.8</version>
        </dependency>

配置文件

server.port=2525
spring.application.name=msgsend
spring.cloud.nacos.server-addr=localhost:8848
spring.cloud.nacos.discovery.server-addr=${spring.cloud.nacos.server-addr}
management.endpoints.web.exposure.include=*
spring.cloud.sentinel.enabled=true
spring.cloud.sentinel.transport.dashboard=localhost:9817
spring.cloud.sentinel.transport.port=8719
#Redis
# Redis数据库索引（默认为0）
spring.redis.database=0
spring.redis.host=（主机）
## Redis服务器连接端口
spring.redis.port=（端口）
## 连接超时时间（毫秒）
spring.redis.timeout=500
## Redis服务器连接密码（默认为空）
spring.redis.password=（密码）
## 连接池中的最大连接数
spring.redis.poolMaxTotal=10
## 连接池中的最大空闲连接
spring.redis.poolMaxIdle=10
## 连接池最大阻塞等待时间（使用负值表示没有限制）
spring.redis.poolMaxWait=3

service

public interface MsgSendService {
    Boolean sendMsg(Map<String,Object> param,String phone);
}

impl
需要自己准备：
accessKeyId accessKeySecret 阿里云签名名称申请阿里云模板code

@Service
public class MsgSendServiceImpl implements MsgSendService {
    @Override
    public Boolean sendMsg(Map<String, Object> param, String phone) {
        if(StringUtils.isEmpty(phone)) return false;
        DefaultProfile profile =
                DefaultProfile.getProfile("default", "accessKeyId（自己的）", "accessKeySecret（自己的）");
        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","阿里云 签名名称"); //申请阿里云 签名名称
        request.putQueryParameter("TemplateCode","申请阿里云 模板code"); //申请阿里云 模板code
        request.putQueryParameter("TemplateParam", JSONObject.toJSONString(param)); //验证码数据，转换json数据传递
        try {
            //最终发送
            CommonResponse response = client.getCommonResponse(request);
            boolean success = response.getHttpResponse().isSuccess();
            return success;
        }catch(Exception e) {
            e.printStackTrace();
            return false;
        }
    }
}

然后是controller：
因为验证码是有时效的，所以用redis存储，这里给5分钟，先看redis里面有无验证码，有就成功，没有就发送验证码

@RestController
@Slf4j
@CrossOrigin
public class MsgSendController {
    @Autowired
    private MsgSendService msgSendService;
    @Autowired
    private RedisTemplate<String,String> redisTemplate;
    @GetMapping("/sendMsg/{phone}")
    public ResultMsg sendMsg(@PathVariable String phone){
        //从redis中获取是否含有验证码，key用手机号
        String ranCode = redisTemplate.opsForValue().get(phone);
        if (!StringUtils.isEmpty(ranCode)){
            ResultMsg.successMsg();
        }
        //如果获取不到就进行阿里云发送
        String code= RandomUtil.getFourBitRandom();
        Map<String,Object> codMap=new HashMap<>();
        codMap.put("code",code);
        //这里调用service发送短信方法
        Boolean isSend=msgSendService.sendMsg(codMap,phone);
        if(isSend){
            //这里如果发送成功，验证码就存进redis中
            redisTemplate.opsForValue().set(phone,code,5, TimeUnit.MINUTES);
            return ResultMsg.successMsg();
        }else {
            return ResultMsg.failMsg().message("短信发送失败");
        }
    }
}