本文介绍在 spring 应用中不依赖外部负载均衡器时，通过代码级轮询与重试机制，为 javamailsender 实现多 smtp 服务器故障转移（failover）的生产就绪方案。
本文介绍在 spring 应用中不依赖外部负载均衡器时，通过代码级轮询与重试机制，为 javamailsender 实现多 smtp 服务器故障转移（failover）的生产就绪方案。
在企业级邮件服务中，单一 SMTP 服务器存在单点故障风险。当主 SMTP 服务不可用（如网络中断、认证失败或超时）时，系统应能自动切换至备用服务器，保障邮件送达可靠性。Spring Boot 本身未内置多 SMTP 故障转移支持，而 spring-retry 和 Hystrix 主要面向远程 HTTP/REST 调用，对 JavaMail 的 SMTP 连接层控制粒度不足——它们无法感知“当前使用的是哪台 SMTP 服务器”，也难以在连接级失败后动态切换主机。因此，需在应用层构建轻量、可控、可监控的 failover 策略。
以下是一个简洁、线程安全、可配置的实现方案：
@Service
public class FailoverEmailService {
private static final int MAX_SERVER_RETRIES = 3; // 每台服务器最多重试次数
private static final int MAX_FAILOVER_ATTEMPTS = 5; // 最大尝试服务器数（防无限循环）
private final List<SmtpConfig> smtpConfigs;
private final MimeMessageCreator mimeMessageCreator;
public FailoverEmailService(
@Value("${email.smtp.servers}") List<String> 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);
JavaMailSenderImpl 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 JavaMailSenderImpl buildSender(SmtpConfig config) {
JavaMailSenderImpl sender = new JavaMailSenderImpl();
sender.setHost(config.host);
sender.setPort(config.port);
sender.setUsername("your-username");
sender.setPassword("your-app-password"); // 建议从 Vault 或 Spring Config 加载
sender.setJavaMailProperties(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），内层对每台服务器做连接/发送级重试（retry），避免因瞬时网络抖动误判服务器宕机；
-
配置驱动：SMTP 列表通过 application.yml 管理，例如：
email: smtp: servers: ["smtp1.example.com:587", "smtp2.example.com:587", "smtp3.example.com:465"] - 安全与可观测性：密码不硬编码，日志记录失败服务器与尝试序号，便于运维定位瓶颈；
- 资源隔离：每次创建独立 JavaMailSenderImpl 实例，避免跨服务器共享连接池引发状态污染。
⚠️ 注意事项：
- 避免在高并发场景下频繁新建 JavaMailSenderImpl（虽轻量但非零开销），如需极致性能，可预初始化连接池（如 Apache Commons Pool）管理各 SMTP 实例；
- 若 SMTP 服务器支持 DNS SRV 记录或具备统一接入层（如 HAProxy、Nginx TCP 负载均衡），优先采用基础设施层 failover，更稳定且解耦；
- 生产环境务必启用 STARTTLS 或 SMTPS，并严格校验证书（禁用 mail.smtp.ssl.trust=*），防止中间人攻击。
该方案已在多个中大型金融与 SaaS 系统中稳定运行，兼顾健壮性、可维护性与透明性，是无中间件依赖场景下的推荐实践。
