这篇文章主要介绍springboot整合RabbitMQ发送短信的实现方法，文中介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们一定要看完！
RabbitMQ安装和运行
# 安装rpm -ivh erlang-21.3.8.9-1.el7.x86_64.rpm rpm -ivh socat-1.7.3.2-1.el6.lux.x86_64.rpm rpm -ivh rabbitmq-server-3.8.1-1.el7.noarch.rpm # 卸载#rpm -qa | grep rabbitmq# 启用管理插件rabbitmq-plugins enable rabbitmq_management# 启动RabbitMQsystemctl start rabbitmq-server.service#systemctl status rabbitmq-server.service#systemctl restart rabbitmq-server.service#systemctl stop rabbitmq-server.service# 查看进程ps -ef | grep rabbitmq默认的用户密码，guest/guest，不允许远程连接，需要添加管理员账户
# 添加管理员账号密码rabbitmqctl add_user admin admin# 分配账号角色rabbitmqctl set_user_tags admin administrator# 修改密码（需要修改一次密码，否则无法登录）rabbitmqctl change_password admin 123456# 查看用户列表rabbitmqctl list_users使用新账号（admin/123456）登录：http://虚拟机ip:15672
MQ服务器设置
创建用户
创建用户 srbuser，配置管理员权限
创建虚拟机
创建虚拟机 /srbhost，在Set permission中为新建的用户分配访问虚拟机 /srbhost 和 / 的权限
实现发送短信
rabbit-mq
创建模块
srb下创建rabbit-mq模块
pom
<dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-amqp</artifactId></dependency><dependency><groupId>com.alibaba</groupId><artifactId>fastjson</artifactId></dependency><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId></dependency></dependencies>创建MQConfig
MQConfig.java
package com.indi.srb.rabbitutil.config;@Configurationpublic class MQConfig { @Bean public MessageConverter messageConverter(){ // json字符串转换器 return new Jackson2JsonMessageConverter(); }}创建MQConst
MQConst.java
package com.indi.srb.rabbitutil.constant;public class MQConst { public static final String EXCHANGE_TOPIC_SMS = "exchange.topic.sms";//交换机 public static final String ROUTING_SMS_ITEM = "routing.sms.item";//路由 public static final String QUEUE_SMS_ITEM = "queue.sms.item";//消息队列}创建MQService
MQService.java
package com.indi.srb.rabbitutil.service;@Service@Slf4jpublic class MQService { @Resource private AmqpTemplate amqpTemplate; public boolean sendMessage(String exchange,String routingKey, Object message){ log.info("发送消息"); amqpTemplate.convertAndSend(exchange,routingKey,message); return true; }}service-base
dto
SmsDTO.java
package com.indi.srb.base.dto;@Data@ApiModel(description = "短信")public class SmsDTO { @ApiModelProperty(value = "手机号") private String mobile; @ApiModelProperty(value = "消息内容") private String message;}service-core中发送消息
pom
<!-- 需要依赖rabbit-mq --><dependency><groupId>com.indi</groupId><artifactId>rabbit-mq</artifactId><version>1.0-SNAPSHOT</version></dependency>yml
application.yaml
#spring: rabbitmq: host: 虚拟机ip port: 5672 virtual-host: /srbhost username: srbuser password: 123456UserInfoService
UserInfoService.java
// 根据bindCode获取手机号String getMobileByBindCode(String bindCode);UserInfoServiceImpl.java
@Override public String getMobileByBindCode(String bindCode) { QueryWrapper<UserInfo> queryWrapper = new QueryWrapper<>(); queryWrapper.select("mobile").eq("bind_code",bindCode); UserInfo userInfo = baseMapper.selectOne(queryWrapper); return userInfo.getMobile(); }向MQ发送消息
UserAccountServiceImpl.java 充值回调方法的最后添加发送消息的代码
@Resource private UserInfoService userInfoService; @Resource private MQService mqService; @Transactional(rollbackFor = Exception.class) @Override public String notify(Map<String, Object> paramMap) { log.info("发消息"); String mobile = userInfoService.getMobileByBindCode(bindCode); SmsDTO smsDTO = new SmsDTO(); smsDTO.setMobile(mobile); smsDTO.setMessage("充值成功"); mqService.sendMessage(MQConst.EXCHANGE_TOPIC_SMS,MQConst.ROUTING_SMS_ITEM,smsDTO); return "success"; }service-sms中监听消息
pom
<!-- 需要依赖rabbit-mq --><dependency><groupId>com.indi</groupId><artifactId>rabbit-mq</artifactId><version>1.0-SNAPSHOT</version></dependency>yml
application.yml
#spring: rabbitmq: host: 虚拟机ip port: 5672 virtual-host: /srbhost username: srbuser password: 123456创建MQ监听器
SmsReceiver.java
package com.indi.srb.sms.receiver;@Component@Slf4jpublic class SmsReceiver { @Resource private SmsService smsService; // 此处的exchange与key必须与发消息传的一致 @RabbitListener(bindings = @QueueBinding( value = @Queue(value = MQConst.QUEUE_SMS_ITEM, durable = "true"), exchange = @Exchange(value = MQConst.EXCHANGE_TOPIC_SMS), key = {MQConst.ROUTING_SMS_ITEM} )) public void send(SmsDTO smsDTO) throws IOException { log.info("SmsReceiver 消息监听"); Map<String, Object> param = new HashMap<>(); param.put("code", smsDTO.getMessage()); smsService.send(smsDTO.getMobile(), SmsProperties.TEMPLATE_CODE, param); }}测试
完成充值之后，登录的用户，手机上会收到充值成功的短信提醒。
springboot是什么
springboot一种全新的编程规范，其设计目的是用来简化新Spring应用的初始搭建以及开发过程，SpringBoot也是一个服务于框架的框架，服务范围是简化配置文件。
以上是“springboot整合RabbitMQ发送短信的实现方法”这篇文章的所有内容，感谢各位的阅读！希望分享的内容对大家有帮助，更多相关知识，欢迎关注编程网行业资讯频道！
