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 {@Beanpublic 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 {@Resourceprivate 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: 虚拟机ipport: 5672virtual-host: /srbhostusername: srbuserpassword: 123456

3、UserInfoService

UserInfoService.java

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

UserInfoServiceImpl.java

    @Overridepublic 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 充值回调方法的最后添加发送消息的代码

    @Resourceprivate UserInfoService userInfoService;@Resourceprivate MQService mqService;@Transactional(rollbackFor = Exception.class)@Overridepublic 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: 虚拟机ipport: 5672virtual-host: /srbhostusername: srbuserpassword: 123456

3、创建MQ监听器

SmsReceiver.java

package com.indi.srb.sms.receiver;@Component
@Slf4j
public class SmsReceiver {@Resourceprivate 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);}
}

测试

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

41. 整合RabbitMQ发送短信相关推荐

Flask实战第41天：发送短信验证码
本项目使用的短信运营商是阿里云.使用淘宝账号登录阿里云控制台.在"产品与服务"中搜索"短信"进入短信服务获取AccessKey 输入子账户用户名权限选择管理 ...
网建短信通使用java调用API发送短信时总是返回-41，关键的关键，仅在于一个问号:(
今天突发奇想做一个定时给女朋友发送表白短信的功能,发送短信的接口很多,不过基本都是收费的,情有可原.在网建短信通平台(http://sms.webchinese.cn/default.shtml)可以 ...
rabbitMQ的使用概述及使用rabbitMQ进行短信验证码发送案例
概述首先来看一张图在图中可以看到,用户注册通常需要完成两件事,向用户发送验证码码,及对用户验证码.信息的校对.初始化,在没有使用的MQ的项目中,验证码的生成.存储.发送都是由调用方法完成的,虽然可 ...
微服务架构集成RabbitMQ给用户推送消息（发送短信，发送邮件，发送站内信息）
因为是分布式微服务项目,所以发送方在一个微服务,接收方在另外的一个微服务,在发送方,导入RabbitMQ依赖包 <dependency>< ...
springboot整合redis实现发送短信验证码
我用的短信平台是阿里云的,需要付费购买服务,购买地址:https://common-buy.aliyun.com/?spm=5176.8195934.907839.sms6.312c4183mzE9Y ...
短信宝 php使用,[php] 使用短信宝发送短信（thinkphp）
/*** SmsBao实现类* @category Think* @package Think* @subpackage Sms*/classSmsBao { private$account;//短信 ...
中国网建java发送短信_短信验证登陆-中国网建提供的SMS短信平台
一.JAVA发送手机短信常见的有三种方式(如下所列): 使用webservice接口发送手机短信,这个可以使用sina提供的webservice进行发送,但是需要进行注册使用短信mao的方式进行短信 ...
java发送短信的发送报告处理
2019独角兽企业重金招聘Python工程师标准>>> 最近上线了一个推送系统.推送系统作用是将短信,邮件,app push等消息触达到用户.目前功能上只实现了短信通道,并且随着业务 ...
短信宝发送短信验证码
$statusStr = array("0" => "短信发送成功","-1" => "参数不全",&quo ...

41. 整合RabbitMQ发送短信

RabbitMQ安装和运行

MQ服务器设置

创建用户

创建虚拟机

实现发送短信

rabbit-mq

1、创建模块

2、pom

3、创建MQConfig

4、创建MQConst

5、创建MQService

service-base

dto

service-core中发送消息

1、pom

2、yml

3、UserInfoService

4、向MQ发送消息

service-sms中监听消息

1、pom

2、yml

3、创建MQ监听器

测试

41. 整合RabbitMQ发送短信相关推荐

最新文章

热门文章