快捷導(dǎo)航

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

更新時(shí)間：2019年12月30日 14:16:34 作者：lytw1315

這篇文章主要介紹了SpringBoot集成RabbitMQ實(shí)現(xiàn)用戶(hù)注冊(cè)的示例代碼，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧

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

三者集成

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

實(shí)現(xiàn)步驟

添加rabbitmq依賴(lài)

<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類(lèi)

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)類(lèi)

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)用戶(hù)發(fā)送注冊(cè)信息的時(shí)候，會(huì)推送給rabbitmq，然后我們只需要定義個(gè)方法添加上@RabbitListener(queues = "email.direct")注解進(jìn)行實(shí)時(shí)監(jiān)聽(tīng)， 注意主啟動(dòng)類(lèi)上需要添加@EnableRabbit開(kāi)啟rabbit ，當(dāng)監(jiān)聽(tīng)到用戶(hù)注冊(cè)的時(shí)候，不需要一直等待發(fā)送郵件成功，就可以先將頁(yè)面返回給用戶(hù)，而不是一直等待，頁(yè)面一直加載不了（瀏覽器一直轉(zhuǎn)圈），使用戶(hù)體驗(yàn)變差，這就是用rabbitmq實(shí)現(xiàn)異步操作的最簡(jiǎn)單用法。

測(cè)試

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