本站首页 收藏本站
广告位联系

APP正在开发中...
返回顶部
您的位置： 主页 > 软件编程 > java >

收藏
分享到

springboot整合RabbitMQ发送短信的实现

java 来源：转载 作者：秩名 发布时间：2021-05-16 14:20:25 人浏览
摘要

RabbitMQ安装和运行 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 # 安装 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安装和运行

# 安装
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，不允许远程连接，需要添加管理员账户

1
2
3
4
5
6
7
8
9
10
11
# 添加管理员账号密码
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

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
<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

1
2
3
4
5
6
7
8
9
10
package com.indi.srb.rabbitutil.config;
 
@Configuration
public class MQConfig {
    @Bean
    public MessageConverter messageConverter(){
        // json字符串转换器
        return new Jackson2JsonMessageConverter();
    }
}

4、创建MQConst

MQConst.java

1
2
3
4
5
6
7
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

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
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

 

1
2
3
4
5
6
7
8
9
10
11
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

1
2
3
4
5
6
<!-- 需要依赖rabbit-mq -->
<dependency>
    <groupId>com.indi</groupId>
    <artifactId>rabbit-mq</artifactId>
    <version>1.0-SNAPSHOT</version>
</dependency>

2、yml

application.yaml

1
2
3
4
5
6
7
#spring:
rabbitmq:
  host: 虚拟机ip
  port: 5672
  virtual-host: /srbhost
  username: srbuser
  password: 123456

3、UserInfoService

UserInfoService.java

1
2
// 根据bindCode获取手机号
String getMobileByBindCode(String bindCode);

UserInfoServiceImpl.java

1
2
3
4
5
6
7
@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 充值回调方法的最后添加发送消息的代码

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
@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

1
2
3
4
5
6
<!-- 需要依赖rabbit-mq -->
<dependency>
    <groupId>com.indi</groupId>
    <artifactId>rabbit-mq</artifactId>
    <version>1.0-SNAPSHOT</version>
</dependency>

2、yml

application.yml

1
2
3
4
5
6
7
#spring:
rabbitmq:
  host: 虚拟机ip
  port: 5672
  virtual-host: /srbhost
  username: srbuser
  password: 123456

3、创建MQ监听器

SmsReceiver.java

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
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);
    }
}

测试

完成充值之后，登录的用户，手机上会收到充值成功的短信提醒。

在这里插入图片描述

在这里插入图片描述

在这里插入图片描述
版权声明 : 本文内容来源于互联网或用户自行发布贡献，该文观点仅代表原作者本人。本站仅提供信息存储空间服务和不拥有所有权，不承担相关法律责任。如发现本站有涉嫌抄袭侵权， 违法违规的内容， 请发送邮件至2530232025#qq.cn(#换@)举报，一经查实，本站将立刻删除。

您可能感兴趣的文章 :

原文链接 : https://blog.csdn.net/Alvin199765/article/details/116760715
相关文章

  • SpringBoot自定义错误处理逻辑介绍

    SpringBoot自定义错误处理逻辑介绍
    1. 自定义错误页面 将自定义错误页面放在 templates 的 error 文件夹下，SpringBoot 精确匹配错误信息，使用 4xx.html 或者 5xx.html 页面可以打印错误

  • Java实现手写一个线程池的代码

    Java实现手写一个线程池的代码
    线程池技术想必大家都不陌生把，相信在平时的工作中没有少用，而且这也是面试频率非常高的一个知识点，那么大家知道它的实现原理和

  • Java实现断点续传功能的代码

    Java实现断点续传功能的代码
    题目实现：网络资源的断点续传功能。 二、解题思路 获取要下载的资源网址 显示网络资源的大小 上次读取到的字节位置以及未读取的字节
  • 你可知HashMap为什么是线程不安全的
    HashMap 的线程不安全 HashMap 的线程不安全主要体现在下面两个方面 在 jdk 1.7 中，当并发执行扩容操作时会造成环形链和数据丢失的情况 在

  • ArrayList的动态扩容机制的介绍

    ArrayList的动态扩容机制的介绍
    对于 ArrayList 的动态扩容机制想必大家都听说过，之前的文章中也谈到过，不过由于时间久远，早已忘却。 所以利用这篇文章做做笔记，加

  • JVM基础之字节码的增强技术介绍

    JVM基础之字节码的增强技术介绍
    字节码增强技术 在上文中，着重介绍了字节码的结构，这为我们了解字节码增强技术的实现打下了基础。字节码增强技术就是一类对现有字

  • Java中的字节码增强技术

    Java中的字节码增强技术
    1.字节码增强技术 字节码增强技术就是一类对现有字节码进行修改或者动态生成全新字节码文件的技术。 参考地址 2.常见技术 技术分类 类

  • Redis BloomFilter布隆过滤器原理与实现

    Redis BloomFilter布隆过滤器原理与实现
    Bloom Filter 概念 布隆过滤器（英语：Bloom Filter）是1970年由一个叫布隆的小伙子提出的。它实际上是一个很长的二进制向量和一系列随机映射

  • Java C++算法题解leetcode801使序列递增的最小交换次

    Java C++算法题解leetcode801使序列递增的最小交换次
    题目要求 思路：状态机DP 实现一：状态机 Java 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 class Solution { public int minSwap(int[] nums1, int[] nums2) { int n

  • Mybatis结果集映射与生命周期介绍

    Mybatis结果集映射与生命周期介绍
    一、ResultMap结果集映射 1、设计思想 对简单的语句做到零配置，对于复杂一点的语句，只需要描述语句之间的关系就行了 2、resultMap的应用场
推荐阅读
最新更新
友情链接
  • 本站所有内容来源于互联网或用户自行发布，本站仅提供信息存储空间服务，不拥有版权，不承担法律责任。如有侵犯您的权益，请您联系站长处理！
  • Copyright © 2017-2022 F11.CN All Rights Reserved. F11站长开发者网 版权所有 | 苏ICP备2022031554号-1 | 51LA统计