`
老竹枝
  • 浏览: 80984 次
  • 性别: Icon_minigender_1
  • 来自: 广州
社区版块
存档分类
最新评论

取巧的方法实现多个Quartz同步

阅读更多

  一套老系统,采用Quartz进行一些定期任务。新加定期任务,处理数据库中的某些数据。由于采用了tomcat集群,有多台服务器并且同一台机器上有多个tomcat。

  代码简单,但是出来以后发现由于多个任务会同时进行,导致同一条数据被多次处理。毫无疑问,这种情况是无法接受的。首先想到的是通过配置Quartz实现任务同步。但是对Quartz不是很熟悉,Google一轮下来,发现Quartz提供了同步,但是配置似乎相当复杂,并且出来的效果是Quartz集群,同一个时刻只能一个tomcat的Quartz运行,而我应用中有些任务必须每个tomcat必须运行,感觉没达到要求。

  第二步,决定自己处理,尝试了几种方法,没达到预期效果。

  最后,想到一个感觉有点取巧的办法。不知道会有什么问题,但是暂时解决问题。

  做法是定义一张新表,只有一个字段ID,默认插入一条记录。

  定义一个函数,每次开始任务时load该行并且锁定。

 

	public void getLock() {
		session = this.getSession();

		tx = session.beginTransaction();
		session.load(TLock4Check.class, 1,LockMode.UPGRADE);
	}

   任务结束时,放弃锁定

	public void releaseLock() {
		tx.rollback();
		this.releaseSession(session);
	}

 看起来有效果,达到预期效果,但总觉得不太正统,下次找个比较正统的解决方案替换之。

0
2
分享到:
评论
2 楼 cloud19841207 2015-11-19  
这样做存在一个问题, 就是1个任务会执行多遍, lock只能保证同一时间执行一个任务。 但不能终止另外一台机器上执行的同一任务。
1 楼 LinApex 2014-11-18  
能解决问题就是好的解决方案!

相关推荐

    java多个数据库实现数据同步

    综上所述,Java实现多数据库数据同步是一个涉及多种技术和策略的复杂问题,需要根据具体业务需求和系统架构来选择合适的方法。在实践中,应注重设计的灵活性、可扩展性和容错性,以保证系统的稳定运行。

    spring多个定时任务quartz配置

    本文将深入探讨如何在Spring中配置Quartz以实现多个定时任务。 首先,我们需要理解Quartz的基本概念。Quartz是一个开源的工作调度框架,它允许应用程序定义作业(Jobs)和触发器(Triggers),以在指定的时间执行...

    Quartz.net作业调度自定义定时执行任务多任务执行c#

    在"Quartz.net作业调度自定义定时执行任务多任务执行c#"这个主题中,我们将深入探讨如何使用Quartz.NET来实现自定义的定时任务,以及如何处理多任务执行。 首先,我们需要理解Quartz.NET的基本概念。在Quartz.NET中...

    转:spring多个定时任务quartz配置

    3. **创建Job类**:Quartz中的任务由`Job`接口实现,你需要定义一个或多个实现了`org.quartz.Job`接口的类,每个类代表一个具体的任务。 4. **定义Trigger**:`Trigger`是决定任务何时运行的规则,可以是...

    java实现两个mysql同步主库的数据

    下面我们将深入探讨如何使用Java实现两个MySQL数据库之间的数据同步,以及涉及的相关知识点。 首先,我们需要理解MySQL的复制原理。MySQL的主从复制是基于日志的,主库上的所有更改都会被记录到二进制日志(binlog...

    quartz整合springbatch动态集群定时实现mysql参考

    4. **集群同步策略**:确保在多节点环境中作业的正确调度和执行,可能使用了`org.quartz.impl.cluster.ClusterManager`。 5. **数据库脚本**:为Quartz和Spring Batch创建必要的数据库表,存储作业元数据和执行信息...

    Mybatis+Spring+SpringMVC+quartz多数据源切换

    这个项目结合了四个关键的技术组件,它们分别是Mybatis、Spring、SpringMVC和Quartz,下面将详细介绍这些技术以及它们在多数据源切换和跨数据库同步中的应用。 **Mybatis** 是一款轻量级的Java持久层框架,它允许...

    定时任务quartz实现分组串行并行动态配置

    4. **并行执行**:默认情况下,Quartz允许多个Job并行执行,只要它们不在同一组或满足并行执行的条件。如果需要限制同一组内的并行执行,可以通过设置Scheduler的属性`org.quartz.threadPool.class`为`org.quartz....

    完美解决多应用服务器负载均衡环境下spring quartz同一定时任务重复执行问题

    5. **集群同步**:Quartz的`StatefulJob`接口可以防止同一任务在集群中的多个节点同时执行,但需要注意的是,如果任务不是状态化的(即实现了`org.quartz.Job`而非`StatefulJob`),则需要自定义逻辑来保证执行的...

    Quartz动态修改时间,java实现修改CronExpression方法

    2. **启动Quartz**:通过执行一个主方法,加载并启动Spring配置文件,初始化Quartz的Scheduler实例。这通常涉及调用SchedulerFactoryBean的getScheduler()方法。 3. **获取和修改Trigger**:一旦Scheduler启动,你...

    spring boot整合quartz实现多个定时任务的方法

    Spring Boot整合Quartz实现多个定时任务的方法 在实际开发中,定时任务是非常常见的需求,例如每天凌晨执行某些任务、每小时执行某些任务等。Spring Boot提供了多种方式来实现定时任务,包括使用Quartz框架。在本文...

    一个简单的实现quartz的例子

    这个"一个简单的实现quartz的例子"提供了基础的Quartz使用方法,虽然可能不包含所有功能,但足以帮助初学者理解其核心概念。 Quartz的核心组件包括: 1. **Job**:这是你要调度的任务,它定义了具体的工作逻辑。你...

    Quartz 定时WebForm和WinForm使用的dll

    这个标题“Quartz 定时WebForm和WinForm使用的dll”暗示了我们将在WebForm和WinForm应用中使用Quartz来实现定时功能。在.NET环境中,Quartz通过引入特定的DLL文件来实现其功能。 首先,我们要理解什么是DLL...

    SpringBoot 整合Quartz(集群)实现定时任务调度

    创建一个实现了`org.quartz.Job`接口的类,这个类代表一个具体的任务。通过`@DisallowConcurrentExecution`注解,我们可以防止同一任务在多个节点上同时执行。此外,还需要创建一个`JobDetail`来注册任务,并使用`...

    quartz的分布式调度大致分两种方式实现

    如果需要扩展以支持数千个短期运行(例如1秒)作业,则可以考虑通过使用多个不同的调度程序(包括HA的多个群集调度程序)对作业集进行分区。 调度程序使用集群范围的锁,这种模式会在添加更多节点(超过三个节点 - ...

    Quartz + spring简单配置多个任务调度

    Quartz + spring简单配置多个任务调度 spring配置文件 简单配置

    自开发实现Quartz Web管理工具

    从以上位置可以查看详细介绍。 网上能找到的Quartz Web管理的资料都是使用的一个国外人写...包括可以添加一个任务(添加的任务只能是实现了Quartz Job接口的任务),暂停、启动、删除任务。基本这些都能满足日常应用了。

    springboot+quartz集群:通过动态配置调度dubbo接口/http接口代码实现

    在"springboot+quartz-cluster"的场景下,我们需要配置Quartz集群,确保任务在多个实例之间进行负载均衡,并且能够在节点故障时自动恢复。 MyBatis是一个优秀的持久层框架,它支持定制化SQL、存储过程以及高级映射...

    ASP.NET使用Quartz.NET实现定时任务调度

    2. **集群支持**:Quartz.NET可以在多个服务器上分布式部署,确保任务的高可用性和容错性。 3. **持久化能力**:它可以将任务和触发器存储到数据库中,即使服务重启,也能恢复之前的状态。 4. **插件扩展**:Quartz...

    Spring+Quartz实现任务调度的小例子

    定义了JobDetailBean之后,我们需要创建一个实际的Job类,实现`org.quartz.Job`接口,并覆盖`execute`方法来定义任务的具体逻辑。 ```java public class MyJob implements Job { @Override public void execute...

Global site tag (gtag.js) - Google Analytics