quartz定时任务配置：
<bean id="scheler"
class="org.springframework.scheling.quartz.SchelerFactoryBean">
<property name="triggers">
<list>
<ref bean="ActionCronTrigger"/>
<ref bean="ActionOrderCronTrigger"/>
<ref bean="InquiryCronTrigger"/>
</list>
</property>
</bean>
其中：
<ref bean="ActionCronTrigger"/>
<ref bean="ActionOrderCronTrigger"/>
<ref bean="InquiryCronTrigger"/>
配置对应的定时任务，可配置多个，名称要唯一，对应的是第二步中配置的CronTriggerFactoryBean
CronTriggerFactoryBean配置，由于要实现动态读取定时任务周期时间，所以我们要写一个类实现CronTriggerFactoryBean，类的内容如下：
public class InitCronTriggerFactoryBean extends CronTriggerFactoryBean implements Serializable {
private static final long serialVersionUID = 1L;
private SysParamServiceImpl sysParamServiceImpl;
private String key;
public void setKey(String key)
{
this.key = key;
}
public void setSysParamServiceImpl(SysParamServiceImpl sysParamServiceImpl)
{
this.sysParamServiceImpl = sysParamServiceImpl;
setCronExpression(getCronExpressionFromDB());
}
private String getCronExpressionFromDB()
{
if(StringUtils.isEmpty(key))
return "0 0 0/1 * * ?";
SysParam sysParam = new SysParam();
try
{
sysParam = sysParamServiceImpl.getNameByKey(key);
}
catch (Exception e)
{
e.printStackTrace();
}
if(sysParam != null && !StringUtils.isEmpty(sysParam.getParamValue()))
return sysParam.getParamValue();
return "0 0 0/1 * * ?";
}
}
简单说明一下：key是用来查询数据库配置的CronExpression表达式的查询条件，SysParamServiceImpl 是实现查询的类，这几个参数都要从spring配置的CronTriggerFactoryBean参数获取，注意，配置的时候，key值的配置要在SysParamServiceImpl 的配置之前，否则报空指针
spring配置CronTriggerFactoryBean：
实现了CronTriggerFactoryBean之后，开始配置CronTriggerFactoryBean，现在配置的是InitCronTriggerFactoryBean ：
<bean id="InquiryCronTrigger" class="cn.com.shopec.quartz.utils.InitCronTriggerFactoryBean">
<property name="jobDetail" ref="InquiryJobDetail" />
<property name="key" value="inquiryQuartzParam" />
<property name="sysParamServiceImpl" ref="sysParamServiceImpl" />
</bean>
id对应quartz定时任务配置的<ref bean="InquiryCronTrigger"/>，参数有三个，第二个和第三个是InitCronTriggerFactoryBean设置内容需要的，第一个<property name="jobDetail" ref="InquiryJobDetail" />则是定时任务执行业务逻辑的类
ps：<property name="sysParamServiceImpl" ref="sysParamServiceImpl" />，这个要配置对应的bean，我的是
<bean id="sysParamServiceImpl" class="cn.com.shopec.core.system.service.impl.SysParamServiceImpl">
</bean>
配置对应的定时任务执行业务方法的类：
<bean id="InquiryJobDetail"
class="org.springframework.scheling.quartz.JobDetailFactoryBean">
<property name="rability" value="true" />
<property name="jobClass" value="cn.com.shopec.quartz.utils.InquiryQuartz" />
<property name="jobDataAsMap">
<map>
<entry key ="inquiryServiceImpl" value-ref="inquiryServiceImpl"/>
</map>
</property>
</bean>
简单说明一下：<property name="jobClass" value="cn.com.shopec.quartz.utils.InquiryQuartz" />配置的是你需要定时执行的类，<property name="jobDataAsMap"> 下面配置的是定时执行类中需要用到的其他类，这是由于项目启动执行定时任务不能在定时任务类中实例化这些类，要配置才行。
对应的定时任务执行类：
public class InquiryQuartz extends QuartzJobBean {
@Autowired
private InquiryServiceImpl inquiryServiceImpl;
@Override
protected void executeInternal(JobExecutionContext arg0) throws JobExecutionException
{
// 实例化接口
inquiryServiceImpl = (InquiryServiceImpl) arg0.getJobDetail().getJobDataMap().get("inquiryServiceImpl");
// 执行业务方法
quartzStart();
}
public void quartzStart(){
// 业务方法...
}
}
说明一下：必须要实现QuartzJobBean 接口
至此，就可以完成可配置CronExpression表达式的定时任务了！1
② quartz+hibernate+spring 频繁操作数据库,出现 数据库连接超过最大连接数
spring
quartz如何动态配置时间
1.
目的：动态设置时间，触发相应的任务
2.
系统架构为
struts
+
spring
+
hibernate
3.
实现步骤：
在页面上设置时间；
将时间转换为unix
cron
expression；
将转换后的时间规则表达式记录到数据库中（也可以写...
③ quartz定时器问题，要往数据库插入数据，报no session
定时器的数据库脚本有没有导入
给你看下我的配置
④ 如何在quartz的job任务中操作数据库
数据库中建表。建表模版在Quartz包下docs/dbTables下，选择相应的数据库和版本即可。ORACLE的11个Table列表如下：
QRTZ_JOB_LISTENERS：存储有关已配置的 JobListener 的信息
JOB_NAME
JOB_GROUP
JOB_LISTENER
QRTZ_TRIGGER_LISTENERS：存储已配置的 TriggerListener 的信息
QRTZ_FIRED_TRIGGERS：存储与已触发的 Trigger 相关的状态信息，以及相联 Job的执行信息
QRTZ_PAUSED_TRIGGER_GRPS：存储已暂停的 Trigger 组的信息
QRTZ_SCHEDULER_STATE：存储集群中note实例信息，quartz会定时读取该表的信息判断集群中每个实例的当前状态
INSTANCE_NAME 之前配置文件中org.quartz.scheler.instanceId配置的名字，就会写入该字段，如果设置为AUTO,quartz会根据物理机名和当前时间产生一个名字
LAST_CHECKIN_TIME：上次检查时间
CHECKIN_INTERVAL ：检查间隔时间
QRTZ_LOCKS：存储程序的悲观锁的信息(假如使用了悲观锁)
QRTZ_SIMPLE_TRIGGERS：存储简单的Trigger，包括重复次数，间隔，以及已触的次数
TRIGGER_NAME ：qrtz_triggers表trigger_name的外键
TRIGGER_GROUP：qrtz_triggers表trigger_group的外键
REPEAT_COUNT ：重复次数
REPEAT_INTERVAL：时间间隔
TIMES_TRIGGERED：触发次数
QRTZ_CRON_TRIGGERS：存储cron表达式表
TRIGGER_NAME ：qrtz_triggers表trigger_name的外键
TRIGGER_GROUP：qrtz_triggers表trigger_group的外键
CRON_EXPRESSION：cron表达式
TIME_ZONE_ID ：时区
QRTZ_TRIGGERS：保存trigger信息
⑤ springboot+quartz持久化到数据库各表含义
1、去quartz官网下载quartz2.2.2版本的压缩包，quartz下载，注意：quartz2.3.0版本的在docs目录下没有发现dbtable目录（存放生成数据库表的sql文件的目录）。
2、做纤执行创建数据库表的sql文件，我使用的是mysql数据库。
生成的表结构
3、在springboot项目中配置quartz。
3.1、两种方式配置quartz，
3.1.1、第一种是使用自定义的quartz.properties,这是简单配置，如果有其他配置可以参考，quartz.properties配烂颤置详情
org.quartz.jobStore.useProperties:true
#org.quartz.scheler.instanceName: quartzScheler
#org.quartz.scheler.instanceId = AUTO
org.quartz.threadPool.class = org.quartz.simpl.SimpleThreadPool
org.quartz.threadPool.threadCount = 15
org.quartz.threadPool.threadPriority: 5
org.quartz.threadPool.: true
org.quartz.jobStore.class = org.quartz.impl.jdbcjobstore.JobStoreTX
org.quartz.jobStore.driverDelegateClass=org.quartz.impl.jdbcjobstore.StdJDBCDelegate
org.quartz.jobStore.isClustered = false
#org.quartz.jobStore.clusterCheckinInterval=20000
org.quartz.jobStore.tablePrefix = qrtz_
org.quartz.jobStore.misfireThreshold = 60000
org.quartz.jobStore.maxMisfiresToHandleAtATime = 20
org.quartz.scheler.rmi.export: false
org.quartz.scheler.rmi.proxy: false
org.quartz.scheler.: false
登纯历仿录后复制
3.1.2、使用配置文件配置springboot中的SchelerFactoryBean。
@Configuration
public class SchelerConfig implements SchelerFactoryBeanCustomizer {
@Autowired
private DataSource dataSource;
@Override
public void customize(SchelerFactoryBean schelerFactoryBean) {
schelerFactoryBean.setStartupDelay(10);
schelerFactoryBean.setOverwriteExistingJobs(true);
schelerFactoryBean.setDataSource(dataSource);
ClassPathResource resource = new ClassPathResource("quartz.properties");
Properties properties = new Properties();
InputStream in= null;
try {
in = resource.getInputStream();
BufferedReader bf = new BufferedReader(new InputStreamReader(in, "UTF-8"));
properties.load(bf);
schelerFactoryBean.setQuartzProperties(properties);
} catch (IOException e) {
e.printStackTrace();
}
}
}
登录后复制
3.2.1、第二种方式是在application.properties文件中的配置，application.properties文件中的spring.quartz.properties. 加上quartz.properties中的键值对，效果与quartz.properties类似。
spring.quartz.properties.org.quartz.jobStore.tablePrefix = qrtz_
spring.quartz.properties.org.quartz.threadPool.threadCount = 10
登录后复制
项目中配置org.quartz.jobStore.tablePrefix = qrtz_，这个配置是默认查询数据库中表的前缀，默认是QRTZ_,以下sql中通过rpt方法组装一条新的sql，替换掉{0},{1}，如果没有明确声明就会使用默认值 org.quartz.jobStore.tablePrefix = QRTZ_，org.quartz.scheler.instanceName: quartzScheler。
如果进行简单的定时任务，可以使用springboot中默认的quartz配置。
3.2.2 自定义配置springboot中的SchelerFactoryBean。
@Configuration
public class SchelerConfig implements SchelerFactoryBeanCustomizer {
@Autowired
private DataSource dataSource;
@Override
public void customize(SchelerFactoryBean schelerFactoryBean) {
schelerFactoryBean.setStartupDelay(10);
schelerFactoryBean.setOverwriteExistingJobs(true);
schelerFactoryBean.setDataSource(dataSource);
}
}
登录后复制
4、新建Job
public class TestJob implements Job {
@Override
public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
System.out.println(System.nanoTime());
}
}
登录后复制
5、数据库中新增job任务脚本，com.example.quartzdemo.job.TestJob是我本地的测试Job，需要修改成你自己Job类。
INSERT INTO `qrtz_job_details` (`SCHED_NAME`, `JOB_NAME`, `JOB_GROUP`, `DESCRIPTION`, `JOB_CLASS_NAME`, `IS_DURABLE`, `IS_NONCONCURRENT`, `IS_UPDATE_DATA`, `REQUESTS_RECOVERY`, `JOB_DATA`) VALUES ('quartzScheler', 'test2Job', 'testGroup', NULL, 'com.example.quartzdemo.job.TestJob', '1', '0', '0', '0', NULL);
INSERT INTO `qrtz_triggers` (`SCHED_NAME`, `TRIGGER_NAME`, `TRIGGER_GROUP`, `JOB_NAME`, `JOB_GROUP`, `DESCRIPTION`, `NEXT_FIRE_TIME`, `PREV_FIRE_TIME`, `PRIORITY`, `TRIGGER_STATE`, `TRIGGER_TYPE`, `START_TIME`, `END_TIME`, `CALENDAR_NAME`, `MISFIRE_INSTR`, `JOB_DATA`) VALUES ('quartzScheler', 'testTrigger2', 'testTriggerGroup', 'test2Job', 'testGroup', NULL, '1554122914000', '1554122913000', '5', 'ACQUIRED', 'CRON', '1554039857000', '0', NULL, '0', NULL);
INSERT INTO `qrtz_cron_triggers` (`SCHED_NAME`, `TRIGGER_NAME`, `TRIGGER_GROUP`, `CRON_EXPRESSION`, `TIME_ZONE_ID`) VALUES ('quartzScheler', 'testTrigger2', 'testTriggerGroup', '0/1 * * * * ?', 'Asia/Shanghai');
登录后复制
6、启动项目，查看控制台打印的日志，成功