[大数据]RabbitMQ实现简单发送验证码功能

1.导入依赖

<!--        设置raabbitmq的依赖-->		
<dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-amqp</artifactId>
        </dependency>	
<!--   mybatis plus依赖-->
<dependency>
            <groupId>com.baomidou</groupId>
            <artifactId>mybatis-plus-boot-starter</artifactId>
            <version>3.0.5</version>
        </dependency>

2.配置文件

spring:
  application:
    name: springboot-rabbitmq
  rabbitmq:
    host: 192.168.112.130  #虚拟机ip，我是在虚拟机运行，本机则使用localhost
    port: 5672  #访问端口号
    username: ems  #登录账号与密码
    password: 123
    virtual-host: /ems  #虚拟消息服务器
  datasource:   #数据源配置
    url: jdbc:mysql://localhost:3306/1808a2?serverTimezone=GMT%2B8&characterEncoding=utf-8
    username: 
    password: 
    driver-class-name: com.mysql.cj.jdbc.Driver
mybatis:
  #扫描mybatis的映射文件位置
  mapper-locations: com/baidu/dao/*.xml
  #mybatis定义实体包引用别名
  type-aliases-package: com.baidu.dto
#打印sql
logging:
  level:
    com.baidu.dao  : debug

3.数据库脚本

DROP TABLE IF EXISTS `tb_user`;
CREATE TABLE `tb_user` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `name` varchar(255) DEFAULT NULL,
  `pwd` varchar(255) DEFAULT NULL,
  `phone` varchar(255) DEFAULT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=2 DEFAULT CHARSET=utf8mb4;

-- ----------------------------
-- Records of tb_user
-- ----------------------------
INSERT INTO `tb_user` VALUES ('1', 'admin', 'admin', '18434290135');

4.启动rabbitmq

docker start MQid

浏览器访问 http://192.168.112.130:15672/ 使用默认来宾账户登录 guest

5.设置一个虚拟消息服务器

规则是/开头

6.创建一个用户

7.使用虚拟消息服务器

admin->Virtual Hosts->/ems

8.实现中间件发送短信

生产者代码

//使用springboot集成rabbitmq的模板
@Autowired
    private RabbitTemplate rabbitTemplate;



@Override
    public ResultResponse SendCode(String phone) {
        QueryWrapper<TBUser> wrapper = new QueryWrapper<TBUser>();
        wrapper.lambda().eq(TBUser::getPhone,phone);
        TBUser tbUser = tbUserMapper.selectOne(wrapper);
        if (tbUser!=null){
            //使用基本的Hello模型，
            rabbitTemplate.convertAndSend("hello",phone);
            return ResultResponse.SUCCESS();
        }else{
            return ResultResponse.FAILED("该手机号不存在");
        }
    }

消费者代码

package com.baidu.hello;

import com.baidu.utils.AuthCodeUtil;
import org.springframework.amqp.rabbit.annotation.Queue;
import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

@Component
//创建一个队列        //使用默认的配置
@RabbitListener(queuesToDeclare = @Queue("hello"))
public class HelloSendCode {

    @RabbitHandler
    public void sendCode(String phone){
        String code = AuthCodeUtil.getCode("0-9", 6);
        System.err.println("手机号 ="+phone+"的验证码为"+code);
    }
}

自动创建的Hello队列，

使用postman测试

天天打码，天天进步！