欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

springboot整合RabbitMQ發(fā)送短信的實現

 更新時間：2021年05月16日 09:19:59   作者：UnityAlvin  
本文會和SpringBoot做整合，實現RabbitMQ發(fā)送短信，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧

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服務器設置

創(chuàng)建用戶

創(chuàng)建用戶 srbuser，配置管理員權限

在這里插入圖片描述

創(chuàng)建虛擬機

創(chuàng)建虛擬機 /srbhost，在Set permission中為新建的用戶分配訪問虛擬機 /srbhost 和 / 的權限

在這里插入圖片描述

在這里插入圖片描述

在這里插入圖片描述

實現發(fā)送短信

rabbit-mq

1、創(chuàng)建模塊

srb下創(chuàng)建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、創(chuàng)建MQConfig

MQConfig.java

package com.indi.srb.rabbitutil.config;

@Configuration
public class MQConfig {
    @Bean
    public MessageConverter messageConverter(){
        // json字符串轉換器
        return new Jackson2JsonMessageConverter();
    }
}

4、創(chuàng)建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、創(chuàng)建MQService

MQService.java

package com.indi.srb.rabbitutil.service;

@Service
@Slf4j
public class MQService {
    @Resource
    private AmqpTemplate amqpTemplate;

    /**
     * 發(fā)送消息
     * @param exchange  交換機
     * @param routingKey    路由
     * @param message   消息
     * @return
     */
    public boolean sendMessage(String exchange,String routingKey, Object message){
        log.info("發(fā)送消息");
        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中發(fā)送消息

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發(fā)送消息

UserAccountServiceImpl.java 充值回調方法的最后添加發(fā)送消息的代碼

    @Resource
    private UserInfoService userInfoService;

    @Resource
    private MQService mqService;

    @Transactional(rollbackFor = Exception.class)
    @Override
    public String notify(Map<String, Object> paramMap) {
        log.info("發(fā)消息");
        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中監(jiān)聽消息

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、創(chuàng)建MQ監(jiān)聽器

SmsReceiver.java

package com.indi.srb.sms.receiver;

@Component
@Slf4j
public class SmsReceiver {
    @Resource
    private SmsService smsService;

    // 此處的exchange與key必須與發(fā)消息傳的一致
    @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 消息監(jiān)聽");
        Map<String, Object> param = new HashMap<>();
        param.put("code", smsDTO.getMessage());
        smsService.send(smsDTO.getMobile(), SmsProperties.TEMPLATE_CODE, param);
    }
}

測試

完成充值之后，登錄的用戶，手機上會收到充值成功的短信提醒。

在這里插入圖片描述

在這里插入圖片描述

在這里插入圖片描述

到此這篇關于springboot整合RabbitMQ發(fā)送短信的實現的文章就介紹到這了,更多相關springboot RabbitMQ發(fā)送短信內容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家！

相關文章

  • Java中的SynchronousQueue阻塞隊列及使用場景解析

    Java中的SynchronousQueue阻塞隊列及使用場景解析

    這篇文章主要介紹了Java中的SynchronousQueue阻塞隊列及使用場景解析,SynchronousQueue 是 Java 中的一個特殊的阻塞隊列,它的主要特點是它的容量為0,這意味著 SynchronousQueue不會存儲任何元素,需要的朋友可以參考下
    2023-12-12
  • springboot新建項目pom.xml文件第一行報錯的解決

    springboot新建項目pom.xml文件第一行報錯的解決

    這篇文章主要介紹了springboot新建項目pom.xml文件第一行報錯的解決方案，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教
    2022-01-01
  • Java中為何要使用ArrayList

    Java中為何要使用ArrayList

    這篇文章主要介紹了Java中為何要使用ArrayList，幫助大家更好的理解和學習Java，感興趣的朋友可以了解下
    2020-09-09
  • Java Thread多線程開發(fā)中Object類詳細講解

    Java Thread多線程開發(fā)中Object類詳細講解

    這篇文章主要介紹了Java Thread多線程開發(fā)中Object類，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習吧
    2023-03-03
  • Java學習之如何進行JSON解析

    Java學習之如何進行JSON解析

    JSON(JavaScript?Object?Notation)是一種輕量級的數據交換格式，它算是JavaScript語言的一部分，與XML一樣都可以用于數據的存儲和傳輸，本文講給大家介紹如何進行JSON解析,需要的朋友可以參考下
    2023-12-12
  • Struts2相關的面試題整理分享

    Struts2相關的面試題整理分享

    這篇文章主要給大家總結整理了關于Struts2相關的面試題，文中先詳細介紹了關于struts2的工作原理、工作流程、攔截器和過濾器的區(qū)別以及什么要使用Struts2，然后分享了總結的一些關于Struts2面試的一些問題，需要的朋友可以參考借鑒，下面來一起看看吧。
    2017-11-11
  • Java簡明解讀代碼塊的應用

    Java簡明解讀代碼塊的應用

    所謂代碼塊是指用"{}"括起來的一段代碼，根據其位置和聲明的不同，可以分為普通代碼塊、構造塊、靜態(tài)塊、和同步代碼塊。如果在代碼塊前加上 synchronized關鍵字，則此代碼塊就成為同步代碼塊
    2022-07-07
  • SpringCloud?Ribbon負載均衡流程分析

    SpringCloud?Ribbon負載均衡流程分析

    在Eureka注冊中心中我們在添加完@LoadBalanced注解，即可實現負載均衡功能，現在一起探索一下負載均衡的原理（Ribbon），感興趣的朋友一起看看吧
    2024-03-03
  • Java連接并操作Sedna XML數據庫的方法

    Java連接并操作Sedna XML數據庫的方法

    這篇文章主要介紹了Java連接并操作Sedna XML數據庫的方法,較為詳細的說明了Sedna XML數據庫的原理與功能,并給出了基于java操作Sedna XML數據庫的方法,需要的朋友可以參考下
    2015-06-06
  • 一篇文章帶你Java多線程入門

    一篇文章帶你Java多線程入門

    這篇文章主要為大家介紹了Java多線程入門，具有一定的參考價值，感興趣的小伙伴們可以參考一下，希望能夠給你帶來幫助
    2022-01-01

最新評論