Spring中@Scheduled tasks（Boot）的通用异常处理程序（Java配置）

Question

在我的Spring Boot（1.4.2版）应用程序中，我有很多计划的任务，希望使用一个处理程序捕获所有异常，就像使用@ExceptionHandler注释的普通控制器一样。由于线程问题，这种方法不适用于使用@Scheduled annotation定义的任务：

@Component
public class UpdateJob {
    @Transactional
    @Scheduled(cron = "0 1 0 * * *")
    public void runUpdateUsers() {
        userService.updateUsers();
    }

    @ExceptionHandler
    public void handle(Exception e) {
       // some more logic here
       logger.error(e.getMessage());
    }

 }

@ExceptionHandler不适用于@计划方法（事实证明它并不意味着）。相反，Spring Boot使用它自己的LoggingErrorHandler：

2016-12-08 15:49:20.016 ERROR 23119 --- [pool-7-thread-1] o.s.s.s.TaskUtils$LoggingErrorHandler    : Unexpected error occurred in scheduled task.

我能以某种方式为计划任务替换或提供默认的异常处理程序吗？或者切换到传播错误处理程序有意义吗？据我所知，它会进一步传播错误。有没有其他方法只使用Java配置（没有XML）来实现这个目标？

这并不是这个问题的重复，因为它明确要求基于Java配置而不是XML的解决方案（因此，在没有任何XML配置的情况下将其合并到Spring Boot项目中是不错的）。

还有一些答案演示了如何从头开始配置TaskScheduler。例如，这个答案要求您还定义池大小、最大池大小、队列容量。这里有一个解决方案，它也需要非常广泛的配置。文档显示了如何配置其他方面，但没有显示如何指定错误处理。但是Java配置需要花费多少精力才能最大限度地保持Spring Boot缺省值（线程池、执行器配置等）。

Answer 1

您使用PropagatingErrorHandler的方法是正确的，但您稍微误解了目的。它会导致异常在堆栈的更上层继续，导致计划的任务在将来不会运行。此外，它是TaskUtils的私有文件，因此您无法访问它。

您需要实现自己的错误处理程序，但只能有一个处理程序。至少，您需要记录异常，因为Spring不再为您记录它。

假设您没有自己的自定义TaskSchedulerbean，要在Spring Boot中创建自己的ErrorHandler，请在@Configance类中实现org.springframework.boot.task.TaskSchedulerCustomzer。

@Override
public void customize(ThreadPoolTaskScheduler taskScheduler) {
    taskScheduler.setErrorHandler(new CustomErrorHandler());
}

private static class CustomErrorHandler implements ErrorHandler {
    private static final Logger logger = LoggerFactory.getLogger(CustomErrorHandler.class);

    @Override
    public void handleError(Throwable t) {
        logger.error("Scheduled task threw an exception: {}", t.getMessage(), t);
    }
}

因为ErrorHandler是一个@keytionalInterface，您可以这样做：

taskScheduler.setErrorHandler(t -> { /* Handle exception here */});

（这是基于Spring Boot 2.1.8）

Answer 2

如注释中所述，@ExceptionHandler适用于Spring MVC控制器。

如果您想为单个调度器提供异常处理逻辑，最简单、最可维护的方法是将其包装到try-catch块中，并在其中处理错误。

如果您想对不同的调度器应用相同的错误处理程序，请遵循@M.Deinum的建议。

Answer 3

下面是一个设置自定义错误处理程序（Spring 2.0.2）的示例：

@Bean
public TaskScheduler taskScheduler() {
    ConcurrentTaskScheduler scheduler = new ConcurrentTaskScheduler();
    scheduler.setErrorHandler(throwable -> { /* custom handler */ });
    return scheduler;
}