Spring 3.2“@Scheduled”注释的异常处理

Question

如何定制spring中@Scheduled注释的异常处理？

我有Cron作业，这些作业将在服务器（Tomcat 6）中触发，当出现任何异常时，我需要进行一些处理。

• Spring版本3.2
• Tomcat服务器6

Answer 1

为什么不包装您的业务逻辑，在@schedule方法中做一个简单的try-catch呢。然后，您可以记录或采取任何必要的措施来应对失败案例。

@Scheduled(cron = "${schedulerRate}")
public void scheduledJob() {
    try {
        businessLogicService.doBusinessLogic();
    } catch (Exception e) {
        log.error(e);
    }
}

Answer 2

您可以为ThreadPoolTaskScheduler实现并注册一个ErrorHandler，该调度器用于调度注释。

 <task:annotation-driven scheduler="yourThreadPoolTaskScheduler"  />

 <bean id="yourThreadPoolTaskScheduler" class="org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler">
        <property name="poolSize" value="5" />
        <property name="errorHandler" ref="yourScheduledTaskErrorHandler" />
 </bean>

 <bean id="yourScheduledTaskErrorHandler" 
     class="com.example.YourScheduledTaskErrorHandler"/>

Answer 3

如果你想使用Java配置，你需要创建配置来实现SchedulingConfigurer

@EnableScheduling
@Configuration
class SchedulingConfiguration implements SchedulingConfigurer {
    private final Logger logger = LoggerFactory.getLogger(getClass());
    private final ThreadPoolTaskScheduler taskScheduler;

    SchedulingConfiguration() {
        taskScheduler = new ThreadPoolTaskScheduler();
        taskScheduler.setErrorHandler(t -> logger.error("Exception in @Scheduled task. ", t));
        taskScheduler.setThreadNamePrefix("@scheduled-");

        taskScheduler.initialize();
    }

    @Override
    public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
        taskRegistrar.setScheduler(taskScheduler);
    }
}

您可以根据需要修改错误处理程序。这里我只记录一条消息。

别忘了给taskScheduler打电话。初始化（）；。没有它，你会得到：

java.lang.IllegalStateException: ThreadPoolTaskScheduler not initialized