`

Quartz集群配置（100%成功）

 
阅读更多
先看看quartz的持久化基本介绍：
引用

1 大家都清楚quartz最基本的概念就是job，在job内调用具体service完成具体功能，quartz需要把每个job存储起来，方便调度，quartz存储job方式就分三种，我们最常用的也是quartz默认的是RAMJobStore，RAMJobStore顾名思义就是把job的相关信息存储在内存里，如果用spring配置quartz的job信息的话，所有信息是配置在xml里，当spirng context启动的时候就把xml里的job信息装入内存。这一性质就决定了一旦JVM挂掉或者容器挂掉，内存中的job信息就随之消失，无法持久化。另外两种方式是JobStoreTX和JobStoreCMT，暂时不讨论这两者的区别，使用这两种JobStore，quartz就会通过jdbc直连或者应用服务器jndi连接数据库，读取配置在数据库里的job初始化信息，并且把job通过java序列化到数据库里，这样就使得每个job信息得到了持久化，即使在jvm或者容器挂掉的情况下，也能通过数据库感知到其他job的状态和信息。
    2 quartz集群各节点之间是通过同一个数据库实例(准确的说是同一个数据库实例的同一套表)来感知彼此的。


由上可见，我们需要创建quartz要用的数据库表，此sql文件在：quartz-1.8.6\docs\dbTables。此文件夹下有各个数据库的sql文件，mysql选择tables_mysql.sql。创建相应表。

接下来新建quartz.properties来覆盖jar包中的此文件，新的properties文件放在src的根目录下即可。下面是文件内容： 
#==============================================================  
#Configure Main Scheduler Properties  
#==============================================================   
org.quartz.scheduler.instanceName = quartzScheduler
org.quartz.scheduler.instanceId = AUTO

#==============================================================  
#Configure JobStore  
#============================================================== 
org.quartz.jobStore.class = org.quartz.impl.jdbcjobstore.JobStoreTX
org.quartz.jobStore.driverDelegateClass = org.quartz.impl.jdbcjobstore.StdJDBCDelegate
org.quartz.jobStore.tablePrefix = QRTZ_
org.quartz.jobStore.isClustered = true
org.quartz.jobStore.clusterCheckinInterval = 20000  
org.quartz.jobStore.dataSource = myDS
 
#==============================================================  
#Configure DataSource  
#============================================================== 
org.quartz.dataSource.myDS.driver = com.mysql.jdbc.Driver
org.quartz.dataSource.myDS.URL = jdbc:mysql://192.168.20.195:3306/database?useUnicode=true&characterEncoding=UTF-8
org.quartz.dataSource.myDS.user = root
org.quartz.dataSource.myDS.password = 123456
org.quartz.dataSource.myDS.maxConnections = 30

#==============================================================  
#Configure ThreadPool  
#============================================================== 
org.quartz.threadPool.class = org.quartz.simpl.SimpleThreadPool
org.quartz.threadPool.threadCount = 10
org.quartz.threadPool.threadPriority = 5
org.quartz.threadPool.threadsInheritContextClassLoaderOfInitializingThread = true


可以看到除了数据源、线程池等配置外，我们指定了一个scheduler实例，实例ID为自动分配。 
#==============================================================  
#Configure Main Scheduler Properties  
#==============================================================   
org.quartz.scheduler.instanceName = quartzScheduler
org.quartz.scheduler.instanceId = AUTO


此外，指定了集群相应配置，检查间隔为20s： 
org.quartz.jobStore.isClustered = true
org.quartz.jobStore.clusterCheckinInterval = 20000


最后配置applicant-context.xml文件。这里特别要注意一点：
引用
MethodInvokingJobDetailFactoryBean 类中的 methodInvoking 方法，是不支持序列化的，因此在把 QUARTZ 的 TASK 序列化进入数据库时就会抛错。

所以我们要自己实现MethodInvokingJobDetailFactoryBean 的功能，这里用MyDetailQuartzJobBean 替换。 

import java.lang.reflect.Method;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.springframework.context.ApplicationContext;
import org.springframework.scheduling.quartz.QuartzJobBean;

public class MyDetailQuartzJobBean extends QuartzJobBean {
	protected final Log logger = LogFactory.getLog(getClass());
	private String targetObject;
	private String targetMethod;
	private ApplicationContext ctx;

	@Override
	protected void executeInternal(JobExecutionContext context)
			throws JobExecutionException {
		try {
			logger.info("execute [" + targetObject + "] at once>>>>>>");
			Object otargetObject = ctx.getBean(targetObject);
			Method m = null;

			try {
				m = otargetObject.getClass().getMethod(targetMethod, new Class[] {JobExecutionContext.class});
				m.invoke(otargetObject, new Object[] {context});
			} catch (SecurityException e) {
				logger.error(e);
			} catch (NoSuchMethodException e) {
				logger.error(e);
			}
		} catch (Exception e) {
			throw new JobExecutionException(e);
		}
	}

	public void setApplicationContext(ApplicationContext applicationContext) {
		this.ctx = applicationContext;
	}

	public void setTargetObject(String targetObject) {
		this.targetObject = targetObject;
	}

	public void setTargetMethod(String targetMethod) {
		this.targetMethod = targetMethod;
	}


终于到配置spring文件这步了 
<bean id="mapScheduler" lazy-init="false" autowire="no"
		class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
		<property name="triggers">
			<list>
				<ref bean="dailyTrigger" />
				<ref bean="billCountTrigger" />
				<ref bean="userAcctTrigger" />
			</list>
		</property>
		<property name="applicationContextSchedulerContextKey" value="applicationContext" />
		<property name="configLocation" value="classpath:quartz.properties" />
	</bean>


	<bean id="dailyBillJob" class="com.***.job.DailyBillJob" />

	<bean id="dailyBillJobDetail" class="org.springframework.scheduling.quartz.JobDetailBean">
		<property name="jobClass">
			<value>com.autelan.auteview.lib.util.MyDetailQuartzJobBean
			</value>
		</property>
		<property name="jobDataAsMap">
			<map>
				<entry key="targetObject" value="dailyBillJob" />
				<entry key="targetMethod" value="execute" />
			</map>
		</property>
	</bean>

	<bean id="dailyTrigger" class="org.springframework.scheduling.quartz.CronTriggerBean">
		<property name="jobDetail">
			<ref bean="dailyBillJobDetail" />
		</property>
		<property name="cronExpression">
			<value>11 11 11 * * ?</value>
		</property>
	</bean>
// 转载请注明出处http://forhope.iteye.com/blog/1398990


大功告成！
分享到：
| Spring--quartz中cronExpression配置说明（ ...
评论
13 楼 born19930314 2017-10-09  
你好，请问还在吗？我的targetObject中由于含有无法序列化的对象，所以报targetObject无法插入到数据库，因为对象是封装的无法修改，有其他解决方案吗
12 楼 stone_yw 2017-07-12  
想问一下，如果quartz只有一个任务，但是这个任务的执行时间比较长，这个要怎么解决？quartz执行的这个任务比如说先从队列中获取数据，然后通过这些数据去获取redis中的数据，然后再对数据进行处理，主要是对数据处理的时间比较耗时。。。
11 楼 yandype 2017-07-04  
mzxueyun 写道
ERROR c.t.k.m.biz.MyDetailQuartzJobBean - java.lang.NoSuchMethodException: com.taobao.kelude.machine.biz.QuartzJob.execute(org.quartz.JobExecutionContext)

我这边在启动的时候报这个错，知道是为什么吗？
QuartzJob是我写的一个定时任务的类


这个简单,这个是java反射机制找不到方法的原因。你明明在MyDetailQuartzJobBean类里面写了 m = otargetObject.getClass().getMethod(targetMethod, new Class[] {JobExecutionContext.class}); 指定了一个JobExecutionContext类型参数,那么你就得在你自定义类的方法execute里面加参数execute(JobExecutionContext context)。
我的建议是把:m = otargetObject.getClass().getMethod(targetMethod, new Class[] {JobExecutionContext.class});和m.invoke(otargetObject, new Object[] {context});花括号里面的类型参数去掉。m = otargetObject.getClass().getMethod(targetMethod, new Class[] {});和m.invoke(otargetObject, new Object[] {});这样,你就可以不必指定参数了。遇到quartz集群问题的可以联系我QQ:918 911 055给我留言。谢谢!
10 楼 x123456789a 2016-04-21  
9 楼 hanyi_ 2016-02-02  
8 楼 senioc 2015-08-19  
这个能不能实现开关切换集群还是非集群？
7 楼 u013474032 2015-07-29  
<!-- 定义目标bean和bean中的方法 --> 
   <bean id="dailyBillJob" class="com.test.job.DailyBillJob" abstract="false"
lazy-init="false" autowire="default" dependency-check="default">
</bean>
   <bean id="dailyBillJobDetail" class="org.springframework.scheduling.quartz.JobDetailBean">
         <property name="jobClass"> 
            <value>com.autelan.auteview.lib.util.MyDetailQuartzJobBean</value> 
        </property>
        <property name="jobDataAsMap"> 
            <map> 
                <entry key="targetObject" value="dailyBillJob" /> 
                <entry key="targetMethod" value="execute" /> 
            </map> 
        </property> 
   </bean>
=======================================================================
按照你提供的方法，在com.test.job.DailyBillJob中实现了execute函数，执行代码之后怎么调用不了execute函数啊
5 楼 mxiaoy 2015-03-03  
怎么进行测试 是用俩个tomcat吗？ 同时启动？ 
4 楼 想不到叫什么名字 2014-09-26  
hw361062491 写道
你好……我下了好多的包，都没有 这个文件\docs\dbTables。
可否把这个贴出来呢？

官网地址：可以自己去下载
http://www.quartz-scheduler.org/downloads
3 楼 hw361062491 2014-04-21  
你好……我下了好多的包，都没有 这个文件\docs\dbTables。
可否把这个贴出来呢？
2 楼 forhope 2012-09-05  
mzxueyun 写道
ERROR c.t.k.m.biz.MyDetailQuartzJobBean - java.lang.NoSuchMethodException: com.taobao.kelude.machine.biz.QuartzJob.execute(org.quartz.JobExecutionContext)

我这边在启动的时候报这个错，知道是为什么吗？
QuartzJob是我写的一个定时任务的类

很显然com.taobao.kelude.machine.biz.QuartzJob，这个类没有定义execute(org.quartz.JobExecutionContext)方法
1 楼 mzxueyun 2012-09-05  
ERROR c.t.k.m.biz.MyDetailQuartzJobBean - java.lang.NoSuchMethodException: com.taobao.kelude.machine.biz.QuartzJob.execute(org.quartz.JobExecutionContext)

我这边在启动的时候报这个错，知道是为什么吗？
QuartzJob是我写的一个定时任务的类
发表评论

您还没有登录,请您登录后再发表评论

相关推荐

    基于内存的Quartz集群配置手册 [中文]

    通过上述步骤，你已经成功配置了一个基于内存的Quartz集群，利用Terracotta实现了任务的分布式管理和负载均衡。在实际生产环境中，这种配置可以提高系统的稳定性和可扩展性，确保即使在单个服务器故障时，任务仍能...

    quartz集群各种数据库建表脚本

    Quartz是一款开源的作业调度框架，它允许开发者在Java应用程序中...在部署Quartz集群时，正确地执行这些脚本是成功配置的前提。同时，了解和理解这些表的结构和作用，对于理解和优化Quartz集群的工作机制也至关重要。

    springboot整合quartz定时任务yml文件配置方式

    至此，我们已经成功地在Spring Boot应用中整合了Quartz定时任务，通过YAML配置文件完成了基本的设置。同时，借助Spring Cloud Alibaba的Nacos和Dubbo，实现了服务发现和注册，为分布式环境下的任务调度打下了基础。...

    Spring Quartz Job 集群 终极解决方案

    最近公司项目上线，需要把app部署在多台服务器上，但只能让其中一台服务器的job执行，一台...按网上的方法，配置了很多遍，都不成功，我这个保证你成功运行。 运行工程前需求初使化12张表，见工程下tables_oracle.sql

    spring-boot集成quartz实现动态任务管理，支持集群

    通过以上步骤，你就可以在Spring Boot应用中成功集成Quartz，实现动态任务管理和集群支持。在实际业务场景中，你可以根据需求创建更多的Job和Trigger，或者自定义JobDataMap来传递参数。务必注意，对于大型、复杂的...

    quartz_2.3.0 SQL脚本

    一旦表创建成功，Quartz的配置文件（如`quartz.properties`）需要更新，指定数据库连接信息，并指向新创建的表。 Quartz 2.3.0版本可能包含了一些新的特性和改进，比如更稳定的调度机制、性能优化或者对Java新版本...

    Quartz2.2.1基于Spring注解方式配置Quartz

    总结，通过上述步骤，我们已经成功地使用Spring注解配置了Quartz2.2.1，实现了基于注解的任务调度。这种方式简化了配置，使得任务管理和扩展更加方便。在实际开发中，可以根据项目需求调整触发规则，实现复杂的定时...

    spring整合quartz使用jdbc存储

    要实现Quartz集群，你需要在多个节点上部署相同的配置。集群配置的关键在于数据库中的表必须是共享的，以便所有节点都能访问到相同的任务和触发器信息。此外，每个节点还需要设置`org.quartz.scheduler.instanceId`...

    spring3配置quartz定时任务

    总结，通过以上步骤，我们就成功地在Spring 3中配置了Quartz定时任务，实现了每10秒执行一次的任务。在实际应用中，你可以根据需求定义更复杂的作业和触发器，以及使用Quartz的其他高级特性，如集群支持、持久化作业...

    基于java的Quartz的实例

    - 在实际开发中，需要根据项目需求调整Quartz配置，比如数据库存储策略、集群配置等。 通过以上步骤，你可以在MyEclipse中成功地实现一个基于Java的Quartz实例，通过控制作业和触发器，实现灵活的任务调度。这个...

    quartz数据库集群锁机制共6页.pdf.zip

    1. **集群配置**：首先，要在每个集群节点上配置相同的数据库连接，并且共享相同的表（如QRTZ_TRIGGERS、QRTZ_JOB_DETAILS等）。这些表是Quartz存储作业和触发器信息的地方。 2. **JobStore选择**：Quartz提供了...

    Quartz2.2.1存储与持久化-基于Spring的配置

    通过以上步骤，我们已经成功地在Spring应用中配置了Quartz 2.2.1，并实现了任务的存储和持久化。在实际运行时，Quartz会根据配置的CRON表达式自动调度并执行任务。如果应用需要重启，Quartz可以从数据库中恢复Job和...

    spring3.1 与 quartz 1.8.6 整合 所有jar

    - 在生产环境中，考虑使用Quartz集群以提高可用性和容错性。 通过以上步骤，你可以在Spring 3.1中成功整合Quartz 1.8.6，实现灵活的任务调度。这个整合过程不仅使任务调度变得更加简单，而且结合了Spring的管理优势...

    Quartz2.2.1java任务持久（mysql）存储demo以及资料

    通过以上步骤，你就成功地在Quartz2.2.1中配置了MySQL作为任务的持久化存储，并创建了一个每隔10秒执行一次的简单任务。在提供的"demo+quartz资料"中，可能包含了更详细的示例代码和使用指南，可以帮助你深入理解...

    Quartz2.2版本开发手册（JAVA）

    Quartz的配置可以通过`org.quartz.impl.StdSchedulerFactory`进行设置，可以通过XML文件、Properties文件或Java代码来指定配置细节。配置项包括JobStore的选择、线程池的配置等。 #### 1.11 高级（企业级）属性 ...

    Quartz jar包

    Quartz还具有集群功能，可以在多台服务器上分布任务，确保任务的高可用性和容错性。通过API，开发者可以轻松创建、修改和删除任务，以及管理触发器。 jta.jar是Java Transaction API的实现，它是Java EE的一部分，...

    基于spring+mybatis的quartz应用

    通过以上步骤，我们就成功地在Spring+MyBatis环境中搭建了一个基于Quartz的计划任务调度系统，该系统具备良好的可扩展性和灵活性，可以适应不同的数据库环境，满足企业的定时任务需求。在实际开发中，还可以根据项目...

    quartz1.6.6 实例

    这个实例是特别为初学者设计的，它没有复杂的配置文件，而是通过纯Java代码进行调度，这使得理解Quartz的基本工作原理变得更加直观。 首先，我们需要了解Quartz的核心概念。在Quartz中，任务被称为Job，而调度的...

    Quartz.NET-2.2

    开发者进行了必要的修改，使得源代码可以在VS2012中成功编译。这对于那些想要深入理解Quartz.NET工作原理或者想要对其进行定制的人来说，是一个宝贵的资源。 Quartz.NET的核心概念包括： 1. **Job（作业）**：这是...

Magicbox
Global site tag (gtag.js) - Google Analytics