背景：xxl-job定时跑批，本地创建专门线程监测定时任务是否执行了，防止xxl-job挂了，及时通知。
@Slf4j
@Component
public final class DetectSubcriber implements DisposableBean,Runnable {
private static final SimpleDateFormat formatdate = new SimpleDateFormat("YYYY-MM-dd");
private static final SimpleDateFormat formatTime = new SimpleDateFormat("HH:mm");
private final Thread thread;
public static volatile Date jobExecDate; //由xxl-job任务线程修改，执行过了的设置当前时间
public static Boolean detectSelfExecFalg = true; //控制当前探测只发送一次提醒
private String specifiedFinishTime; //指定一个定时任务完成之后的时间点
private Long detectIntervalTime; //探测间隔时间，没必要一直跑，合理即可
private DetectSubcriber(@Value("${specified.finish.time}")String specifiedFinishTime,
@Value("${detect.interval.time}")Long detectIntervalTime,
@Autowired TeacherLiveJobHandler teacherLiveJobHandler){
this.specifiedFinishTime = specifiedFinishTime;
this.detectIntervalTime = detectIntervalTime;
this.teacherLiveJobHandler = teacherLiveJobHandler;
this.thread = new Thread(this);
this.thread.setDaemon(true);
this.thread.start();
}
@Override
public void run() {
try {
final Date finishTime = formatTime.parse(specifiedFinishTime);
while(true){
Thread.sleep(detectIntervalTime); //应该先执行，防止系统启动之后就会触发探测报警
final boolean jobNotExec = jobExecDate == null || !formatdate.format(jobExecDate).equals(formatdate.format(new Date()));
final Date currentTime = formatTime.parse(formatTime.format(new Date()));
if (currentTime.before(finishTime)) {
detectSelfExecFalg = true; //在该时间段开启
}
if (jobNotExec && detectSelfExecFalg && currentTime.after(finishTime)) {
detectSelfExecFalg = false; //在currentTime.after(finishTime)内执行一次就行
log.info("xxl-job未执行，触发探活执行。");
//xxl-job挂了，由当前线程触发
try {
//todo 触发定时
}catch (Exception e){
log.error("",e);
}
//todo 发送报警
}
}
}catch (Exception e){
if (specifiedFinishTime == null) {
log.error("启动探活必须指定开始时间（探活开始时间的时间点）【specified.finish.time】。");
}
log.error("探活程序报错：",e);
}
}
@Override
public void destroy() throws Exception {
jobExecDate = null;
}
}
另一个线程：
DetectSubcriber.jobExecDate = new Date(); //应该先执行，下面任务的成功失败和探活无关。不能因为下面任务失败而导致触发探活报警。任务应该有自己的报警
//todo 跑批核心任务
写在后面
这个有必要吗？个人觉得没必要，本身xxl-job肯定是集群部署，故障率很低，万一要是发生了，那应该也是由运维人员及时修复。另一个发生故障的可能就是物理故障，如果都部署在同一台机器那也没啥毛用，不过一般是不会这么部署。同意这么做只是不想费口舌，再者是觉得这挺好玩。一些补偿措施不能为了甩锅而补偿。这程序可能几年也不会触发......
网友评论