基於Redis在定時任務里判斷其他定時任務是否已經正常執行完的方案

執行的定時任務是基於其他定時任務計算得到的結果基礎上做操作的，那么如何來確定其他存在數據依賴的定時任務已經執行完成呢？

在分布式環境里，可通過集群的redis來解決這個問題：

即，在跑批任務開始時，將任務key+當日凌晨時間組成的key值進行加1，例如：

redisOperator.getJedis().incr(key+ startDateStr);
redisOperator.setKeyExpireTime(key+ startDateStr, 60*60*24);

跑批完成后，再將任務key+當日凌晨時間組成的key值減1,例如：

//跑批結束后自減
redisOperator.getJedis().decr(key+ startDateStr);

正常任務執行完，redis里對應的應該狀態是0。

//阻塞循環，一直等到另外的定時任務跑成功了，才繼續。
while (!checkCanRun(reportTime)) {
    int interval = 7200000;
    long sleepTime = System.currentTimeMillis();
    //休眠
    logger.info("sendOperationDailyReportHandler sleep time = " + TimeUnit.MILLISECONDS.toSeconds(System.currentTimeMillis()-sleepTime) + " seconds");
    Thread.sleep(interval);
}


private boolean checkCanRun (DateTime reportTime) {

    String runningFinishKey = redisOperator.getValueByKey(key + dateStr);

    if ("0".equals(runningFinishKey )) {
        return true;
    }
    return false;
}