// 配置類(lèi)啟用異步并自定義線程池
@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;
    }
}

// 服務(wù)類(lèi)
@Service
public class AssessmentService {
    @Async("taskExecutor")
    public void performMentalHealthAssessment(User user) {
        // 模擬耗時(shí)評(píng)估邏輯
        // ...
    }
}

// 控制器調(diào)用
@RestController
public class AssessmentController {
    @Autowired
    private AssessmentService assessmentService;

    @PostMapping("/trigger-assessment")
    public ResponseEntity<String> triggerAssessment(@RequestBody User user) {
        assessmentService.performMentalHealthAssessment(user);
        return ResponseEntity.ok("評(píng)估已異步觸發(fā)");
    }
}

// 生產(chǎn)者（控制器）
@RestController
public class AssessmentController {
    @Autowired
    private RabbitTemplate rabbitTemplate;

    @PostMapping("/trigger-assessment")
    public ResponseEntity<String> triggerAssessment(@RequestBody User user) {
        rabbitTemplate.convertAndSend("assessmentExchange", "assessment.routingKey", user);
        return ResponseEntity.ok("評(píng)估任務(wù)已發(fā)送至消息隊(duì)列");
    }
}

// 消費(fèi)者
@Component
public class AssessmentConsumer {
    @RabbitListener(queues = "assessmentQueue")
    public void handleAssessment(User user) {
        // 處理心理健康評(píng)估
        // ...
    }
}

@Service
public class AssessmentService {
    @Autowired
    private Executor taskExecutor;

    public CompletableFuture<Void> performMentalHealthAssessment(User user) {
        return CompletableFuture.runAsync(() -> {
            // 模擬耗時(shí)評(píng)估邏輯
            // ...
        }, taskExecutor);
    }
}

// 控制器調(diào)用
@PostMapping("/trigger-assessment")
public CompletableFuture<ResponseEntity<String>> triggerAssessment(@RequestBody User user) {
    return assessmentService.performMentalHealthAssessment(user)
            .thenApplyAsync(unused -> ResponseEntity.ok("評(píng)估完成"));
}

// 定義事件
public class AssessmentEvent extends ApplicationEvent {
    private User user;
    public AssessmentEvent(Object source, User user) {
        super(source);
        this.user = user;
    }
    // getter
}

// 發(fā)布者（控制器）
@RestController
public class AssessmentController {
    @Autowired
    private ApplicationEventPublisher eventPublisher;

    @PostMapping("/trigger-assessment")
    public ResponseEntity<String> triggerAssessment(@RequestBody User user) {
        eventPublisher.publishEvent(new AssessmentEvent(this, user));
        return ResponseEntity.ok("評(píng)估事件已發(fā)布");
    }
}

// 異步監(jiān)聽(tīng)者
@Component
public class AssessmentListener {
    @Async
    @EventListener
    public void handleAssessmentEvent(AssessmentEvent event) {
        // 處理評(píng)估邏輯
        // ...
    }
}