用户微服务-用户注册发送短信验证码

悠悠 2021-12-03 19:59 577阅读 0赞

# 1 需求分析 #

注册账号，用手机号注册，填写后发送短信验证码，  
填写短信验证码正确方可注册成功。

# 2 实现思路 #

1）用户微服务生成6位的短信验证码，存入redis （以code\_手机号为key），再发送给rabbitmq .  
2）短信微服务从rabbitmq中提取消息，调用阿里云通信api发送短信  
3）用户注册，从redis提取验证码，与用户在界面上填写的验证码进行比较，只有填写正确才能注册。

# 3 发送短信验证码 #

实现思路： 在用户服务编写API ,生成手机验证码，存入Redis并发送到RabbitMQ

## （1）rabbitmq中新增队列sms ，用于存储发送的短信 ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3NpbmF0XzM5MTc5OTkz_size_16_color_FFFFFF_t_70]

## （2）changgou\_service\_user的pom.xml引入依赖 ##

<dependency>
                <groupId>org.springframework.amqp</groupId>
                <artifactId>spring-rabbit</artifactId>
            </dependency>

## （3）修改changgou\_service\_user的application.yml，在spring节点下添加配置 ##

server:
      port: 9008
    spring:
      application:
        name: user
      datasource:
        driver-class-name: com.mysql.jdbc.Driver
        url: jdbc:mysql://192.168.200.128:3306/changgou_user?useUnicode=true&characterEncoding=UTF-8&serverTimezone=UTC
        username: root
        password: admin
      main:
        allow-bean-definition-overriding: true #当遇到同样名字的时候，是否允许覆盖注册
      redis:
        host: 192.168.200.128
      rabbitmq:
        host: 192.168.200.128
    eureka:
      client:
        service-url:
          defaultZone: http://127.0.0.1:6868/eureka
      instance:
        prefer-ip-address: true
    feign:
      hystrix:
        enabled: true
      client:
        config:
          default:   #配置全局的feign的调用超时时间  如果 有指定的服务配置 默认的配置不会生效
            connectTimeout: 60000 # 指定的是 消费者 连接服务提供者的连接超时时间 是否能连接  单位是毫秒
            readTimeout: 20000  # 指定的是调用服务提供者的 服务 的超时时间（）  单位是毫秒
    #hystrix 配置
    hystrix:
      command:
        default:
          execution:
            timeout:
              #如果enabled设置为false，则请求超时交给ribbon控制
              enabled: true
            isolation:
              strategy: SEMAPHORE
              thread:
                # 熔断器超时时间，默认：1000/毫秒
                timeoutInMilliseconds: 20000

## （4）在UserService中新增方法定义 ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3NpbmF0XzM5MTc5OTkz_size_16_color_FFFFFF_t_70 1]

/**
         * 发送短信验证码
         * @param mobile
         */
        public void sendSms(String mobile);
         /**
         * 增加
         * @param user
         * @param code
         */
        public void register(User user,String code);

## （5）UserServiceImpl方法实现 ##

实现逻辑：  
1）生成六位随机数验证码  
2）以手机号作为key，存入redis  
3）将手机号与验证码发送到MQ

@Autowired
         private RedisTemplate redisTemplate;
         @Autowired
         private RabbitTemplate rabbitTemplate;
      /**
         * 1）生成六位随机数验证码
         * 2）以手机号作为key，存入redis
         * 3）将手机号与验证码发送到MQ
         * @param mobile
         */
        @Override
        public void sendSms(String mobile) {
                  //  * 1）生成六位随机数验证码
            String code = RandomStringUtils.randomNumeric(6);
            System.out.println("==================code:======="+code);
            //  * 2）以手机号作为key，存入redis
            redisTemplate.boundValueOps("Code_"+mobile).set(code,12, TimeUnit.HOURS);
                  //  * 3）将手机号与验证码发送到MQ
             Map info = new HashMap();
             info.put("mobile",mobile);
             info.put("code",code);
             rabbitTemplate.convertAndSend("","sms", JSON.toJSONString(info));
        }
        
        /**
         *1）校验redis中是否存在验证码，用户输入验证码是否与redis中是否一致
         * 2）根据用户名查询用户，如果不为null，则该用户已注册
         * 3）填充用户信息并保存
         * @param user
         * @param code
         */
        @Override
        public void register(User user, String code) {
            //1）校验redis中是否存在验证码，用户输入验证码是否与redis中是否一致
           String redisCode =(String)redisTemplate.boundValueOps("Code_"+user.getPhone()).get();
            System.out.println("===========redisCode:"+redisCode);
           //2. 参数校验：redis中的code是否过期，用户输入的验证与redis中的验证码是否一致,当前用户是否已经注册过
            if (StringUtils.isEmpty(redisCode)){
                throw new RuntimeException("当前验证码已过期");
            }
            if (!redisCode.equals(code)){
                throw new RuntimeException("输入的验证码有误");
            }
            if (StringUtils.isEmpty(user.getUsername())){
                user.setUsername(user.getPhone());
            }
            //* 2）根据用户名查询用户，如果不为null，则该用户已注册
            User searchUser = new User();
            searchUser.setUsername(user.getUsername());
           if (userMapper.selectCount(searchUser)>0){
               //该用户已经注册过
               throw  new RuntimeException("当前用户已经注册过");
           }
            //3.填充用户的信息
            user.setCreated(new Date());
            user.setUpdated(new Date());
            user.setPoints(0);//积分初始值为0
            user.setStatus("1");//状态1
            user.setIsEmailCheck("0");//邮箱认证
            user.setIsMobileCheck("1");//手机认证
            String password = BCrypt.hashpw(user.getPassword(), BCrypt.gensalt());//密码加密
            user.setPassword(password);
            //4.保存用户信息
           userMapper.insertSelective(user);
        }

## (6)UserController增加方法 ##

/**
         * 发送短信
         * @param mobile
         * @return
         */
        @RequestMapping("/send_sms")
        public Result  sendSms(@RequestParam("mobile")   String mobile){
            userService.sendSms(mobile);
            return new Result(true,StatusCode.OK,"发送短信成功");
        }
        /**
         * 注册
         * @param user
         * @param code
         * @return
         */
        @PostMapping("/register")
        public Result register(@RequestBody User user,@RequestParam("code") String code){
            userService.register(user,code);
            return new Result(true,StatusCode.OK,"用户注册成功");
        }

## (7)测试 ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3NpbmF0XzM5MTc5OTkz_size_16_color_FFFFFF_t_70 2]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3NpbmF0XzM5MTc5OTkz_size_16_color_FFFFFF_t_70 3]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3NpbmF0XzM5MTc5OTkz_size_16_color_FFFFFF_t_70]: /images/20211203/59c968cc25c24d01a637f013424db1e1.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3NpbmF0XzM5MTc5OTkz_size_16_color_FFFFFF_t_70 1]: /images/20211203/17c18d39946742a5899ac0017c559f7c.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3NpbmF0XzM5MTc5OTkz_size_16_color_FFFFFF_t_70 2]: /images/20211203/14f2f234dc0f46e2925dcb4c02420a67.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3NpbmF0XzM5MTc5OTkz_size_16_color_FFFFFF_t_70 3]: /images/20211203/a654b13c6a834f1da52223fdf65a20c9.png