springquartz2数据库

‘壹’ spring 4 quartz 2.x动态配置triggers

spring 4.x没有配置过，这里有一个spring 3.x 的quartz定时配置，你参考参考：

<?xmlversion="1.0"encoding="UTF-8"?>
<beansxmlns="http://www.springframework.org/schema/beans"
	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xmlns:p="http://www.springframework.org/schema/p"
	xsi:schemaLocation="http://www.springframework.org/schema/beanshttp://www.springframework.org/schema/beans/spring-beans-3.1.xsd">
	<!--
	1、JobDetail：JobDetail是一个具体的类。
2、Trigger：触发器，它用于定义Job何时执行。最常用的是SimpleTrigger和CronTrigger。
一般来说，如果你需要在一个固定的时间和重复次数或者一个固定的间隔时间，那么SimpleTrigger比较合适；
如果你有许多复杂的作业调度，那么CronTrigger比较合适。
CronTrigger和Unix的cron机制基本一样，我们需要的只是一个cron表达式。
比如“0012**?”会在每天中午12点触发执行；“01510槐嫌?*6L”会在每个月的最后一个星期五的早上10:15触发Job执行。
铅态手3、Scheler和SchelerFactory：Scheler负责管理Trigger、调度Job，
SchelerFactory则是Scheler工厂，负责生成Scheler。
	-->
	
	<!--总管理类如果将lazy-init='false'那么容器启动就会执行调度程序-->
	<beanclass="org.springframework.scheling.quartz.SchelerFactoryBean"lazy-init="false">
		<!--通过属性配置spring上下文[此属性可省略]-->
		<propertyname="">
			<value>applicationContext</value>
		</property>
		<propertyname="triggers">
			<list>
				<!--作业调度器,list下可加入其他的调度器-->
				<refbean="testTrigger"/>
			</list>
		</property>
		<propertyname="autoStartup"value="true"/>
	</bean>
	
	<!--要调度的对象-->
	<beanid="testJob"class="name.zealze.test.JobTest"/>
	
	<beanid="testTrigger"class="org.springframework.scheling.quartz.CronTriggerBean">
		<propertyname="jobDetail"ref="testJobDetail"/>
		<!--按cron表达式时间点触发事件http://cron.qqe2.com/-->
		<propertyname="cronExpression"value="00/2***?"/>
	</bean>
	
	<beanid="testJobDetail"class="org.springframework.scheling.quartz.">
		<propertyname="targetObject"ref="testJob"/>
		<propertyname="targetMethod"value="execute"/>
		<!--是否允许任务闭销并发执行。当值为false时，表示必须等到前一个线程处理完毕后才再启一个新的线程-->
		<propertyname="concurrent"value="false"/>
	</bean>
	
</beans>

‘贰’ spring配置quartz后怎么访问数据库

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

‘叁’ spring 集成 quartz 需要哪些数据库表

我集成quartz只加了一张表
记录了cron表达式，状态，执行的类，或明方法
或许可世迅以再加上日志表，记录操作搜团此日志

‘肆’ Springboot整合quartz（二）

我们可以再spingboot的自动装配知氏胡源码可以看到quartz定义了如下的接口搭拦和核喊类：

继承 QuartzJobBean并重写 executeInternal 方法，与之前的实现 Job`接口类似

这里 TestService 打印一条 uuid 模拟调用service的场景

‘伍’ 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、启动项目，查看控制台打印的日志，成功

‘陆’ Spring+Quartz查询数据库动态设置cron表达式求助

主要有三个核心概念：调度器、任务和触发器。
三者关系简单来说就是，调度器负责调度各个任务，到了某个时刻或者过了一定时间，触发器触动了，特定任务便启动执行。概念相对应的类和接口有：
1）JobDetail：望文生义就是描述任务的相关情况；
2）Trigger：描述出发Job执行的时间触发规则。有SimpleTrigger和CronTrigger两个子类代表两种方式，一种是每隔多少分钟小时执行，则用SimpleTrigger；另一种是日历相关的重复时间间隔，如每天凌晨，每周星期一运行的话，通过Cron表达式便可定义出复杂的调度方案。
3）Scheler：代表一个Quartz的独立运行容器，Trigger和JobDetail要注册到Scheler中才会生灶闭效，也就是让调度器知隐档裂道有哪些触发器和任务，才能进行按规则进蠢陪行调度任务。

‘柒’ quartz+hibernate+spring 频繁操作数据库,出现 数据库连接超过最大连接数

spring
quartz如何动态配置时间
1.
目的：动态设置时间，触发相应的任务
2.
系统架构为
struts
+
spring
+
hibernate
3.
实现步骤：
在页面上设置时间；
将时间转换为unix
cron
expression；
将转换后的时间规则表达式记录到数据库中（也可以写...

‘捌’ ssh2框架spring+quartz配置定时任务时，像System.out.pringtln("aa")就能打印，可是查询数据库时就不执行

确定你的配置文件和查询数据库部分的代码没有问题吗，

‘玖’ 请教，spring3.2+quartz2.1.6报如下错误如何解决

Spring官网有说明其已支持Quartz 2.x，但是需要将者游Spring升级到3.1以上。由于Quartz 2.x修改了部分API，所以需要修改一下Quartz的配置。大体来说很简单，如下：
1）升级Spring的jar包
2）升级Quartz的jar包
3）首山销修改配置
将CronTriggerBean修改唯哗为CronTriggerFactoryBean
将JobDetailBean修改为JobDetailFactoryBean

‘拾’ spring4使用quartz哪个版本包合适

您好，根据您的要求，最合适键绝的Spring4使用Quartz版本包应该是Quartz 2.2.1。Quartz是一个开源的作业调度框架，它可以安排任务在特定的时间运行，它可消握以被集成到任何Java应用程序中，包括Spring4。Quartz 2.2.1是一个稳定的版本，它支持Spring4，并且支持多种数据库，包括MySQL，PostgreSQL，Oracle，MS SQL Server等。Quartz 2.2.1还拿亮庆支持多种触发器，包括SimpleTrigger，CronTrigger，CalendarIntervalTrigger等，这些触发器可以帮助您安排任务在特定的时间运行。此外，Quartz 2.2.1还支持多种作业监听器，可以帮助您监控作业的运行状态，以及在作业失败时触发特定的处理程序。因此，Quartz 2.2.1是Spring4使用Quartz的最佳选择。