redis分布式锁解决集群服务器定时任务重复执行问题

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了redis分布式锁解决集群服务器定时任务重复执行问题，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含2194字，纯文字阅读大概需要4分钟。

内容图文

问题描述

将带有定时任务的项目部署在单台测试环境上，完全没问题。生产上是两台集群服务器，项目部署上去发现定时任务的模块同时在两台机器上各执行了一遍，这将会导致其他意外的发生。

解决方案----redis分布式锁

使用redis分布式锁，为定时任务唯一指定的key加锁，并设置锁超时时间。当触发定时任务时，一台服务的任务进入切面，通过setNX(key,value)方法为唯一的key加锁，如果当前key不存在，将放入缓存，并返回true,通过expire(key,second)设置锁超时时间，结束后跳出执行定时任务方法。第二台服务任务进入时，设置锁的时候发现该锁已存在于缓存，并返回false，不跳转到执行定时任务方法。

核心代码

1.分布式锁切面

@Aspect
@Slf4j
@Component
public class CacheLockAspect {
 private static final String LOCK_VALUE = "locked";
 @Autowired
 private RedisConnection connection;
 @Around("execution(* *.*(..)) && @annotation(com.common.annotation.CacheLock)")
 public void cacheLockPoint(ProceedingJoinPoint pjp) {
 Method cacheMethod = null;
 for (Method method : pjp.getTarget().getClass().getMethods()) {
 if (null!=method.getAnnotation(CacheLock.class)){
 cacheMethod = method;
 break;
 }
 }
 try {
 String lockKey = cacheMethod.getAnnotation(CacheLock.class).lockedPrefix();
 long timeOut = cacheMethod.getAnnotation(CacheLock.class).expireTime();
 if(null == lockKey){
 throw new ManagerException(ErrorMsgEnum.LOCK_NAME_EMPTY);
 }
 if (connection.setNX(lockKey.getBytes(),LOCK_VALUE.getBytes())) {
 connection.expire(lockKey.getBytes(),timeOut);
 log.info("method:{}获取锁:{},开始运行！",cacheMethod,lockKey);
 pjp.proceed();
 return;
 }
 log.info("method:{}未获取锁:{},运行失败！",cacheMethod,lockKey);
 } catch (Throwable e) {
 log.error("method:{},运行错误！",cacheMethod,e);
 throw new ManagerException(ErrorMsgEnum.LOCK_JOB_ERROR,e);
 }
 }
}

2.手写方法级注解

@Target(ElementType.METHOD)
@Retention(RetentionPolicy.RUNTIME)
@Documented
public @interface CacheLock {
 String lockedPrefix() default ""; //redis 锁key的前缀
 long expireTime() default 10; //key在redis里存在的时间，1000S
}

3.定时任务服务

@Slf4j
@Service
public class TimeTaskService {
 /**
 * 执行定时任务
 **/
 @Scheduled(cron = "0 0 1 * * ?")
 @CacheLock(lockedPrefix = "TimeTaskService",expireTime=30)
 public void executeTask() {
 System.out.println("hello world!");
 }
}

内容总结

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

内容备注

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

内容手机端