一个实现类,简单的测试,打印出当前调度实例的名称和下次触发时间:
package com.christ.test.action;
import java.io.Serializable;
import java.util.Date;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.quartz.SchedulerException;
import org.springframework.scheduling.quartz.QuartzJobBean;
/**
* @author
*/
public class HelloJob extends QuartzJobBean implements Serializable {
/**
*
*/
static Log log = LogFactory.getLog(HelloJob.class);
/**
*
*/
public void helloJob() {
log.info("每分钟第10秒非集群测试" + (new Date().toString()));
}
@Override
protected void executeInternal(JobExecutionContext context) throws JobExecutionException {
try {
log.info(context.getScheduler().getSchedulerName() + "集群测试下一次运行时间应该为: "+ context.getTrigger().getNextFireTime());
// Scheduler sc = context.getScheduler();
// sc.shutdown();
} catch (SchedulerException e) {
e.printStackTrace();
}
}
}
然后就是配置好quartz.xml,这里包括非集群和集群的方法,非集群也可以用插件实现,不过要多个配置文件,我嫌麻烦就直接写这里了:
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:aop="http://www.springframework.org/schema/aop"
xmlns:tx="http://www.springframework.org/schema/tx" xmlns:context="http://www.springframework.org/schema/context"
xmlns:dwr="http://www.directwebremoting.org/schema/spring-dwr"
xsi:schemaLocation="
http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
http://www.springframework.org/schema/tx
http://www.springframework.org/schema/tx/spring-tx-3.0.xsd
http://www.springframework.org/schema/aop
http://www.springframework.org/schema/aop/spring-aop-3.0.xsd
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context.xsd
http://www.directwebremoting.org/schema/spring-dwr
http://www.directwebremoting.org/schema/spring-dwr-3.0.xsd">
<!-- 集群任务 -->
<bean id="job" class="org.springframework.scheduling.quartz.JobDetailBean">
<property name="jobClass" value="com.christ.test.action.HelloJob" />
</bean>
<!-- 集群作业触发器 -->
<bean id="clusterJobTime" class="org.springframework.scheduling.quartz.CronTriggerBean">
<property name="jobDetail" ref="job" />
<!-- cron表达式 -->
<property name="cronExpression" value="30 * * * * ?" />
</bean>
<!-- 集群调度 -->
<bean name="clusterQuartzScheduler" lazy-init="false" class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
<!--启动时更新数据库中己存在的Job-->
<property name="overwriteExistingJobs" value="true"/>
<!-- 应用启动后启动QuartzScheduler -->
<property name="startupDelay" value="30"/>
<property name="triggers">
<list>
<ref bean="clusterJobTime" />
</list>
</property>
<property name="configLocation" value="classpath:quartz.properties"/>
</bean>
<!--非集群作业-->
<bean id="helloJob" class="com.christ.test.action.HelloJob"></bean>
<bean id="jobtest"
class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
<!-- 调用的类 -->
<property name="targetObject" ref="helloJob"/>
<!-- 调用类中的方法 -->
<property name="targetMethod" value="helloJob"/>
</bean>
<!-- 非集群作业触发器-->
<bean id="JobTime" class="org.springframework.scheduling.quartz.CronTriggerBean">
<property name="jobDetail" ref="jobtest" />
<!-- cron表达式 -->
<property name="cronExpression" value="10 * * * * ?" />
</bean>
<!-- 非集群调度 -->
<bean name="quartzScheduler" class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
<!-- 触发器 -->
<property name="triggers">
<list>
<ref bean="JobTime" />
</list>
</property>
</bean>
</beans>
分享到:
相关推荐
quartz集群调度机制调研及源码分析,基于quartz 1.7版本
一个基于springboot的quartz集群dome。 向http://localhost:9090/job/addjob注入3个参数 类名:(及时定时任务的类如:com.ybjdw.site.job.NewJob) 组名:随意 定时启动方法:如“0/3 * * * * ?”(每3秒启动一次...
本文章是关于springboot集成quartz集群的步骤,LZ亲测。
SSH框架,主要实现了OA中的RABC权限管理,整合了Quartz,并支持Quartz集群
quartz集群Sql大放送,包含几十种数据库的初始sql,赶紧送上分来吧,记得评价返分
springboot 集成 quartz 集群 加 sql 等 文章介绍 单机加集群都有 https://blog.csdn.net/weixin_42749765/article/details/88532413
NULL 博文链接:https://lostangel0214.iteye.com/blog/1163503
java + quartz实现定时任务,实现集群配置,在集群环境下多节点运行定时Quartz定任务,就会存在重复处理任务的现象,为解决这一问题,下面我将介绍使用 Quartz 的 TASK ( 12 张表)实例化到数据库,基于数据库自动...
NULL 博文链接:https://kenny-liu.iteye.com/blog/634853
自己弄了将近一天的成果。主要是修改MethodInvokingJobDetailFactoryBean这个类。
NULL 博文链接:https://daoshud1.iteye.com/blog/1955099
quartz集群时需要在数据库中创建的表结构(oracle,mysql,sqlserver,h2sql等22种数据库)
quartz集群各种数据库建表脚本,基于quartz2.2.1版本。
NULL 博文链接:https://vista-move.iteye.com/blog/2274246
quartz在集群环境下的最终解决方案quartz在集群环境下的最终解决方案
NULL 博文链接:https://kissroom112.iteye.com/blog/2224442
大家可以思考一下、现在有 A、B、C三个应用同时作为集群服务器对外统一提供服务、每个应用下各有一个Quartz、它们会按照既定的时间自动执行各自的任务。我们先不说实现什么功能,就说这样的架构其实有点像多线程。...
最近公司项目上线,需要把app部署在多台服务器上,但只能让其中一台服务器的job执行,一台服务器挂了,另一台还能继续执行job,通过网上查找资料,都是java工程的方式,不好部署并测试,经过二天辛苦整合,终于整理成...