短信微服务

红太狼 2021-07-24 11:59 500阅读 0赞

# 一 点睛 #

短信+注册业务流程

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoZW5ncWl1bWluZw_size_16_color_FFFFFF_t_70][]

# 二 创建项目 #

## 1 创建模块 ##

service\_sms

## 2 配置pom.xml ##

<dependencies>
        
        <dependency>
            <groupId>com.aliyun</groupId>
            <artifactId>aliyun-java-sdk-core</artifactId>
        </dependency>
    </dependencies>

## 3 application.yml ##

server:
      port: 8150 # 服务端口
    
    spring:
      profiles:
        active: dev # 环境设置
      application:
        name: service-sms # 服务名
      cloud:
        nacos:
          discovery:
            server-addr: localhost:8848 # nacos服务地址
    #spring:
      redis:
        host: 127.0.0.1
        port: 6379
        database: 0
        password:
        lettuce:
          pool:
            max-active: 20  #最大连接数，负值表示没有限制，默认8
            max-wait: -1    #最大阻塞等待时间，负值表示没限制，默认-1
            max-idle: 8     #最大空闲连接，默认8
            min-idle: 0     #最小空闲连接，默认0
    
    #阿里云短信
    aliyun:
      sms:
        regionId: cn-hangzhou
        keyId: <你的keyId>
        keySecret: <你的keySecret>
        templateCode: SMS_96695065
        signName: 谷粒

## 4 为子账号添加授权 ##

AliyunDysmsFullAccess

## 5 日志配置文件 ##

logback-spring.xml

## 6 创建启动类 ##

/**
    * @className: ServiceSmsApplication
    * @description: 启动类
    * @date: 2020/12/24
    * @author: cakin
    */
    @SpringBootApplication(exclude = DataSourceAutoConfiguration.class)
    @ComponentScan({"com.atguigu.guli"})
    @EnableDiscoveryClient
    public class ServiceSmsApplication {
        public static void main(String[] args) {
            SpringApplication.run(ServiceSmsApplication.class, args);
        }
    }

# 三 配置和工具 #

## 1 从配置文件读取常量 ##

创建常量读取工具类：SmsProperties.java

/**
    * @className: SmsProperties
    * @description: 常量读取工具类
    * @date: 2020/12/24
    * @author: cakin
    */
    @Data
    @Component
    // 注意prefix要写到最后一个 "." 符号之前
    @ConfigurationProperties(prefix="aliyun.sms")
    public class SmsProperties {
        /**
         * regionId
         */
        private String regionId;
        /**
         * keyId
         */
        private String keyId;
        /**
         * keySecret
         */
        private String keySecret;
        /**
         * 模板
         */
        private String templateCode;
        /**
         * 签名
         */
        private String signName;
    }

## 2 引入工具类 ##

common-util中引入工具类：RandomUtils.java、FormUtils.java

RandomUtils.java

/**
    * @className: RandomUtils
    * @description: 获取随机数
    * @date: 2020/12/24
    * @author: cakin
    */
    public class RandomUtils {
    
       private static final Random random = new Random();
    
       private static final DecimalFormat fourdf = new DecimalFormat("0000");
    
       private static final DecimalFormat sixdf = new DecimalFormat("000000");
    
       /**
        * 功能描述：获取4位随机数
        *
        * @author cakin
        * @date 2020/12/24
        * @return String 4位随机数
        */
       public static String getFourBitRandom() {
          return fourdf.format(random.nextInt(10000));
       }
    
       /**
        * 功能描述：获取6位随机数
        *
        * @author cakin
        * @date 2020/12/24
        * @return String 6位随机数
        * @description:
        */
       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<Object, Object> hashMap = new HashMap<Object, Object>();
          // 生成随机数字并存入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;
       }
    }

FormUtils.java

/**
    * @className: FormUtils
    * @description: 字符串操作工具类
    * @date: 2020/12/24
    * @author: cakin
    */
    public class FormUtils {
        /**
         * 手机号验证
         */
        public static boolean isMobile(String str) {
            Pattern p = Pattern.compile("^[1][3,4,5,7,8,9][0-9]{9}$"); // 验证手机号
            Matcher m = p.matcher(str);
            return m.matches();
        }
    }

# 四 发送短信 #

1 控制器

@RestController
    @RequestMapping("/api/sms")
    @Api(description = "短信管理")
    @CrossOrigin // 跨域
    @Slf4j
    public class ApiSmsController {
        @Autowired
        private SmsService smsService;
    
        @Autowired
        private RedisTemplate redisTemplate;
    
        @GetMapping("send/{mobile}")
        public R getCode(@PathVariable String mobile) throws ClientException {
            // 校验手机号是否合法
            if (StringUtils.isEmpty(mobile) || !FormUtils.isMobile(mobile)) {
                log.error("手机号不正确");
                throw new GuliException(ResultCodeEnum.LOGIN_MOBILE_ERROR);
    //            return R.error().message("手机号不正确").code(28001);
            }
            // 生成验证码
            String checkCode = RandomUtils.getFourBitRandom();
            // 发送验证码
            smsService.send(mobile, checkCode);
            // 存储验证码到redis
            redisTemplate.opsForValue().set(mobile, checkCode, 5, TimeUnit.MINUTES);
            return R.ok().message("短信发送成功");
        }
    }

## 2 service ##

接口

/**
    * @className: SmsService
    * @description: 短信服务
    * @date: 2020/12/24
    * @author: cakin
    */
    public interface SmsService {
        void send(String mobile, String checkCode) throws ClientException;
    }

实现

@Service
    @Slf4j
    public class SmsServiceImpl implements SmsService {
        @Autowired
        private SmsProperties smsProperties;
    
    
        /**
         * 功能描述：发送短信
         *
         * @param mobile    手机号
         * @param checkCode 验证码
         * @author cakin
         * @date 2020/12/24
         */
        @Override
        public void send(String mobile, String checkCode) throws ClientException {
            // 创建配置对象
            DefaultProfile profile = DefaultProfile.getProfile(
                    smsProperties.getRegionId(),
                    smsProperties.getKeyId(),
                    smsProperties.getKeySecret());
            // 创建client对象
            IAcsClient client = new DefaultAcsClient(profile);
            // 创建参数对象
            CommonRequest request = new CommonRequest();
            // 组装参数对象
            request.setSysMethod(MethodType.POST);
            request.setSysDomain("dysmsapi.aliyuncs.com");
            request.setSysVersion("2017-05-25");
            request.setSysAction("SendSms");
            request.putQueryParameter("RegionId", smsProperties.getRegionId());
            request.putQueryParameter("PhoneNumbers", mobile);
            request.putQueryParameter("SignName", smsProperties.getSignName());
            request.putQueryParameter("TemplateCode", smsProperties.getTemplateCode());
            Map<String, String> param = new HashMap<>();
            param.put("code", checkCode);
            Gson gson = new Gson();
            String json = gson.toJson(param);
            request.putQueryParameter("TemplateParam", json);
            // 发送短信
            CommonResponse response = client.getCommonResponse(request);
    //      response.getHttpResponse().isSuccess()//注意：此处不能通过http的响应结果判断短信是否发送成功
            // 得到就送字符串格式的返回结果
            String data = response.getData();
            // 解析响应结果
            HashMap<String, String> map = gson.fromJson(data, HashMap.class);
            String code = map.get("Code");
            String message = map.get("Message");
            if ("isv.BUSINESS_LIMIT_CONTROL".equals(code)) {
                log.error("发送短信过于频繁：" + "code-" + code + ", message-" + message);
                throw new GuliException(ResultCodeEnum.SMS_SEND_ERROR_BUSINESS_LIMIT_CONTROL);
            }
            if (!"OK".equals(code)) {
                log.error("短信发送失败：" + "code-" + code + ", message-" + message);
                throw new GuliException(ResultCodeEnum.SMS_SEND_ERROR);
            }
        }
    }

# 五 测试 #

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoZW5ncWl1bWluZw_size_16_color_FFFFFF_t_70 1][]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoZW5ncWl1bWluZw_size_16_color_FFFFFF_t_70]: /images/20210724/8713a0226a704d29a6ff468f9ea3a952.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoZW5ncWl1bWluZw_size_16_color_FFFFFF_t_70 1]: /images/20210724/302e13586c7d4ad5a52be9a6779b5c4b.png