springboot整合RabbitMQ发送短信的实现方法

这篇文章主要介绍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 # 启动RabbitMQ systemctl 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

1、创建模块

srb下创建rabbit-mq模块

2、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>

3、创建MQConfig

MQConfig.java

package com.indi.srb.rabbitutil.config; @Configuration public class MQConfig {     @Bean     public MessageConverter messageConverter(){         // json字符串转换器         return new Jackson2JsonMessageConverter();     } }

4、创建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";//消息队列 }

5、创建MQService

MQService.java

package com.indi.srb.rabbitutil.service; @Service @Slf4j public class MQService {     @Resource     private AmqpTemplate amqpTemplate;     /**      * 发送消息      * @param exchange  交换机      * @param routingKey    路由      * @param message   消息      * @return      */     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中发送消息

1、pom

<!-- 需要依赖rabbit-mq -->	<dependency>	<groupId>com.indi</groupId>	<artifactId>rabbit-mq</artifactId>	<version>1.0-SNAPSHOT</version>	</dependency>

2、yml

application.yaml

  #spring:   rabbitmq:     host: 虚拟机ip     port: 5672     virtual-host: /srbhost     username: srbuser     password: 123456

3、UserInfoService

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();     }

4、向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中监听消息

1、pom

<!-- 需要依赖rabbit-mq -->	<dependency>	<groupId>com.indi</groupId>	<artifactId>rabbit-mq</artifactId>	<version>1.0-SNAPSHOT</version>	</dependency>

2、yml

application.yml

  #spring:   rabbitmq:     host: 虚拟机ip     port: 5672     virtual-host: /srbhost     username: srbuser     password: 123456

3、创建MQ监听器

SmsReceiver.java

package com.indi.srb.sms.receiver; @Component @Slf4j public 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发送短信的实现方法”这篇文章的所有内容，感谢各位的阅读！希望分享的内容对大家有帮助，更多相关知识，欢迎关注亿速云行业资讯频道！