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

來源：本站原創(chuàng)|時間：2020-01-10|欄目：Java|點擊：次

上一篇已經(jīng)介紹了什么是rabbitmq以及和springboot集成方法，也介紹了springboot集成郵件的方式，不了解的可以先看以前寫的文章。

三者集成

上一篇springboot集成郵件注冊的已經(jīng)介紹了，本篇文章基于這個介紹，我們只需要修改下面幾處即可完成3者集成。

實現(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實現(xiàn)類

public void save(TbUser user) {
    long startTime = System.currentTimeMillis();
    userMapper.insert(user);
    long endTime = System.currentTimeMillis();
    System.out.println("耗時："+(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ā)送注冊信息的時候，會推送給rabbitmq，然后我們只需要定義個方法添加上@RabbitListener(queues = "email.direct")注解進行實時監(jiān)聽， 注意主啟動類上需要添加@EnableRabbit開啟rabbit ，當(dāng)監(jiān)聽到用戶注冊的時候，不需要一直等待發(fā)送郵件成功，就可以先將頁面返回給用戶，而不是一直等待，頁面一直加載不了（瀏覽器一直轉(zhuǎn)圈），使用戶體驗變差，這就是用rabbitmq實現(xiàn)異步操作的最簡單用法。

測試

這里就直接截個圖，可以對比下上一篇同步串行用戶注冊發(fā)送郵件耗時。

具體代碼我已經(jīng)上傳到了github，如果有問題可以參考下。前往

以上就是本文的全部內(nèi)容，希望對大家的學(xué)習(xí)有所幫助，也希望大家多多支持我們。

上一篇：Spring Boot企業(yè)常用的starter示例詳解

欄目：Java

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

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

本文地址：http://www.jygsgssxh.com/a1/Java/8808.html

更多Java

雷火电竞-中国电竞赛事及体育赛事平台

Java

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

您可能感興趣的文章

閱讀排行

本欄相關(guān)

隨機閱讀