quartz @DisallowConcurrentExecution无法禁止多机并发的解决方法

本次遇到这个问题是这样一个场景，某些计算需要较长的时间，并且监控的周期会比较短。每3S监控一次，且执行周期最长已经超过6S，由于定时任务执行逻辑下一次依赖上一次的结果，在并发执行的情况下，会导致计算错误，因此必须要限制并发执行。

在开发单个节点的时候，没有问题，当部署了多个执行节点的时候，任务被并发的执行了。难道回到单节点模式？这样定时任务的高可用就没用了！

好了，现在的问题是。DisallowConcurrentExecution没有做到真正的多机禁止非并发执行！

解决方案是，增加分布式锁。为了不增加架构复杂度，直接引入了redisson红锁来进行处理。增加了BaseQuartzJob，在任务里识别DisallowConcurrentExecution的Annotation来进行加锁，等于是把互锁的机制增强，以免增加新的annotation。当然分布式锁你也可以用zookeeper，这里只是一个实现思路。

public abstract class BaseQuartzJob implements Job, Runnable{

	private static final String CONCURRENT_LOCK = "ConcurrentLock";
	
	@Autowired
	private RedissonClient redissonClient;

	private String lockJobClass;
	
	public BaseQuartzJob() {
		DisallowConcurrentExecution disallowConcurrentExecution = getClass().getAnnotation(DisallowConcurrentExecution.class);
		if(disallowConcurrentExecution != null) {
			lockJobClass = getClass().getSimpleName() + CONCURRENT_LOCK;
		}
	}

	@Override
	public void execute(JobExecutionContext context) throws JobExecutionException {

		if(SysInitBeanHelper.inited) { //Bean注入初始化完毕
			//如果有并发禁止锁，要锁多机并发，否则还是会并发
			if(lockJobClass != null) {
				RLock lockJob = redissonClient.getLock(lockJobClass);
				if(lockJob.tryLock()) { //如果有锁，把线程释放出去干其他事情
					try {
						this.run();
					}finally {
						lockJob.unlock();
					}
				}
			}else {
				this.run();
			}
		}else {
//			throw new JobExecutionException("Data not ready", false);
			//NO OP
		}
	}
}

好了，下一步我们可以写一个类，部署多机并发来测试

/**
 * 对接定时器.
 * @author JIM
 *
 */
@Component
@Scheduled(cron="0/3 * * * * ?")
@DisallowConcurrentExecution //执行时间超过周期不另启线程执行(已支持全节点唯一执行)
public class ErpDockingJob extends BaseQuartzJob{

	@Override
	public void run() {
		SpringContextHelper.getBean(DockingService.class).syncData();	
	}


}

增加这样的Bean达到同一时间唯一节点唯一执行

这里说点题外话，看到@Scheduled是不是很熟悉，没错，它就是spring Schedule定时器语法，从单机模式过来的同学一定非常熟悉这个语法，那么如何将quartz的配置做到这么简化的呢？这里先卖个关子，本次只是说明如何加锁，以后有时间再写文章

本文地址：https://blog.csdn.net/applebomb/article/details/111962087

quartz @DisallowConcurrentExecution无法禁止多机并发的解决方法

相关推荐