在 Spring Boot 中触发异步任务进行心理健康评估，可通过以下方式实现，各有优缺点：
1. 使用 @Async 注解
实现原理：基于 Spring 的异步支持，通过线程池执行异步任务。
案例：
// 配置类启用异步并自定义线程池
@Configuration
@EnableAsync
public class AsyncConfig {@Bean(name = "taskExecutor")public Executor taskExecutor() {ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();executor.setCorePoolSize(5);executor.setMaxPoolSize(10);executor.setQueueCapacity(25);executor.setThreadNamePrefix("Async-");executor.initialize();return executor;}
}// 服务类
@Service
public class AssessmentService {@Async("taskExecutor")public void performMentalHealthAssessment(User user) {// 模拟耗时评估逻辑// ...}
}// 控制器调用
@RestController
public class AssessmentController {@Autowiredprivate AssessmentService assessmentService;@PostMapping("/trigger-assessment")public ResponseEntity<String> triggerAssessment(@RequestBody User user) {assessmentService.performMentalHealthAssessment(user);return ResponseEntity.ok("评估已异步触发");}
}
优点：
- 简单易用，只需添加注解和配置线程池。
- 与 Spring 生态无缝集成。
缺点：
- 默认使用
SimpleAsyncTaskExecutor（不重用线程），需手动配置线程池优化性能。 - 异步方法需在
public方法上调用，且同一类内部调用会失效（代理问题）。 - 异常处理需通过
AsyncUncaughtExceptionHandler自定义。
2. 消息队列（如 RabbitMQ）
实现原理：通过消息中间件解耦，生产者发布任务，消费者异步处理。
案例：
// 生产者（控制器）
@RestController
public class AssessmentController {@Autowiredprivate RabbitTemplate rabbitTemplate;@PostMapping("/trigger-assessment")public ResponseEntity<String> triggerAssessment(@RequestBody User user) {rabbitTemplate.convertAndSend("assessmentExchange", "assessment.routingKey", user);return ResponseEntity.ok("评估任务已发送至消息队列");}
}// 消费者
@Component
public class AssessmentConsumer {@RabbitListener(queues = "assessmentQueue")public void handleAssessment(User user) {// 处理心理健康评估// ...}
}
优点：
- 完全解耦，适用于分布式系统。
- 支持消息持久化、重试机制和流量削峰。
缺点：
- 需要额外维护消息中间件（如 RabbitMQ/Kafka）。
- 增加了系统复杂度，需处理消息丢失、重复消费等问题。
3. CompletableFuture（手动异步）
实现原理：利用 Java 8 的 CompletableFuture 手动管理异步任务。
案例：
@Service
public class AssessmentService {@Autowiredprivate Executor taskExecutor;public CompletableFuture<Void> performMentalHealthAssessment(User user) {return CompletableFuture.runAsync(() -> {// 模拟耗时评估逻辑// ...}, taskExecutor);}
}// 控制器调用
@PostMapping("/trigger-assessment")
public CompletableFuture<ResponseEntity<String>> triggerAssessment(@RequestBody User user) {return assessmentService.performMentalHealthAssessment(user).thenApplyAsync(unused -> ResponseEntity.ok("评估完成"));
}
优点：
- 灵活控制异步流程，支持链式调用和结果组合。
- 可自定义线程池，避免资源竞争。
缺点：
- 代码复杂度较高，需手动处理异常和超时。
- 不适合简单的“触发后不管”场景。
4. Spring Events（应用内事件）
实现原理：通过发布-订阅模型实现异步事件监听。
案例：
// 定义事件
public class AssessmentEvent extends ApplicationEvent {private User user;public AssessmentEvent(Object source, User user) {super(source);this.user = user;}// getter
}// 发布者（控制器）
@RestController
public class AssessmentController {@Autowiredprivate ApplicationEventPublisher eventPublisher;@PostMapping("/trigger-assessment")public ResponseEntity<String> triggerAssessment(@RequestBody User user) {eventPublisher.publishEvent(new AssessmentEvent(this, user));return ResponseEntity.ok("评估事件已发布");}
}// 异步监听者
@Component
public class AssessmentListener {@Async@EventListenerpublic void handleAssessmentEvent(AssessmentEvent event) {// 处理评估逻辑// ...}
}
优点：
- 松耦合，便于扩展多个监听器。
- 无需引入外部组件。
缺点：
- 仅适用于单应用内，不支持分布式。
- 默认同步执行，需配合
@Async实现异步。
对比总结
| 方法 | 适用场景 | 优点 | 缺点 |
|---|---|---|---|
@Async | 简单异步任务 | 集成简单，适合轻量级场景 | 需处理线程池和异常，同类调用失效 |
| 消息队列 | 分布式系统、高可靠性场景 | 解耦彻底，支持重试和削峰 | 维护中间件，复杂度高 |
CompletableFuture | 复杂异步流程控制 | 灵活，支持链式调用 | 代码复杂，需手动管理 |
| Spring Events | 应用内事件通知 | 松耦合，易于扩展监听器 | 不支持分布式，依赖 @Async |
根据实际场景选择：轻量级任务用 @Async，分布式需求用消息队列，复杂流程用 CompletableFuture，应用内解耦用事件监听。
