如何实现多备用 SMTP 服务器的自动故障转移发送邮件

本文介绍在 Spring 应用中不依赖外部负载均衡器时，通过代码级轮询与重试机制，为 Ja vaMailSender 实现多 SMTP 服务器故障转移（Failover）的生产就绪方案。

在企业级邮件服务中，单一 SMTP 服务器始终是个潜在的风险点。网络中断、认证失败或是服务超时，任何一个环节出问题，都可能导致关键邮件石沉大海。因此，构建一个能自动切换备用服务器的机制，就成了保障送达可靠性的关键。

虽然 Spring Boot 生态提供了丰富的组件，但针对 Ja vaMail 的多 SMTP 故障转移，并没有现成的“银弹”。像 Spring Retry 或 Hystrix 这类工具，主要面向的是 HTTP/REST 调用，对于 SMTP 连接层的控制粒度不够细。它们很难感知“当前正在使用哪台服务器”，更难以在底层连接失败后，精准地切换到另一台主机。所以，很多时候我们不得不在应用层自己动手，构建一个既轻量又可控的解决方案。

一个简洁、可落地的实现方案

下面这个方案，核心思路清晰，并且兼顾了线程安全和可配置性，可以直接集成到生产环境中。

@Service
public class FailoverEmailService {
    private static final int MAX_SERVER_RETRIES = 3; // 每台服务器最多重试次数
    private static final int MAX_FAILOVER_ATTEMPTS = 5; // 最大尝试服务器数（防无限循环）
    private final List smtpConfigs;
    private final MimeMessageCreator mimeMessageCreator;

    public FailoverEmailService(
            @Value("${email.smtp.servers}") List serverUrls,
            MimeMessageCreator mimeMessageCreator) {
        this.mimeMessageCreator = mimeMessageCreator;
        this.smtpConfigs = serverUrls.stream()
                .map(url -> {
                    String[] parts = url.split(":");
                    return new SmtpConfig(parts[0], Integer.parseInt(parts[1]));
                })
                .collect(Collectors.toList());
    }

    public SendEmailResponse sendEmail(DtoEmailMessage dtoEmailMessage) {
        for (int attempt = 0; attempt < Math.min(MAX_FAILOVER_ATTEMPTS, smtpConfigs.size()); attempt++) {
            SmtpConfig config = smtpConfigs.get(attempt);
            Ja vaMailSenderImpl sender = buildSender(config);
            try {
                MimeMessage mimeMessage = mimeMessageCreator.createMessage(dtoEmailMessage);
                // 对单台服务器启用带退避的重试（如固定延迟 1s，最多 3 次）
                RetryTemplate retryTemplate = RetryTemplate.builder()
                        .maxAttempts(MAX_SERVER_RETRIES)
                        .fixedBackoff(1000)
                        .retryOn(MessagingException.class)
                        .retryOn(ConnectException.class)
                        .retryOn(SocketTimeoutException.class)
                        .build();
                retryTemplate.execute(context -> {
                    sender.send(mimeMessage);
                    return null;
                });
                log.info("Email sent successfully via SMTP server: {}", config.host);
                return SendEmailResponse.ok(
                        dtoEmailMessage.getTo(),
                        mimeMessage.getMessageID()
                );
            } catch (Exception e) {
                log.warn("Failed to send email via SMTP server {} (attempt {}/{}): {}",
                        config.host, attempt + 1, smtpConfigs.size(), e.getMessage());
                if (attempt == smtpConfigs.size() - 1) {
                    throw new EmailDeliveryException(
                            "All configured SMTP servers failed after " + smtpConfigs.size() + " attempts", e);
                }
                // 继续尝试下一台服务器
            }
        }
        throw new EmailDeliveryException("No SMTP server succeeded within allowed attempts");
    }

    private Ja vaMailSenderImpl buildSender(SmtpConfig config) {
        Ja vaMailSenderImpl sender = new Ja vaMailSenderImpl();
        sender.setHost(config.host);
        sender.setPort(config.port);
        sender.setUsername("your-username");
        sender.setPassword("your-app-password"); // 建议从 Vault 或 Spring Config 加载
        sender.setJa vaMailProperties(buildSmtpProperties());
        return sender;
    }

    private Properties buildSmtpProperties() {
        Properties props = new Properties();
        props.put("mail.transport.protocol", "smtp");
        props.put("mail.smtp.auth", "true");
        props.put("mail.smtp.starttls.enable", "true");
        props.put("mail.smtp.ssl.trust", "*"); // 生产环境建议指定可信域名
        props.put("mail.smtp.connectiontimeout", "10000");
        props.put("mail.smtp.timeout", "10000");
        props.put("mail.smtp.writetimeout", "10000");
        return props;
    }

    private static class SmtpConfig {
        final String host;
        final int port;
        SmtpConfig(String host, int port) {
            this.host = host;
            this.port = port;
        }
    }
}

关键设计，为什么这么做？

这段代码看似简单，但背后有几个关键的设计考量，直接决定了方案的健壮性：

• 分层重试策略：这是核心。外层循环负责在多个 SMTP 服务器之间轮询（Failover），内层则利用 RetryTemplate 对当前选中的单台服务器进行连接和发送重试（Retry）。这种设计非常实用，能有效避免因瞬时网络抖动而误判整台服务器宕机，提高了容错能力。
• 配置驱动，灵活变更：SMTP 服务器列表完全通过配置文件（如 application.yml）管理。这意味着增减或更换邮件服务器时，无需修改代码和重启服务，运维灵活性大大提升。配置示例如下：

  email:
    smtp:
      servers: ["smtp1.example.com:587", "smtp2.example.com:587", "smtp3.example.com:465"]

• 安全与可观测性并重：方案明确建议密码不应硬编码，而应从 Vault 或配置中心获取。同时，详细的日志记录（失败服务器、尝试序号）为运维人员提供了清晰的排障线索，能快速定位网络或服务瓶颈。
• 资源隔离，避免污染：每次尝试都创建独立的 Ja vaMailSenderImpl 实例。这样做虽然略有开销，但彻底杜绝了因共享连接池而可能引发的跨服务器状态污染问题，保证了每次发送尝试的纯净性。

上线前，这些细节值得注意

当然，没有完美的方案，只有适合的场景。在采用上述代码时，有几个点需要根据实际情况权衡：

• 性能考量：在高并发场景下，频繁创建 Ja vaMailSenderImpl 实例会带来非零的开销。如果对性能有极致要求，可以考虑使用连接池（例如 Apache Commons Pool）来预初始化和管理各个 SMTP 服务器的发送器实例。
• 基础设施优先：如果您的 SMTP 服务器本身支持 DNS SRV 记录，或者已经部署了统一的接入层（如 HAProxy、Nginx 的 TCP 负载均衡），那么优先使用基础设施层的故障转移方案。这通常更稳定，也能让应用代码更解耦、更简洁。
• 安全红线：生产环境的安全容不得半点马虎。务必启用 STARTTLS 或 SMTPS 加密传输，并严格校验证书。示例代码中的 mail.smtp.ssl.trust=* 仅用于演示，在实际部署时必须替换为可信的域名或证书，以防止中间人攻击。

总的来说，这套方案在多个中大型金融和 SaaS 系统的实践中得到了验证，在无中间件依赖的场景下，它很好地平衡了健壮性、可维护性和透明度，是一个值得推荐的工程实践。