SpringBoot集成RabbitMQ實(shí)現(xiàn)用戶注冊(cè)的示例代碼
上一篇已經(jīng)介紹了什么是rabbitmq以及和springboot集成方法,也介紹了springboot集成郵件的方式,不了解的可以先看以前寫的文章。
三者集成
上一篇springboot集成郵件注冊(cè)的已經(jīng)介紹了,本篇文章基于這個(gè)介紹,我們只需要修改下面幾處即可完成3者集成。
實(shí)現(xiàn)步驟
添加rabbitmq依賴
<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-amqp</artifactId> </dependency>
添加rabbitmq配置
spring: rabbitmq: addresses: 127.0.0.1 username: guest password: guest port: 5672
修改controller類
package com.lytw13.demo.controller; import com.lytw13.demo.model.TbUser; import com.lytw13.demo.service.UserService; import com.lytw13.demo.util.MailUtil; import org.springframework.amqp.rabbit.annotation.RabbitListener; import org.springframework.amqp.rabbit.core.RabbitTemplate; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.PostMapping; import org.springframework.web.bind.annotation.RequestBody; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; @RestController @RequestMapping("user") public class UserController { @Autowired UserService userService; @Autowired RabbitTemplate rabbitTemplate; @PostMapping("save") public void save(@RequestBody TbUser user) { userService.save(user); rabbitTemplate.convertAndSend("email.direct","email.direct",user); } }
修改service實(shí)現(xiàn)類
public void save(TbUser user) { long startTime = System.currentTimeMillis(); userMapper.insert(user); long endTime = System.currentTimeMillis(); System.out.println("耗時(shí):"+(endTime-startTime)); } @RabbitListener(queues = "email.direct") public void sendEmail(TbUser user) { List<String> fileList = new ArrayList<>(); fileList.add("E:\\others\\MyBlog\\新建文本文檔1.txt"); fileList.add("E:\\others\\MyBlog\\新建文本文檔.txt"); MailUtil.sendHtmlTemplateMail(user.getEmail(),user.getName(),fileList); }
現(xiàn)在就完成了,當(dāng)用戶發(fā)送注冊(cè)信息的時(shí)候,會(huì)推送給rabbitmq,然后我們只需要定義個(gè)方法添加上@RabbitListener(queues = "email.direct")注解進(jìn)行實(shí)時(shí)監(jiān)聽(tīng), 注意主啟動(dòng)類上需要添加@EnableRabbit開(kāi)啟rabbit ,當(dāng)監(jiān)聽(tīng)到用戶注冊(cè)的時(shí)候,不需要一直等待發(fā)送郵件成功,就可以先將頁(yè)面返回給用戶,而不是一直等待,頁(yè)面一直加載不了(瀏覽器一直轉(zhuǎn)圈),使用戶體驗(yàn)變差,這就是用rabbitmq實(shí)現(xiàn)異步操作的最簡(jiǎn)單用法。
測(cè)試
這里就直接截個(gè)圖,可以對(duì)比下上一篇同步串行用戶注冊(cè)發(fā)送郵件耗時(shí)。
具體代碼我已經(jīng)上傳到了github,如果有問(wèn)題可以參考下。前往
以上就是本文的全部?jī)?nèi)容,希望對(duì)大家的學(xué)習(xí)有所幫助,也希望大家多多支持我們。
上一篇:Spring Boot企業(yè)常用的starter示例詳解
欄 目:Java
本文標(biāo)題:SpringBoot集成RabbitMQ實(shí)現(xiàn)用戶注冊(cè)的示例代碼
本文地址:http://mengdiqiu.com.cn/a1/Java/8808.html
您可能感興趣的文章
- 01-10Springboot中@Value的使用詳解
- 01-10springboot實(shí)現(xiàn)文件上傳步驟解析
- 01-10springboot jta atomikos實(shí)現(xiàn)分布式事物管理
- 01-10SpringBoot使用RabbitMQ延時(shí)隊(duì)列(小白必備)
- 01-10Java搭建RabbitMq消息中間件過(guò)程詳解
- 01-10如何基于SpringBoot部署外部Tomcat過(guò)程解析
- 01-10springboot集成fastDfs過(guò)程代碼實(shí)例
- 01-10SPRINGBOOT讀取PROPERTIES配置文件數(shù)據(jù)過(guò)程詳解
- 01-10springboot 配置DRUID數(shù)據(jù)源的方法實(shí)例分析
- 01-10springboot2.0使用Hikari連接池的方法(替換druid)


閱讀排行
- 1C語(yǔ)言 while語(yǔ)句的用法詳解
- 2java 實(shí)現(xiàn)簡(jiǎn)單圣誕樹的示例代碼(圣誕
- 3利用C語(yǔ)言實(shí)現(xiàn)“百馬百擔(dān)”問(wèn)題方法
- 4C語(yǔ)言中計(jì)算正弦的相關(guān)函數(shù)總結(jié)
- 5c語(yǔ)言計(jì)算三角形面積代碼
- 6什么是 WSH(腳本宿主)的詳細(xì)解釋
- 7C++ 中隨機(jī)函數(shù)random函數(shù)的使用方法
- 8正則表達(dá)式匹配各種特殊字符
- 9C語(yǔ)言十進(jìn)制轉(zhuǎn)二進(jìn)制代碼實(shí)例
- 10C語(yǔ)言查找數(shù)組里數(shù)字重復(fù)次數(shù)的方法
本欄相關(guān)
- 01-10Java實(shí)現(xiàn)動(dòng)態(tài)模擬時(shí)鐘
- 01-10Springboot中@Value的使用詳解
- 01-10JavaWeb實(shí)現(xiàn)郵件發(fā)送功能
- 01-10利用Java實(shí)現(xiàn)復(fù)制Excel工作表功能
- 01-10Java實(shí)現(xiàn)動(dòng)態(tài)數(shù)字時(shí)鐘
- 01-10java基于poi導(dǎo)出excel透視表代碼實(shí)例
- 01-10java實(shí)現(xiàn)液晶數(shù)字字體顯示當(dāng)前時(shí)間
- 01-10基于Java驗(yàn)證jwt token代碼實(shí)例
- 01-10Java動(dòng)態(tài)顯示當(dāng)前日期和時(shí)間
- 01-10淺談Java中真的只有值傳遞么
隨機(jī)閱讀
- 01-10SublimeText編譯C開(kāi)發(fā)環(huán)境設(shè)置
- 01-11Mac OSX 打開(kāi)原生自帶讀寫NTFS功能(圖文
- 08-05織夢(mèng)dedecms什么時(shí)候用欄目交叉功能?
- 01-10C#中split用法實(shí)例總結(jié)
- 04-02jquery與jsp,用jquery
- 01-10delphi制作wav文件的方法
- 01-11ajax實(shí)現(xiàn)頁(yè)面的局部加載
- 01-10使用C語(yǔ)言求解撲克牌的順子及n個(gè)骰子
- 08-05dedecms(織夢(mèng))副欄目數(shù)量限制代碼修改
- 08-05DEDE織夢(mèng)data目錄下的sessions文件夾有什