Spring MVC异步Java邮件发送器无法发送全部邮件求助

我开发了一个Spring MVC Web应用，需要为大量用户操作发送邮件。最初用同步方式实现，连续执行4-5次操作时，邮件发送器无法发送全部邮件，仅能发送部分。改用@Async异步方法后，问题依然存在。

我的异步发送方法：

@Async
public Future<String> sendMail(MailParametersTO mailParams, MailTypeEnum type) {
    try {
        MimeMessage message = mailSender.createMimeMessage();
        message.setSubject(mailUtils.getMailSubject(mailParams.getSubjectParams(), type));
        MimeMessageHelper helper = new MimeMessageHelper(message, true, "UTF-8");
        helper.setFrom(from);
        helper.setCc(mailParams.getCc().toArray(new String[0])); 
        helper.setTo(mailParams.getTo().toArray(new String[0]));
        helper.setText(mailUtils.getMailBody(mailParams.getBodyParams(), mailParams.getLink(), type), true);
        Thread.sleep(30000);
        mailSender.send(message);
    } catch (Exception e) {
        e.printStackTrace();
        return new AsyncResult<>("ERROR");
    }
    return new AsyncResult<>("OK");
}   

异步配置类：

@Configuration
@EnableAsync(proxyTargetClass = true)
@EnableScheduling
public class AsyncConfig implements SchedulingConfigurer, AsyncConfigurer {

    @Bean
    public ThreadPoolTaskScheduler taskScheduler() {
        ThreadPoolTaskScheduler scheduler = new ThreadPoolTaskScheduler();
        scheduler.setPoolSize(2);
        scheduler.setThreadNamePrefix("task-");
        scheduler.setAwaitTerminationSeconds(1200); // 20 minutes
        scheduler.setWaitForTasksToCompleteOnShutdown(true);
        return scheduler;
    }

    @Override
    public Executor getAsyncExecutor() {
        return this.taskScheduler();
    }

    @Override
    public void configureTasks(ScheduledTaskRegistrar registrar) {
        TaskScheduler scheduler = this.taskScheduler();
        registrar.setTaskScheduler(scheduler);
    }

    @Override
    public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {
        return new SimpleAsyncUncaughtExceptionHandler();
    }
}

问题排查与修复方案 #

1. 调整线程池配置 #

当前线程池仅设置2个核心线程，加上方法内30秒的sleep，连续请求会导致任务排队甚至被拒绝。建议：

• 增大核心线程数，根据实际邮件发送量调整（比如设为10）
• 添加队列容量配置，避免任务被直接丢弃
• 配置合理的拒绝策略，防止任务丢失

修改后的taskScheduler配置：

@Bean
public ThreadPoolTaskScheduler taskScheduler() {
    ThreadPoolTaskScheduler scheduler = new ThreadPoolTaskScheduler();
    scheduler.setPoolSize(10); // 增大线程池大小
    scheduler.setQueueCapacity(100); // 设置任务队列缓冲容量
    scheduler.setThreadNamePrefix("mail-task-");
    scheduler.setAwaitTerminationSeconds(1200);
    scheduler.setWaitForTasksToCompleteOnShutdown(true);
    // 拒绝策略：让调用线程执行任务，避免直接丢弃
    scheduler.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
    return scheduler;
}

2. 移除冗余的Thread.sleep #

代码中的Thread.sleep(30000)完全是无效操作，会占用线程池线程，导致后续任务无法及时执行。直接删除这一行即可。

3. 完善异常处理与日志记录 #

当前仅打印堆栈信息，无法定位具体哪封邮件发送失败。建议使用日志框架（如SLF4J）记录详细错误信息：

private static final Logger logger = LoggerFactory.getLogger(YourMailService.class);

@Async
public Future<String> sendMail(MailParametersTO mailParams, MailTypeEnum type) {
    try {
        // 原有邮件构建逻辑
        mailSender.send(message);
        logger.info("邮件发送成功，收件人：{}", String.join(",", mailParams.getTo()));
        return new AsyncResult<>("OK");
    } catch (Exception e) {
        logger.error("邮件发送失败，收件人：{}，类型：{}", String.join(",", mailParams.getTo()), type, e);
        return new AsyncResult<>("ERROR");
    }
}

4. 配置邮件发送器连接池 #

使用JavaMailSender时，需要配置SMTP连接池，避免频繁创建连接被邮件服务器限流。在application.properties中添加：

spring.mail.properties.mail.smtp.connectionpoolsize=5
spring.mail.properties.mail.smtp.auth=true
spring.mail.properties.mail.smtp.starttls.enable=true
spring.mail.properties.mail.smtp.ssl.trust=你的SMTP服务器地址

5. 确保异步方法的正确调用 #

Spring的@Async基于AOP代理实现，同一个类内部调用异步方法不会触发异步逻辑。如果sendMail被当前类的其他方法调用，需要注入自身的代理对象：

@Service
public class MailService {
    @Autowired
    private MailService selfProxy; // 注入自身代理对象

    public void triggerMailSend(MailParametersTO mailParams, MailTypeEnum type) {
        // 通过代理对象调用异步方法
        selfProxy.sendMail(mailParams, type);
    }

    @Async
    public Future<String> sendMail(...) {
        // ...
    }
}

6. 排查邮件服务器限制 #

多数邮件服务商（如Gmail、国内主流邮箱）会限制并发发送数量或频率，需要确认是否触发了这些限制。可以联系服务商调整配额，或在必要时添加发送间隔（优先通过线程池和连接池优化）。

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