上一篇已經介紹了什麼是rabbitmq以及和springboot整合方法，也介紹了springboot整合郵件的方式，不瞭解的可以先看以前寫的文章。

三者整合

上一篇springboot整合郵件註冊的已經介紹了，本篇文章基於這個介紹，我們只需要修改下面幾處即可完成3者整合。

實現步驟

新增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實現類

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);
  }

現在就完成了，當用戶傳送註冊資訊的時候，會推送給rabbitmq，然後我們只需要定義個方法新增上@RabbitListener(queues = "email.direct")註解進行實時監聽， 注意主啟動類上需要新增@EnableRabbit開啟rabbit ，當監聽到使用者註冊的時候，不需要一直等待發送郵件成功，就可以先將頁面返回給使用者，而不是一直等待，頁面一直載入不了（瀏覽器一直轉圈），使使用者體驗變差，這就是用rabbitmq實現非同步操作的最簡單用法。

測試

這裡就直接截個圖，可以對比下上一篇同步序列使用者註冊傳送郵件耗時。

具體程式碼我已經上傳到了github，如果有問題可以參考下。前往

以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支援我們。