基于 Spring Boot 與 RabbitMQ 的郵件發(fā)送：確保 100%消息成功投遞

作者：編程疏影 2024-08-12 12:17:03

RabbitMQ 猶如一位堅定的衛(wèi)士，確保了郵件發(fā)送任務(wù)的可靠排隊和精細(xì)處理；而 Spring Boot 則宛如一位智慧的導(dǎo)師，提供了便捷的開發(fā)環(huán)境和豐富多樣的功能支持。

在當(dāng)今的企業(yè)級應(yīng)用開發(fā)中，郵件發(fā)送是一個常見且重要的功能需求。為了確保郵件能夠穩(wěn)定、高效且 100%成功投遞，我們可以結(jié)合 Spring Boot 和 RabbitMQ 來實現(xiàn)這一目標(biāo)。

技術(shù)選型與框架介紹

在構(gòu)建郵件發(fā)送系統(tǒng)時，我們精心挑選了 Spring Boot 和 RabbitMQ 這兩個強大的技術(shù)框架，并充分利用它們各自的優(yōu)勢來實現(xiàn)高效、可靠的郵件投遞功能。

Spring Boot 作為一款出色的快速開發(fā)框架，為我們提供了諸多便利。它基于 Spring 框架，但極大地簡化了項目的配置和部署流程。憑借其內(nèi)置的自動配置機制，開發(fā)者無需繁瑣地處理各種基礎(chǔ)配置，能夠迅速搭建起項目的基本架構(gòu)。同時，Spring Boot 對各種主流技術(shù)和組件的良好集成性，使得我們能夠輕松引入所需的依賴，快速構(gòu)建功能豐富的應(yīng)用。

RabbitMQ 則是一款卓越的消息代理和隊列服務(wù)器，在分布式系統(tǒng)的消息傳遞中發(fā)揮著關(guān)鍵作用。其基于先進的消息隊列機制，能夠有效地應(yīng)對高并發(fā)場景下的消息處理需求。通過將郵件發(fā)送任務(wù)轉(zhuǎn)化為消息并放入隊列中，RabbitMQ 確保了任務(wù)的有序處理和可靠傳遞，即使在系統(tǒng)面臨高負(fù)載或出現(xiàn)故障的情況下，也能保證郵件發(fā)送不丟失、不重復(fù)，從而極大地提高了郵件投遞的成功率和穩(wěn)定性。

將 Spring Boot 和 RabbitMQ 相結(jié)合，能夠充分發(fā)揮兩者的優(yōu)勢。Spring Boot 提供了便捷的開發(fā)環(huán)境和高效的應(yīng)用架構(gòu)，而 RabbitMQ 則為郵件發(fā)送任務(wù)提供了可靠的排隊和處理機制，共同保障了郵件發(fā)送的高效性和 100%投遞成功率。

項目依賴配置（pom.xml）

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.7.10</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    <groupId>com.icoderoad</groupId>
    <artifactId>mail-sender</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>MailSender</name>
    <description>基于 Spring Boot 和 RabbitMQ 的郵件發(fā)送項目</description>

    <properties>
        <java.version>11</java.version>
    </properties>

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-mail</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.amqp</groupId>
            <artifactId>spring-rabbit</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-devtools</artifactId>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-thymeleaf</artifactId>
        </dependency>
    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>
</project>

YAML 屬性文件配置（application.yml）

spring:
  mail:
    host: smtp.example.com  # 替換為您的 SMTP 服務(wù)器地址
    port: 587  # 端口
    username: your_email@example.com  # 發(fā)件人郵箱
    password: your_password  # 郵箱密碼
    properties:
      mail.smtp.auth: true
      mail.smtp.starttls.enable: true

rabbitmq:
  host: localhost  # RabbitMQ 服務(wù)器地址
  port: 5672  # 端口
  username: guest
  password: guest

后端代碼實現(xiàn)

郵件發(fā)送服務(wù)類（MailService.java）

import lombok.RequiredArgsConstructor;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.mail.MailException;
import org.springframework.mail.SimpleMailMessage;
import org.springframework.mail.javamail.JavaMailSender;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Service;

import java.util.concurrent.ConcurrentHashMap;

@EnableScheduling
@Service
@RequiredArgsConstructor
public class MailService {

    private final JavaMailSender mailSender;
    private final RabbitTemplate rabbitTemplate;
    private static final int MAX_RETRY = 3; // 最大重試次數(shù)
    private static final Log LOGGER = LogFactory.getLog(MailService.class);

    private ConcurrentHashMap<String, Integer> retryMap = new ConcurrentHashMap<>();

    public boolean sendMail(String to, String subject, String content) {
        SimpleMailMessage message = new SimpleMailMessage();
        message.setTo(to);
        message.setSubject(subject);
        message.setText(content);

        int retryCount = 0;
        boolean sentSuccessfully = false;
        String key = to + "_" + subject;

        while (retryCount < MAX_RETRY &&!sentSuccessfully) {
            try {
                mailSender.send(message);
                sentSuccessfully = true;
                retryMap.remove(key);
            } catch (MailException e) {
                retryCount++;
                LOGGER.error("發(fā)送郵件失敗，重試次數(shù): " + retryCount + "，收件人: " + to + "，主題: " + subject, e);
                retryMap.put(key, retryCount);
            }
        }

        if (!sentSuccessfully) {
            LOGGER.error("郵件發(fā)送最終失敗，收件人: " + to + "，主題: " + subject);
        }

        return sentSuccessfully;
    }

    @Scheduled(fixedDelay = 60000) // 每分鐘執(zhí)行一次
    public void retryFailedMails() {
        for (String key : retryMap.keySet()) {
            String[] parts = key.split("_");
            String to = parts[0];
            String subject = parts[1];

            SimpleMailMessage message = new SimpleMailMessage();
            message.setTo(to);
            message.setSubject(subject);

            int retryCount = retryMap.get(key);
            boolean sentSuccessfully = false;

            while (retryCount < MAX_RETRY &&!sentSuccessfully) {
                try {
                    mailSender.send(message);
                    sentSuccessfully = true;
                    retryMap.remove(key);
                } catch (MailException e) {
                    retryCount++;
                    if (!sentSuccessfully) {
                        rabbitTemplate.convertAndSend("retryQueue", key);
                        LOGGER.error("重試郵件發(fā)送失敗，已發(fā)送到隊列，收件人: " + to + "，主題: " + subject);
                    }
                }
            }

            if (!sentSuccessfully) {
                LOGGER.error("重試郵件發(fā)送最終失敗，收件人: " + to + "，主題: " + subject);
            }
        }
    }
}

要合理設(shè)置最大重試次數(shù)，避免過度重試導(dǎo)致資源浪費。同時，在重試間隔上也需要根據(jù)實際情況進行合理的設(shè)計，以平衡成功率和性能。還需要對重試過程中的異常情況進行更詳細(xì)的記錄和監(jiān)控，將重試仍不成功的郵件發(fā)送信息發(fā)送到隊列，方便后續(xù)進一步處理，提高了系統(tǒng)的靈活性和容錯性。

RabbitMQ 配置類（RabbitMQConfig.java）

import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class RabbitMQConfig {

    @Bean
    public Queue mailQueue() {
        return new Queue("mail_queue");
    }
}

RabbitMQ 消費者（MailConsumer.java）

import lombok.RequiredArgsConstructor;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

@Component
@RequiredArgsConstructor
public class MailConsumer {

    private final MailService mailService;

    @RabbitListener(queues = "mail_queue")
    public void consumeMailMessage(String message) {
        // 解析消息，提取收件人、主題和內(nèi)容等信息
        String[] parts = message.split(";");
        String to = parts[0];
        String subject = parts[1];
        String content = parts[2];
        mailService.sendMail(to, subject, content);
    }
}

控制器類（MailController.java）

import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class MailController {

    private final RabbitTemplate rabbitTemplate;

    public MailController(RabbitTemplate rabbitTemplate) {
        this.rabbitTemplate = rabbitTemplate;
    }

    @PostMapping("/sendMail")
    public String sendMail(@RequestBody MailRequest request) {
        // 將郵件信息轉(zhuǎn)換為字符串，發(fā)送到 RabbitMQ 隊列
        String message = request.getTo() + ";" + request.getSubject() + ";" + request.getContent();
        // 發(fā)送到隊列
        rabbitTemplate.convertAndSend("mail_queue", message);
        return "郵件發(fā)送請求已提交";
    }
}

前端頁面實現(xiàn)

使用 Thymeleaf 模板和 JavaScript 實現(xiàn)前端頁面：

<!DOCTYPE html>
<html xmlns:th="http://www.thymeleaf.org">
<head>
    <meta charset="UTF-8">
    <title>郵件發(fā)送</title>
    <script src="https://ajax.googleapis.com/ajax/libs/jquery/3.5.1/jquery.min.js"></script>
</head>
<body>
    <h2>郵件發(fā)送</h2>
    <form th:action="@{/sendMail}" method="post">
        <label for="to">收件人：</label><input type="text" id="to" name="to"><br>
        <label for="subject">主題：</label><input type="text" id="subject" name="subject"><br>
        <label for="content">內(nèi)容：</label><textarea id="content" name="content"></textarea><br>
        <button type="submit">發(fā)送</button>
    </form>
    <div id="result"></div>

    <script>
        $(document).ready(function() {
            $("form").submit(function(event) {
                event.preventDefault();
                var to = $("#to").val();
                var subject = $("#subject").val();
                var content = $("#content").val();
                $.ajax({
                    url: $(this).attr("action"),
                    type: "POST",
                    data: JSON.stringify({
                        "to": to,
                        "subject": subject,
                        "content": content
                    }),
                    contentType: "application/json",
                    success: function(response) {
                        $("#result").text(response);
                    },
                    error: function() {
                        $("#result").text("發(fā)送失敗");
                    }
                });
            });
        });
    </script>
</body>
</html>

通過以上精心設(shè)計的架構(gòu)和精妙絕倫的代碼實現(xiàn)，我們成功地借助 Spring Boot 和 RabbitMQ 的強大力量，構(gòu)建出一個能夠確保 100%消息成功投遞的郵件發(fā)送系統(tǒng)。在此過程中，RabbitMQ 猶如一位堅定的衛(wèi)士，確保了郵件發(fā)送任務(wù)的可靠排隊和精細(xì)處理；而 Spring Boot 則宛如一位智慧的導(dǎo)師，提供了便捷的開發(fā)環(huán)境和豐富多樣的功能支持。

責(zé)任編輯：武曉燕來源：路條編程