Spring Cloud Task 高级特性Task Events示例

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-task</artifactId>
    <version>3.1.3</version>
</dependency>

@Component
public class LongRunningTask implements CommandLineRunner {

    @Override
    public void run(String... args) throws Exception {
        Thread.sleep(5000);
    }
}

@Component
public class CustomTaskEventListener implements TaskEventListener {

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

    @Override
    public void onTaskStartup(TaskExecution taskExecution) {
        logger.info("Task startup event received for task id: {}", taskExecution.getExecutionId());
    }

    @Override
    public void onTaskSuccess(TaskExecution taskExecution) {
        logger.info("Task success event received for task id: {}", taskExecution.getExecutionId());
    }

    @Override
    public void onTaskFailed(TaskExecution taskExecution, Throwable throwable) {
        logger.info("Task failed event received for task id: {}", taskExecution.getExecutionId());
    }

    @Override
    public void onTaskEnd(TaskExecution taskExecution) {
        logger.info("Task end event received for task id: {}", taskExecution.getExecutionId());
    }

    @Override
    public void onTaskEndFailed(TaskExecution taskExecution, Throwable throwable) {
        logger.info("Task end failed event received for task id: {}", taskExecution.getExecutionId());
    }
}

@Component
public class EmailTaskEventPublisher {

    private final JavaMailSender mailSender;

    public EmailTaskEventPublisher(JavaMailSender mailSender) {
        this.mailSender = mailSender;
    }

    @EventListener
    public void handleTaskSuccessEvent(TaskExecutionEvent event) {
        if (event.getTaskExecution().getExitCode() == 0) {
            SimpleMailMessage message = new SimpleMailMessage();
            message.setTo("example@example.com");
            message.setSubject("Task execution completed successfully");
            message.setText("Task execution completed successfully");
            mailSender.send(message);
        }
    }
}