一.技术及思路
二.案例编写
配置环境：使用docker新建redis,mysql，rabbitmq的容器
MySQL：启动docker服务systemctl start docker
查看docker服务状态
systemctl status docker
查看目录进入mysql目录下，然后新创建一个容器，熟悉一下docker部署MySQLcd root/mysql/方式1
docker run -id -p 3306:3306 \--name=c_mysql2 \-v $PWD/conf:/etc/mysql/conf.d \-v $PWD/logs:/logs \-v $PWD/data:/var/lib/mysql \-e MYSQL_ROOT_PASSWORD=root \mysql:5.7
方式2
docker run --name=c_mysql -d -p 3306:3306 -e MYSQL_ROOT_PASSWORD=root mysql:5.7
查看容器运行状态
docker ps -a
启动c_mysql容器
docker start c_mysql
到这一步的时候，出错了，新的MySQL容器和旧的MySQL容器都启动不了了，而且后来将新的容器删除之后，旧的容器依旧启动不了，也不知道啥情况（前面是用第一种方式创建，不行就请教了老师，改成了第二种方式）然后到用Navicat连接诶数据库
然后现在开始创建项目，配置环境
自动创建springboot项目，导入依赖<!--整合mybatis-plus--><dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId><version>5.1.49</version></dependency><dependency><groupId>com.baomidou</groupId><artifactId>mybatis-plus-boot-starter</artifactId><version>3.0.5</version></dependency><dependency><groupId>junit</groupId><artifactId>junit</artifactId><version>4.12</version></dependency><!--加密组件,apache--><dependency><groupId>commons-codec</groupId><artifactId>commons-codec</artifactId><version>1.3</version></dependency><!--redis依赖--><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-redis</artifactId></dependency><!--jwt--><dependency><groupId>io.jsonwebtoken</groupId><artifactId>jjwt</artifactId><version>0.9.1</version></dependency><!--AMQP依赖--><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-amqp</artifactId></dependency>
然后，根据我们的需要，我们现在需要在这个父项目当中，创建两个子模块（注意要创建maven项目，因为springboot项目本身就已经继承了一个父类，那么就会导致我们无法再继承刚刚我们创建的父项目）在这两个模块当中，一个用来实现发送短消息，登录注册这三个功能，另一个用来实现收验证码的功能新建模块1：Pubreg,手写启动类，加入核心配置文件，里面增加mq的配置
package com.pro;import org.mybatis.spring.annotation.MapperScan;import org.springframework.boot.SpringApplication;import org.springframework.boot.autoconfigure.SpringBootApplication;@SpringBootApplication@MapperScan(value = "com.pro.mapper")public class PubRegApp {public static void main(String[] args) {SpringApplication.run(PubRegApp.class,args);}}
#mqspring.rabbitmq.host=192.168.8.171#通信端口spring.rabbitmq.port=5672spring.rabbitmq.username=rabbitspring.rabbitmq.password=rabbitspring.rabbitmq.virtual-host=/
package com.pro.config;import org.springframework.amqp.core.Queue;import org.springframework.context.annotation.Bean;import org.springframework.context.annotation.Configuration;//标识了下面这个注解，就代表是配置类：相当于以前的applicationContext.xml文件@Configurationpublic class PubConfig {@Beanpublic Queue queue(){return new Queue("yzmQueue");}}
然后在这个模块里面开始写我们的发送验证码和登录业务思路：业务层，我们需要根据前端传过来的用户名随机生成验证码，将用户名和密码存进reids,并且发送到yzmQueue队列中
package com.pro.service;import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;import com.baomidou.mybatisplus.extension.api.R;import com.pro.domain.User;import com.pro.mapper.UserMapper;import org.springframework.amqp.rabbit.core.RabbitTemplate;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.data.redis.core.RedisTemplate;import org.springframework.stereotype.Service;import java.time.Duration;import java.util.HashMap;import java.util.Map;import java.util.Random;@Servicepublic class UserServiceImpl implements UserService {@Autowiredprivate UserMapper userMapper;@Autowiredprivate RedisTemplate redisTemplate;@Autowiredprivate RabbitTemplate rabbitTemplate;/*** 发送验证码* @param username*/@Overridepublic void proYzm(String username) {Random random = new Random();int yzm = random.nextInt(9000)+1000;//生成一个1000到10000之间的四位数验证码//用用户名做键，验证码做值，存进Redis，并设置一分钟的存活时间String YZM = String.valueOf(yzm);redisTemplate.opsForValue().set(username,YZM, Duration.ofSeconds(120));//将yzmQueue作为队列名，验证码和手机号的作为消息发送到消息队列当中,前提是我们已经写了配置类，创建了这个队列Map<Object,Object> map = new HashMap();map.put("username",username);map.put("yzm",yzm);rabbitTemplate.convertAndSend("yzmQueue",map);}/*** 验证是否已经发送过验证码* @param username* @return*/public String checkYzm(String username){String redisData = (String) redisTemplate.opsForValue().get(username);return redisData;}@Overridepublic String checkLogin(String username,String yzm) {String redisYzm = (String) redisTemplate.opsForValue().get(username);QueryWrapper queryWrapper = new QueryWrapper();queryWrapper.eq("username",username);User user = userMapper.selectOne(queryWrapper);//如果用户不存在，注册并判断是否登录成功if(user == null){if(yzm.equals(redisYzm)){User user1 = new User();user1.setUsername(username);userMapper.insert(user1);return "尊贵的"+username+"用户，您已注册并登录成功!";}else {return "验证码错误或已过期！";}}else {//用户存在，直接判断是否可以登录if(redisYzm.equals(yzm)){return "尊贵的"+username+"用户，欢迎回来!";}else {return "验证码错误或已过期！";}}}}
package com.pro.controller;import com.pro.service.UserService;import com.pro.util.R;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.web.bind.annotation.GetMapping;import org.springframework.web.bind.annotation.PostMapping;import org.springframework.web.bind.annotation.RestController;@RestControllerpublic class UserController {@Autowiredprivate UserService userService;/*** 发验证码* @param username* @return*/@PostMapping("/proYzm")public R proYzm (String username){String checkYzm = userService.checkYzm(username);if(checkYzm == null){userService.proYzm(username);return new R(200,"验证码发送成功！");}return new R(300,"请两分钟之后再发验证码！");}/*** 登录判断* @param username* @param yzm* @return*/@PostMapping("/checkLogin")public String checkLogin(String username,String yzm){String s = userService.checkLogin(username, yzm);return s;}}
效果：Redis里面可以看到信息只能存活我们设置的60秒
测试好发送验证码，我们现在来写接收验证码
首先建一个模块conReg,手写启动类，加入核心配置文件，里面增加mq的配置写一个监听类来监听队列当中的验证码消息，模拟接收验证码package com.pro.listener;import org.springframework.amqp.rabbit.annotation.RabbitListener;import org.ponent;import java.util.Map;@Componentpublic class SpringRabbitListener {/* @RabbitListener(queues = "java")public void listenerQueue(String msg){System.out.println("消费者接受到了消息："+msg);}*/@RabbitListener(queues = "yzmQueue")public void listenerWorkQueue1(Map map)throws Exception{System.out.println("【验证密码】您的验证码为:"+map.get("yzm")+"。尊敬的"+map.get("username")+"客户，以上验证密码2分钟内有效，请勿泄露或转发他人。【湖北移动 移动认证】");}}
然后如果是已注册用户，登录会显示欢迎回来
验证码错误或者过期，就会提示验证码过期或错误，这里我没有设置具体是用户名错误还是验证码错误了。
遇到的问题数据库ID没有设自动递增，插入user的时候，用null去调用get方法后续需要改进：加入token，未登录不能操作，前端页面实现。
