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

<bean id="scheduler"

class="org.springframework.scheduling.quartz.SchedulerFactoryBean">

<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.scheduling.quartz.JobDetailFactoryBean">

<property name="durability" 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

两种想法

1、在你insert的时候，就启动一个线程，延时时间根据你的lastTime 来设定 ，这样存在一个风险：访问量过大，启动的线程过多怎么办

2、lastTime一般根据什么来决定的，建议你设置一个定时器quartz , 每隔2小时或者什么去定时查一遍数据库，所有延期（根据lastTime来决定）的 进行处理