欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

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

程序员文章站 2022-06-19 11:18:10
本次遇到这个问题是这样一个场景,某些计算需要较长的时间,并且监控的周期会比较短。每3S监控一次,且执行周期最长已经达到5S,由于定时任务执行逻辑下一次依赖上一次的结果,因此如果并发的情况下,会导致计算错误。在开发单个节点的时候,没有问题,当部署了多个执行阶段的时候,任务被并发的执行了。好了,现在的问题是。DisallowConcurrentExecution没有做到真正的多机非并发执行!解决方案是,增加分布式锁。为了不增加架构复杂度,直接引入了redisson红锁来进行处理。增加了BaseQuart...

本次遇到这个问题是这样一个场景,某些计算需要较长的时间,并且监控的周期会比较短。每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