elastic-job允许用户在任务调度异常时指定处理异常的异常处理器,异常处理器由接口JobExceptionHandler定义,其定义如下:
/** * 作业异常处理器. * * @author zhangliang */ public interface JobExceptionHandler { /** * 处理作业异常. * * @param jobName 作业名称 * @param cause 异常原因 */ void handleException(String jobName, Throwable cause); }
如果没有指定自己的异常处理器elastic-job默认将使用DefaultJobExceptionHandler处理异常,其定义如下:
/** * 默认作业异常处理器. * * @author zhangliang */ @Slf4j public final class DefaultJobExceptionHandler implements JobExceptionHandler { @Override public void handleException(final String jobName, final Throwable cause) { log.error(String.format("Job '%s' exception occur in job processing", jobName), cause); } }
以下是一个自定义的异常处理器的示例:
public class MyJobExceptionHandler implements JobExceptionHandler { private static final Logger logger = Logger.getLogger(MyJobExceptionHandler.class); @Override public void handleException(String jobName, Throwable cause) { logger.error(String.format("任务[%s]调度异常", jobName), cause); } }
异常处理器的配置是通过job-exception-handler属性指定的,所有作业类型的异常处理器的配置是通用的:
<job:simple id="myExceptionJob" class="com.elim.learn.elastic.job.MyExceptionJob" cron="0/30 * * * * ?" registry-center-ref="regCenter" sharding-total-count="4" overwrite="true" job-exception-handler="com.elim.learn.elastic.job.MyJobExceptionHandler" />
(本文由Elim写于2017年10月2日)