利用redis 分布式锁 解决集群环境下多次定时任务执行

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了利用redis 分布式锁 解决集群环境下多次定时任务执行，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含2012字，纯文字阅读大概需要3分钟。

内容图文

定时任务：

    @Scheduled(cron= "0 39 3 * * *")
    public void getAllUnSignData(){
        //检查任务锁,若其它节点的相同定时任务已经执行，则该节点的任务执行一个空任务，否则设置锁并执行该任务
        String timerName = this.getClass().getName()+Thread.currentThread() .getStackTrace()[1].getMethodName();//当前类名+当前方法名
        if(redisLock.requireLock(timerName,7200)){
            return;
        }
        long startTime = System.currentTimeMillis();
        logger.info("定时任务 UnSignStatistics start-->" + startTime );
        //找出签到异常的学生，保存在表中
        gxyWarnService.saveUnSignWarn();
        long endTime = System.currentTimeMillis();
        logger.info("定时任务 UnSignStatistics end-->" +endTime+ ", execute time: " + (endTime - startTime) + "ms" );


    }

用类名+方法名作为key， 去redis 获取锁。

如果获取到了键值对： (key , 1) ，则说明定时任务已被执行，返回true ， 执行if 中的return, 不执行 后面的定时任务。

如果没有获取到 键值对： (key , 1) ，则说明定时任务没有被执行 。在redis中 设置键值对 (key , 1)， （并设置有效期7200秒，这个有效期小于定时任务的周期即可），并返回false 。不执行if 中的return，继续执行后面的定时任务代码。

@Component
public class RedisLock {
    //redis中存任务锁的key前缀
    public final static String MOGUDING_TIMER_LOCK_KEY = "com:lock:job:";

    @Autowired
    private RedisTemplate<String, Object> redisTemplate;

    /**
     * 判断是否有锁。有，返回true；否，返回false,设置一定期效的锁
     * @param lockName
     * @param expire  锁的有效时间长，单位：秒
     * @return
     */
    public boolean requireLock(String lockName,long expire){
        String key = MOGUDING_TIMER_LOCK_KEY+lockName;
        if(redisTemplate.opsForValue().getAndSet(key,"1")==null){   //“1”这里无任何意义
            redisTemplate.expire(key,expire,TimeUnit.SECONDS);
            return false;
        }else {
            return true;
        }
    }
    /**
     * 判断是否有锁。有，返回true；否，返回false,设置一定期效的锁
     * @param lockName
     * @param date  锁的有效时间截止点
     * @return
     */
    public boolean requireLock(String lockName,Date date){
        String key = MOGUDING_TIMER_LOCK_KEY+lockName;
        if(redisTemplate.opsForValue().getAndSet(key,"1")==null){  //“1”这里无任何意义
            redisTemplate.expireAt(key,date);
            return false;
        }else {
            return true;
        }
    }
}

内容总结

以上是互联网集市为您收集整理的利用redis 分布式锁 解决集群环境下多次定时任务执行全部内容，希望文章能够帮你解决利用redis 分布式锁 解决集群环境下多次定时任务执行所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端