首先，定义一个简单的Spring Boot应用程序，并添加Spring Cloud Task的依赖：
代码语言：javascript复制<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-task</artifactId>
<version>3.1.3</version>
</dependency>然后，创建一个CommandLineRunner接口的实现，用于模拟一个长时间运行的任务：
代码语言：javascript复制@Component
public class LongRunningTask implements CommandLineRunner {
@Override
public void run(String... args) throws Exception {
Thread.sleep(5000);
}
}接下来，创建一个TaskEventListener的实现，用于记录任务执行相关的事件：
代码语言：javascript复制@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());
}
}最后，创建一个TaskEventPublisher的实现，用于在任务执行结束后发送一封电子邮件：
代码语言：javascript复制@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);
}
}
}在这个示例中，EmailTaskEventPublisher定义了一个handleTaskSuccessEvent方法，用于处理任务成功事件。当任务执行的退出代码为0时，它将发送一封包含任务执行结果的电子邮件。
现在，可以启动这个应用程序，并运行任务。在任务执行期间，可以在控制台输出中看到任务执行事件的记录。当任务执行结束后，将发送一封电子邮件。
