Redis解决定时任务
@Scheduled(cron = "0 */1 * * * ?")//每个1分钟的整数倍
public void closeOrderTaskV2(){
log.info("关闭订单定时任务启动");
//50s
long lockTimeout = Integer.parseInt(PropertiesUtil.getProperty("lock.timeout"));
//获取锁
Long setnxResult = RedisShardedPoolUtil.setnx(Const.REDIS_LOCK.CLOSE_ORDER_TASK_LOCK,
String.valueOf(System.currentTimeMillis() + lockTimeout));
if(setnxResult!=null&& setnxResult.intValue()==1){
//返回1,获取到了锁
//不要直接调用closeOrder,第一次启动任务锁没有设置有效期,以后执行一定获取不到锁
closeOrder(Const.REDIS_LOCK.CLOSE_ORDER_TASK_LOCK);
}else{
log.info("没有获取到分布式锁:{}",Const.REDIS_LOCK.CLOSE_ORDER_TASK_LOCK);
}
log.info("关闭订单定时任务结束");
}
下面的一行设置端点,在redis里设置值成功,返回1,不继续设置过期时间停止tomcat。
//获取锁
** Long setnxResult = RedisShardedPoolUtil.setnx(Const.REDIS_LOCK.CLOSE_ORDER_TASK_LOCK,
String.valueOf(System.currentTimeMillis() + lockTimeout));
**
显示没有设置有效期
关闭tomcat
redis里的值丢失了
断点在这里,然后设置完值以后,