Springboot整合RabbitMQ實現(xiàn)發(fā)送驗證碼的示例代碼
更新時間：2022年02月10日 11:31:51 作者：weixin_43873712
這篇文章主要介紹了Springboot整合RabbitMQ實現(xiàn)發(fā)送驗證碼的功能,基于AMQP協(xié)議實現(xiàn)的消息隊列，它是一種應(yīng)用程序之間的通信方法，消息隊列在分布式系統(tǒng)開 發(fā)中應(yīng)用非常廣泛，需要的朋友可以參考下
1. RabbitMQ的介紹
- MQ全稱為Message Queue，即消息隊列， RabbitMQ是由erlang語言開發(fā)，基于AMQP（Advanced Message Queue 高級消息隊列協(xié)議）協(xié)議實現(xiàn)的消息隊列，它是一種應(yīng)用程序之間的通信方法，消息隊列在分布式系統(tǒng)開 發(fā)中應(yīng)用非常廣泛。RabbitMQ官方地址：http://www.rabbitmq.com/
- 開發(fā)中消息隊列通常有如下應(yīng)用場景：
1、任務(wù)異步處理。 將不需要同步處理的并且耗時長的操作由消息隊列通知消息接收方進行異步處理。提高了應(yīng)用程序的響應(yīng)時間。
2、應(yīng)用程序解耦合 MQ相當(dāng)于一個中介，生產(chǎn)方通過MQ與消費方交互，它將應(yīng)用程序進行解耦合。并且有如下優(yōu)點。
1.使得簡單，功能強大。
2.基于AMQP協(xié)議。
3.社區(qū)活躍，文檔完善。
4.高并發(fā)性能好，這主要得益于Erlang語言。
5.Spring Boot默認已集成RabbitMQ
- 組成部分說明如下：
- Broker：消息隊列服務(wù)進程，此進程包括兩個部分：
- Exchange和Queue。
- Exchange：消息隊列交換機，按一定的規(guī)則將消息路由轉(zhuǎn)發(fā)到某個隊列，對消息進行過慮。
Queue：消息隊列，存儲消息的隊列，消息到達隊列并轉(zhuǎn)發(fā)給指定的消費方。
Producer：消息生產(chǎn)者，即生產(chǎn)方客戶端，生產(chǎn)方客戶端將消息發(fā)送到MQ。
Consumer：消息消費者，即消費方客戶端，接收MQ轉(zhuǎn)發(fā)的消息。
消息發(fā)布接收流程：
-----發(fā)送消息-----
1、生產(chǎn)者和Broker建立TCP連接。
2、生產(chǎn)者和Broker建立通道。
3、生產(chǎn)者通過通道消息發(fā)送給Broker，由Exchange將消息進行轉(zhuǎn)發(fā)。
4、Exchange將消息轉(zhuǎn)發(fā)到指定的Queue（隊列）
----接收消息-----
1、消費者和Broker建立TCP連接
2、消費者和Broker建立通道
3、消費者監(jiān)聽指定的Queue（隊列）
4、當(dāng)有消息到達Queue時Broker默認將消息推送給消費者。
5、消費者接收到消息
2. 搭建環(huán)境
- 實現(xiàn)原理：
- 在綁定（Binding）Exchange與Queue的同時，一般會指定一個binding key；消費者將消息發(fā)送給Exchange時，一般會指定一個routing key；當(dāng)binding key與routing key相匹配時，消息將會被路由到對應(yīng)的Queue中。
- 多個消費者可以訂閱同一個Queue，這時Queue中的消息會被平均分攤給多個消費者進行處理，而不是每個消費者都收到所有的消息并處理。
2.1引入jar包
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-amqp</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
</dependency>
<!--redis-->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>2.2生產(chǎn)者配置
2.2.1Rabbit配置類
package com.cui.user.config;
import org.springframework.amqp.core.*;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
/** rabbitmq配置類 配置交換機，消息隊列，并且綁定交換機和queue
* @Author Cui
* @Date 2020-4-9 14:55
*/
@Configuration
public class RabbitmqConfig {
//隊列bean的名稱 cms 用來發(fā)送短信驗證碼
public static final String QUEUE_INFORM_CMS= "queue_inform_cms";
//隊列bean的名稱 email 用來發(fā)送郵件
//public static final String QUEUE_INFORM_EMAIL= "queue_inform_email";
//交換機的名稱
public static final String EXCHANGE_TOPIC_INFORM_="exchange_topic_inform";
//隊列的名稱
@Value("${cxp.mq.queue}")
public String queue_cms_postpage_name;
//routingKey
@Value("${cxp.mq.routingKey}")
public String routingKey;
/**
* 交換機配置使用direct類型
* @return the exchange
*/
@Bean(EXCHANGE_TOPIC_INFORM_)
public Exchange EXCHANGE_TOPICS_INFORM() {
//durable(true) 持久化，mq重啟之后交換機還在
return ExchangeBuilder.directExchange(EXCHANGE_TOPIC_INFORM_).durable(true).build();
}
//聲明隊列
@Bean(QUEUE_INFORM_CMS)
public Queue QUEUE_CMS_POSTPAGE() {
Queue queue = new Queue(QUEUE_INFORM_CMS);
return queue;
* 綁定隊列到交換機
*
* @param queue the queue
* @param exchange the exchange
* @return the binding
@Bean
public Binding BINDING_QUEUE_INFORM_SMS(@Qualifier(QUEUE_INFORM_CMS) Queue queue, @Qualifier(EXCHANGE_TOPIC_INFORM_) Exchange exchange) {
return BindingBuilder.bind(queue).to(exchange).with(routingKey).noargs();
}2.2.2 application.yml文件配置
server:
port: ${PORT:8002}
spring:
application:
name: cxp-service-manage-user
#Redis配置
redis:
host: 127.0.0.1
port: 6379
jedis:
pool:
max-active: 8
max-wait: -1
max-idle: 500
min-idle: 0
lettuce:
shutdown-timeout: 0
datasource:
url: jdbc:mysql://localhost:3306/system_user?useUnicode=true&characterEncoding=utf-8&useSSL=true&serverTimezone=UTC
username: root
password: 123456
driver-class-name: com.mysql.jdbc.Driver
rabbitmq:
port: 5672
username: guest
password: guest
virtualHost: /
cxp:
mq:
#cms客戶端監(jiān)控的隊列名稱（不同的客戶端監(jiān)控的隊列不能重復(fù)）
queue: queue_inform_cms
routingKey: inform.#.sms.# #此routingKey郵件消費者和信息消費者通用
mybatis:
mapper-locations: classpath:mapper/*Mapper.xml
type-aliases-package: com.cui.model.entity.user
mapper:
mappers: com.cui.model.BaseMapper #通用基類配置
identity: mysql
pagehelper:
helperDialect: mysql
reasonable: true
supportMethodsArguments: true
params: count=countSql
eureka:
client:
registerWithEureka: true #服務(wù)注冊開關(guān)
fetchRegistry: true #服務(wù)發(fā)現(xiàn)開關(guān)
serviceUrl: #Eureka客戶端與Eureka服務(wù)端進行交互的地址，多個中間用逗號分隔
defaultZone: ${EUREKA_SERVER:http://localhost:50101/eureka/,http://localhost:50102/eureka/}
instance:
prefer-ip-address: true #將自己的ip地址注冊到Eureka服務(wù)中
ip-address: ${IP_ADDRESS:127.0.0.1}
instance-id: ${spring.application.name}:${server.port} #指定實例id
ribbon:
MaxAutoRetries: 2 #最大重試次數(shù)，當(dāng)Eureka中可以找到服務(wù)，但是服務(wù)連不上時將會重試，如果eureka中找不到服務(wù)則直接走斷路器
MaxAutoRetriesNextServer: 3 #切換實例的重試次數(shù)
OkToRetryOnAllOperations: false #對所有操作請求都進行重試，如果是get則可以，如果是post，put等操作沒有實現(xiàn)冪等的情況下是很危險的,所以設(shè)置為false
ConnectTimeout: 5000 #請求連接的超時時間
ReadTimeout: 6000 #請求處理的超時時間2.3消費者配置
引入jar包，這里需引入阿里云通信多的jar包和Redis的jar包
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
<!--阿里云通信-->
<dependency>
<groupId>com.aliyun</groupId>
<artifactId>aliyun-java-sdk-core</artifactId>
<version>4.4.0</version>
<artifactId>aliyun-java-sdk-dysmsapi</artifactId>
<version>1.0.0</version>
<!-- 導(dǎo)入Eureka客戶端的依賴 -->
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
<!-- feign相關(guān)依賴 -->
<artifactId>spring-cloud-starter-openfeign</artifactId>
<dependency>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
<artifactId>spring-boot-starter-amqp</artifactId>2.3.1 消費者配置類（同生產(chǎn)者）
package com.cui.sms.config;
import org.springframework.amqp.core.*;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
/** rabbitmq配置類 配置交換機，消息隊列，并且綁定交換機和queue
* @Author Cui
* @Date 2020-4-9 14:55
*/
@Configuration
public class RabbitmqConfig {
//隊列bean的名稱 cms 用來發(fā)送短信驗證碼
public static final String QUEUE_INFORM_CMS= "queue_inform_cms";
//隊列bean的名稱 email 用來發(fā)送郵件
//public static final String QUEUE_INFORM_EMAIL= "queue_inform_email";
//交換機的名稱
public static final String EXCHANGE_TOPIC_INFORM_="exchange_topic_inform";
//隊列的名稱
@Value("${cxp.mq.queue}")
public String queue_cms_postpage_name;
//routingKey
@Value("${cxp.mq.routingKey}")
public String routingKey;
/**
* 交換機配置使用direct類型
* @return the exchange
*/
@Bean(EXCHANGE_TOPIC_INFORM_)
public Exchange EXCHANGE_TOPICS_INFORM() {
//durable(true) 持久化，mq重啟之后交換機還在
return ExchangeBuilder.directExchange(EXCHANGE_TOPIC_INFORM_).durable(true).build();
}
//聲明隊列
@Bean(QUEUE_INFORM_CMS)
public Queue QUEUE_CMS_POSTPAGE() {
Queue queue = new Queue(QUEUE_INFORM_CMS);
return queue;
* 綁定隊列到交換機
*
* @param queue the queue
* @param exchange the exchange
* @return the binding
@Bean
public Binding BINDING_QUEUE_INFORM_SMS(@Qualifier(QUEUE_INFORM_CMS) Queue queue, @Qualifier(EXCHANGE_TOPIC_INFORM_) Exchange exchange) {
return BindingBuilder.bind(queue).to(exchange).with(routingKey).noargs();
}2.3.2 application.yml文件配置
server:
port: 8103
spring:
application:
name: cxp-manager-service-sms
rabbitmq:
host: 127.0.0.1
port: 5672
username: guest
password: guest
virtualHost: /
#Redis配置
redis:
port: 6379
password: 123456
jedis:
pool:
max-active: 8
max-wait: -1
max-idle: 500
min-idle: 0
lettuce:
shutdown-timeout: 0
aliyun:
sms:
accessKeyId: XXXXXXXXXXXXXXXXXXXX
accessKeySecret: XXXXXXXXXXXXXXXXXXXX
template_code: XXXXXXXXXXX
sign_name: XXXX
cxp:
mq:
#cms客戶端監(jiān)控的隊列名稱（不同的客戶端監(jiān)控的隊列不能重復(fù)）
queue: queue_inform_cms
routingKey: inform.sms #此routingKey用來監(jiān)聽信息
eureka:
client:
registerWithEureka: true #服務(wù)注冊開關(guān)
fetchRegistry: true #服務(wù)發(fā)現(xiàn)開關(guān)
serviceUrl: #Eureka客戶端與Eureka服務(wù)端進行交互的地址，多個中間用逗號分隔
defaultZone: ${EUREKA_SERVER:http://localhost:50101/eureka/,http://localhost:50102/eureka/}
instance:
prefer-ip-address: true #將自己的ip地址注冊到Eureka服務(wù)中
ip-address: ${IP_ADDRESS:127.0.0.1}
instance-id: ${spring.application.name}:${server.port} #指定實例id
ribbon:
MaxAutoRetries: 2 #最大重試次數(shù)，當(dāng)Eureka中可以找到服務(wù)，但是服務(wù)連不上時將會重試，如果eureka中找不到服務(wù)則直接走斷路器
MaxAutoRetriesNextServer: 3 #切換實例的重試次數(shù)
OkToRetryOnAllOperations: false #對所有操作請求都進行重試，如果是get則可以，如果是post，put等操作沒有實現(xiàn)冪等的情況下是很危險的,所以設(shè)置為false
ConnectTimeout: 5000 #請求連接的超時時間
ReadTimeout: 6000 #請求處理的超時時間3.寫發(fā)送短信驗證碼的代碼
3.1寫一個controller來調(diào)用發(fā)送驗證碼的接口
/**
* 發(fā)送短信驗證碼
* @param phone
* @return
*/
@ApiOperation(value = "發(fā)送短信驗證碼",notes = "發(fā)送短信驗證碼")
@GetMapping("/sendSms")
public ResponseResult sendSms(String phone){
LOGGER.info("要發(fā)送的手機號為：{}", phone);
userService.sendSms(phone);
return new ResponseResult(UserMsg.SUCCESS.getMsgCd(), UserMsg.SUCCESS.getMsgInfo());
}3.2 生成驗證碼
后臺生成六位數(shù)的隨機驗證碼，并且將驗證碼存入Redis中，設(shè)置五分鐘的過期時間(用于用戶注冊時的校對)，將驗證碼存到RabbitMQ中，當(dāng)調(diào)用發(fā)送接口時，生產(chǎn)端將信息發(fā)送到綁定的隊列中。
/**
* 向注冊用戶發(fā)送發(fā)送驗證碼
* @param phone 注冊的用戶的手機號
*/
@Override
public void sendSms(String phone) {
//1.生成六位隨機驗證碼
Random random = new Random();//隨機函數(shù)
int code = random.nextInt(999999);//設(shè)置隨機數(shù)的最大值
if(code<100000){ //如果驗證碼小于六位數(shù)，加100000保證驗證碼為6位數(shù)
code+=100000;
}
//System.out.println("短信驗證碼："+code);
LOGGER.info("生成的短信驗證碼為：{{}}", code);
//2.將驗證碼存入redis
redisTemplate.boundValueOps("code_"+phone).set(code+"");
redisTemplate.boundValueOps("code_"+phone).expire(5, TimeUnit.MINUTES);//設(shè)置驗證碼五分鐘到期
//3.將驗證碼存入RabbitMQ
Map<String,String> map = new HashMap<String, String>();
map.put("phone", phone);
map.put("code", code+"");
//以json格式存到RabbitMQ消息隊列中
rabbitTemplate.convertAndSend(EXCHANGE_TOPIC_INFORM_, routingKey, JSON.toJSONString(map));
}3.3發(fā)送短信驗證碼
在RabbitMQ的消費者端監(jiān)聽短信的routingKey ，當(dāng)收到生產(chǎn)端發(fā)來的消息后，便會調(diào)用阿里云通信向用戶發(fā)送短信
package com.cui.sms.mq;
import com.alibaba.fastjson.JSON;
import com.aliyuncs.CommonResponse;
import com.cui.sms.utils.SmsUtil;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.amqp.core.Message;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;
import java.util.Map;
/**
* @Author Cui
* @Date 2020-4-9 15:40
* 監(jiān)聽MQ,發(fā)送短信驗證碼
*/
@Component
public class SmsMessageConsumer {
private static final Logger LOGGER = LoggerFactory.getLogger(SmsMessageConsumer.class);
@Autowired
private SmsUtil smsUtil;
@Value("${aliyun.sms.template_code}")
private String templateCode;
@Value("${aliyun.sms.param}")
private String param; //短信參數(shù)
@RabbitListener(queues = {"${cxp.mq.queue}"})
public void onMessage(Message message) {
String jsonString= new String(message.getBody());//得到mq中存入的json格式的消息
Map<String,String> map = JSON.parseObject(jsonString, Map.class);//將json格式轉(zhuǎn)換為Map格式
String phone = map.get("phone");//mq中存入的手機號
String code = map.get("code");//mq中存入的驗證碼
//System.out.println("手機號"+phone+"驗證碼"+code);
LOGGER.info("發(fā)送的手機號為：{} ,發(fā)送的驗證碼為 ：{}",phone, code);
//調(diào)用阿里云通信
CommonResponse commonResponse = smsUtil.sendSms(phone, templateCode, param.replace("[value]", code));
}
}3.4 實現(xiàn)驗證碼的校對
用戶收到驗證碼并且填寫完相應(yīng)的信息后，點擊注冊，將自己的信息發(fā)送到后臺，后臺收到信息后，取出存在Redis中的驗證碼，和用戶的驗證碼進行比較，然后將結(jié)果返回給前端。代碼如下所示：
@PostMapping("/save")
@ApiOperation(value = "新增用戶",notes = "新增用戶")
public ResponseResult add(@RequestBody User user, String smsCode){
LOGGER.info("新增的用戶的信息為：{}，用戶收到的驗證碼為：{}", user.toString(),smsCode);
//對用戶密碼進行加密后在存入數(shù)據(jù)庫
BCryptPasswordEncoder encoder = new BCryptPasswordEncoder();
String newPassword = encoder.encode(user.getPassword());
user.setPassword(newPassword);
userService.add(user,smsCode );
return new ResponseResult(UserMsg.SUCCESS.getMsgCd(), UserMsg.SUCCESS.getMsgInfo());
}/**
* 用戶注冊
* @param user 用戶對象信息
* @param smsCode 短信驗證碼
*/
@Override
public void add(User user, String smsCode) {
//獲取系統(tǒng)驗證碼
String sysCode = (String) redisTemplate.boundValueOps("code_" + user.getPhone()).get();
//比較短信驗證碼
LOGGER.info("從Redis中取到的短信驗證碼為：{{}}",smsCode+" 用戶收到的的短信驗證碼為：{{}}",smsCode);
if(sysCode==null||"".equals(smsCode)){
throw new RuntimeException("驗證碼未發(fā)送或已過期！請稍后重試");
}
if(!smsCode.equals(sysCode)){
throw new RuntimeException("驗證碼不正確，請重新輸入！");
}
if(user.getUsername()==null){
user.setUsername(user.getPhone());
}
User searchUser = new User();
//將用戶傳來的手機號傳給searchUser，去查詢數(shù)據(jù)庫中是否存在該手機號
searchUser.setPhone(user.getPhone());
if(userDao.selectCount(searchUser)>0){
throw new RuntimeException("該手機號已被注冊！");
}
//設(shè)置user的其他參數(shù)
user.setCreated(new Date());
user.setUpdated(new Date());
user.setPoints(0);//積分初始值為0
user.setStatus("1");//狀態(tài)1
user.setIsEmailCheck("0");//郵箱認證
user.setIsMobileCheck("1");//手機認證
userDao.insert(user);
}到此這篇關(guān)于Springboot整合RabbitMQ實現(xiàn)發(fā)送驗證碼的功能的文章就介紹到這了,更多相關(guān)Springboot整合RabbitMQ發(fā)送驗證碼內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！
相關(guān)文章
Spring Boot整合MyBatis連接Oracle數(shù)據(jù)庫的步驟全紀錄
這篇文章主要給大家介紹了關(guān)于Spring Boot整合MyBatis連接Oracle數(shù)據(jù)庫的相關(guān)資料，文中通過示例代碼介紹的非常詳細，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2018-07-07
SpringBoot配置數(shù)據(jù)庫密碼加密的實現(xiàn)
這篇文章主要介紹了SpringBoot配置數(shù)據(jù)庫密碼加密的實現(xiàn)，文中通過示例代碼介紹的非常詳細，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2021-03-03
Java畢業(yè)設(shè)計實戰(zhàn)之食品溯源系統(tǒng)的實現(xiàn)
這是一個使用了java+Springboot+Maven+mybatis+Vue+mysql+wd開發(fā)的食品溯源系統(tǒng)，是一個畢業(yè)設(shè)計的實戰(zhàn)練習(xí)，具有食品溯源該有的所有功能，感興趣的朋友快來看看吧2022-01-01
Mybatis?resultMap標簽繼承、復(fù)用、嵌套方式
這篇文章主要介紹了Mybatis?resultMap標簽繼承、復(fù)用、嵌套方式，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2022-03-03
這篇文章主要介紹了Scala之文件讀取、寫入、控制臺操作的方法示例,文中通過示例代碼介紹的非常詳細，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2019-06-06
這篇文章主要介紹了Java 多線程優(yōu)先級實例詳解的相關(guān)資料,需要的朋友可以參考下2017-04-04
java網(wǎng)絡(luò)編程基礎(chǔ)知識介紹
這篇文章主要介紹了java網(wǎng)絡(luò)編程基礎(chǔ)知識介紹，涉及OSI分層模型和TCP/IP分層模型的對應(yīng)關(guān)系、IP地址、端口號、tcp、udp等相關(guān)內(nèi)容，還是比較不錯的，這里分享給大家，供需要的朋友參考。2017-11-11
這篇文章主要介紹了Java方法參數(shù)傳遞機制原理解析,文中通過示例代碼介紹的非常詳細，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友可以參考下2019-12-12
詳解Java中的do...while循環(huán)語句的使用方法
這篇文章主要介紹了Java中的do...while循環(huán)語句的使用方法,是Java入門學(xué)習(xí)中的基礎(chǔ)知識,需要的朋友可以參考下2015-10-10
最近沒有事情做，閑的發(fā)呆，于是寫個東東練練手。這篇文章主要介紹了Java 多用戶登錄限制的實現(xiàn)方法的相關(guān)資料,需要的朋友可以參考下2016-11-11