SpringBoot异步处理实战指南

@SpringBootApplication
@EnableAsync
public class DemoApplication {
    public static void main(String[] args) {
        SpringApplication.run(DemoApplication.class, args);
    }
}

@Configuration
public class AsyncConfig implements AsyncConfigurer {
    @Override
    public Executor getAsyncExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setCorePoolSize(5);
        executor.setMaxPoolSize(10);
        executor.setQueueCapacity(100);
        executor.initialize();
        return executor;
    }
}

public interface EmailService {
    @Async  // 标注为异步方法
    void sendEmail(String to, String subject, String content);
}

@Service
public class EmailServiceImpl implements EmailService {
    @Override
    public void sendEmail(String to, String subject, String content) {
        // 模拟耗时操作
        try {
            Thread.sleep(3000);
            System.out.println("邮件已发送至: " + to);
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        }
    }
}

@RestController
@RequestMapping("/api")
public class EmailController {
    @Autowired
    private EmailService emailService;
    @GetMapping("/send")
    public ResponseEntity<String> sendMail() {
        emailService.sendEmail("user@example.com", "测试主题", "异步邮件内容");
        return ResponseEntity.ok("请求已接收，邮件处理中..."); // 立即返回响应
    }
}