欧美大屁股bbbbxxxx,狼人大香伊蕉国产www亚洲,男ji大巴进入女人的视频小说,男人把ji大巴放进女人免费视频,免费情侣作爱视频

歡迎來(lái)到入門教程網(wǎng)!

Java

當(dāng)前位置:主頁(yè) > 軟件編程 > Java >

SpringBoot集成RabbitMQ實(shí)現(xiàn)用戶注冊(cè)的示例代碼

來(lái)源:本站原創(chuàng)|時(shí)間:2020-01-10|欄目:Java|點(diǎn)擊: 次

上一篇已經(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

下一篇:SpringBoot新手入門的快速教程

本文標(biāo)題:SpringBoot集成RabbitMQ實(shí)現(xiàn)用戶注冊(cè)的示例代碼

本文地址:http://mengdiqiu.com.cn/a1/Java/8808.html

網(wǎng)頁(yè)制作CMS教程網(wǎng)絡(luò)編程軟件編程腳本語(yǔ)言數(shù)據(jù)庫(kù)服務(wù)器

如果侵犯了您的權(quán)利,請(qǐng)與我們聯(lián)系,我們將在24小時(shí)內(nèi)進(jìn)行處理、任何非本站因素導(dǎo)致的法律后果,本站均不負(fù)任何責(zé)任。

聯(lián)系QQ:835971066 | 郵箱:835971066#qq.com(#換成@)

Copyright © 2002-2020 腳本教程網(wǎng) 版權(quán)所有