SpringBoot整合异步任务实现发送邮件

<dependencies>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-mail</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-test</artifactId>
    </dependency>
    <dependency>
        <groupId>org.projectlombok</groupId>
        <artifactId>lombok</artifactId>
    </dependency>
</dependencies>

server:
  port: 8087
spring:
  application:
    name: springboot-scheduled
  mail:
    # 配置 SMTP 服务器地址
    host: smtp.qq.com
    # 发送者邮箱
    username: 790933839@qq.com
    # 配置密码，注意不是真正的密码，而是刚刚申请到的授权码
    password: vjstfghblprwbdbd
    # 端口号465或587
    port: 587
    # 默认的邮件编码为UTF-8
    default-encoding: UTF-8
    # 配置SSL 加密工厂
    properties:
      mail:
        smtp:
          socketFactoryClass: javax.net.ssl.SSLSocketFactory
        #表示开启 DEBUG 模式，这样，邮件发送过程的日志会在控制台打印出来，方便排查错误
        debug: true

@Configuration
@EnableAsync // 开启异步配置
public class ThreadPoolTaskExecutorConfig {

    @Bean
    public TaskExecutor taskExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        //设置核心线程数
        executor.setCorePoolSize(10);
        //设置最大线程数
        executor.setMaxPoolSize(20);
        //缓冲队列200：用来缓冲执行任务的队列
        executor.setQueueCapacity(200);
        //线程活路时间 60 秒
        executor.setKeepAliveSeconds(60);
        //线程池名的前缀：设置好了之后可以方便我们定位处理任务所在的线程池
        executor.setThreadNamePrefix("taskExecutor-");
        //设置拒绝策略
        executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
        executor.setWaitForTasksToCompleteOnShutdown(true);
        return executor;
    }
}

@Data
@Accessors(chain = true)
public class Account {
    private String username;
    private String password;
    private String email;
}

public interface EmailService {
    /**用于注册成功后发送邮件 @param account 账号信息*/
    void senderEmail(Account account);
}


@Slf4j
@Service
public class EmailServiceImpl implements EmailService {
    
	@Autowired
    private JavaMailSender javaMailSender;

    @Async("taskExecutor")
    @Override
    public void senderEmail(Account account) {
        log.info(Thread.currentThread().getName());
        //一个复杂的邮件
        MimeMessage message = this.javaMailSender.createMimeMessage();
        try {
            //组装
            MimeMessageHelper helper = new MimeMessageHelper(message, true);
            //正文
            //主题
            helper.setSubject("小可爱，欢迎你的到来哦！！！");
            //开启html模式
            helper.setText("<h1>小可爱,我想你一定会喜欢这里吧！！！</h1>" +
                    "<p>你的账号为:"+account.getUsername()+"</p>" +
                    "<p>你的密码为："+account.getPassword()+"</p>", true);
            //附件
            helper.addAttachment("1.jpg", new File("C:\\Users\\ASUS\\Desktop\\杂七杂八\\杂图\\2.gif"));
            helper.setTo(account.getEmail());
            helper.setFrom("790933839@qq.com");
            javaMailSender.send(message);
        } catch (MessagingException e) {
            e.printStackTrace();
        }
    }
}

@Slf4j
@RestController
@RequestMapping("/async")
public class AsyncController {

    private static List<Account> accountList=new ArrayList<Account>();

    @Autowired
    private  TaskExecutor taskExecutor;

    @Autowired
    private  EmailService emailService;

    /**写一个注册发送邮件的栗子 */
    @PostMapping("/register")
    public String register(@RequestBody  Account account){
        accountList.add(account);
        emailService.senderEmail(account);
        log.info(Thread.currentThread().getName());
        return "OK";
    }
}