如何支持备用SMTP服务器列表？邮件发送代码优化咨询

一、现有代码的核心改进方向 #

现有代码仅依赖单一SMTP实例发送邮件，要支持多服务器切换，需从以下维度改造：

• 抽象SMTP客户端管理：放弃单一JavaMailSender依赖，维护一组对应不同SMTP服务器的预配置JavaMailSender实例。
• 失败状态追踪：为每个SMTP服务器维护连续失败计数器，达到2-3次阈值时触发切换逻辑。
• 切换策略实现：定义服务器选择规则，优先使用当前活跃服务器，触发切换后自动轮询下一个可用实例。
• 状态重置机制：服务器恢复可用时，重置其失败计数，可选自动切回原活跃服务器的逻辑。

二、成熟生产级方案选择 #

无需从零实现，推荐两种基于现有生态的可行方案：

1. Spring Boot动态JavaMailSender+自定义状态管理器 #

通过Spring配置多组JavaMailSender实例，封装一个SMTP服务器管理器实现切换逻辑，核心代码示例：

@Component
public class MultiSmtpEmailSender {
    private final List<JavaMailSender> mailSenders;
    private AtomicInteger currentIndex = new AtomicInteger(0);
    private final Map<Integer, AtomicInteger> failCounterMap = new ConcurrentHashMap<>();
    private static final int FAIL_THRESHOLD = 3;

    // 构造注入所有配置好的SMTP客户端实例
    public MultiSmtpEmailSender(List<JavaMailSender> mailSenders) {
        this.mailSenders = mailSenders;
        // 初始化每个服务器的失败计数器
        for (int i = 0; i < mailSenders.size(); i++) {
            failCounterMap.put(i, new AtomicInteger(0));
        }
    }

    public SendEmailResponse sendEmail(DtoEmailMessage dtoEmailMessage) {
        int current = currentIndex.get();
        JavaMailSender sender = mailSenders.get(current);
        try {
            MimeMessage mimeMessage = mimeMessageCreator.createMessage(dtoEmailMessage);
            sender.send(mimeMessage);
            // 发送成功，重置当前服务器的失败计数
            failCounterMap.get(current).set(0);
            return SendEmailResponse.ok(channelEmailMessage.getEmailNotification().getTo(), mimeMessage.getMessageID());
        } catch (UnsupportedEncodingException | MessagingException | RuntimeException e) {
            int failCount = failCounterMap.get(current).incrementAndGet();
            if (failCount >= FAIL_THRESHOLD) {
                // 切换到下一个服务器，循环轮询
                int nextIndex = (current + 1) % mailSenders.size();
                currentIndex.set(nextIndex);
                failCounterMap.get(nextIndex).set(0);
                // 切换后立即重试一次
                return sendEmail(dtoEmailMessage);
            }
            throw new EmailSendFailedException("SMTP服务器" + current + "发送失败，当前尝试次数：" + failCount, e);
        }
    }
}

多SMTP服务器配置示例：

@Configuration
public class MultiSmtpConfig {
    @Bean("smtpServer1")
    public JavaMailSender smtpServer1() {
        JavaMailSenderImpl sender = new JavaMailSenderImpl();
        sender.setHost("server1.example.com");
        sender.setPort(587);
        sender.setUsername("user1");
        sender.setPassword("pass1");
        // 配置协议、加密等参数
        Properties props = sender.getJavaMailProperties();
        props.put("mail.smtp.auth", "true");
        props.put("mail.smtp.starttls.enable", "true");
        return sender;
    }

    @Bean("smtpServer2")
    public JavaMailSender smtpServer2() {
        JavaMailSenderImpl sender = new JavaMailSenderImpl();
        sender.setHost("server2.example.com");
        sender.setPort(587);
        sender.setUsername("user2");
        sender.setPassword("pass2");
        // 相同的基础配置或自定义配置
        Properties props = sender.getJavaMailProperties();
        props.put("mail.smtp.auth", "true");
        props.put("mail.smtp.starttls.enable", "true");
        return sender;
    }

    @Bean
    public List<JavaMailSender> mailSenders(@Qualifier("smtpServer1") JavaMailSender s1,
                                           @Qualifier("smtpServer2") JavaMailSender s2) {
        return Arrays.asList(s1, s2);
    }
}

2. 基于Resilience4j的熔断器切换方案 #

Resilience4j是轻量容错组件（替代已进入维护模式的Hystrix），可通过为每个SMTP服务器配置熔断器实现故障切换：

• 为每个JavaMailSender绑定一个CircuitBreaker，当失败次数达到阈值时，熔断器自动打开。
• 发送邮件时遍历服务器列表，选择第一个熔断器处于关闭状态的服务器使用。
• 熔断器会自动监控服务器状态，恢复可用时自动关闭，无需手动维护失败计数。

这种方案的优势是借助成熟组件实现故障状态管理，减少自定义代码量。

三、Spring Retry/Hystrix不适用的原因 #

• Spring Retry：仅针对同一实例的重试逻辑，无法直接实现多实例切换，需额外结合状态管理，效率低于自定义管理器。
• Hystrix：核心是单一依赖的熔断降级，不支持多实例轮询切换场景，且已停止迭代更新。

四、生产环境额外注意事项 #

• 状态持久化：若服务重启会丢失失败计数，可将状态存储到Redis等介质中，保证切换逻辑的连续性。
• 监控与报警：监控每个SMTP服务器的失败次数、切换频率，所有服务器连续失败时触发运维报警。
• 重试边界控制：切换服务器后的重试次数需限制，避免无限循环占用资源。

内容的提问来源于stack exchange，提问作者gstackoverflow