Spring定时器时间配置(一)

2014-11-24 02:33:28 · 作者: · 浏览: 4

Quartz在Spring中动态设置cronExpression (spring设置动态定时任务)

    2007-07-25 13:52

    什么是动态定时任务:是由客户制定生成的,服务端只知道该去执行什么任务,但任务的定时是不确定的(是由客户制定)。

    这样总不能修改配置文件每定制个定时任务就增加一个trigger吧,即便允许客户修改配置文件,但总需要重新启动web服务啊,研究了下Quartz在Spring中的动态定时,发现

    

        
        
            0/10 * * * *
        

    
    中cronExpression是关键,如果可以动态设置cronExpression的值,也就说如果我们可以直接调用CronTriggerBean中设置cronExpression的方法,就可以顺利解决问题了。
    熟悉1的朋友可以跳过不看,下面2、3是动态定时任务的具体实现。
    1、Quartz在Spring中的简单配置

    Spring配置文件:

    
        
        
        
    

    
        
        
            0/10 * * * *
        

    

    
        
            
                
            

        

    

    在上面的配置中设定了
    ① targetMethod: 指定需要定时执行scheduleInfoAction中的simpleJobTest()方法
    ② concurrent:对于相同的JobDetail,当指定多个Trigger时, 很可能第一个job完成之前,第二个job就开始了。指定concurrent设为false,多个job不会并发运行,第二个job将不会在第一个job完成之前开始。
    ③ cronExpression:0/10 * * * * 表示每10秒执行一次,具体可参考附表。
    ④ triggers:通过再添加其他的ref元素可在list中放置多个触发器。
    scheduleInfoAction中的simpleJobTest()方法,注意:此方法没有参数,如果scheduleInfoAction有两个方法simpleJobTest()和simpleJobTest(String argument),则spring只会去执行无参的simpleJobTest().
    public void simpleJobTest()
    {
        log.warn("uh oh, Job is scheduled !'" + "' Success...");
    }

    2.Quartz在Spring中动态设置cronTrigger方法一
    Spring配置文件:
    
        
        
    

    
        
        
        
    

    
        
        
            0/10 * * * *
        

    

    
        
            
                
            

        

    

    scheduleInfoAction中的reScheduleJob ()方法及相关方法
    ① reScheduleJob读取数据库,获得自定义定时器调度时间():
    private void reScheduleJob() throws SchedulerException, ParseException
    {
        // 运行时可通过动态注入的scheduler得到trigger
        CronTriggerBean trigger = (CronTriggerBean) scheduler.getTrigger("cronTrigger", Scheduler.DEFAULT_GROUP);
        String dbCronExpression = getCronExpressionFromDB();
        String originConExpression = trigger.getCronExpression();
        // 判断从DB中取得的任务时间(dbCronExpression)和现在的quartz线程中的任务时间(originConExpression)是否相等
        // 如果相等,则表示用户并没有重新设定数据库中的任务时间,这种情况不需要重新rescheduleJob
        if(!originConExpression.equalsIgnoreCase(dbCronExpression))
        {
            trigger.setCronExpression(dbCronExpression);
            scheduler.rescheduleJob("cronTrigger", Scheduler.DEFAULT_GROUP, trigger);
        }
        // 下面是具体的job内容,可自行设置
        // executeJobDetail();
    }
    ② getCronExpressionFromDB():从数据库中获得dbCronExpression的具体代码,由于使用了scheduleInfoManager,所以要在定义相应的setter方法
    private String getCronExpressionFromDB()
    {
        String sql="from ScheduleInfo scheduleInfo where 1=1 ";
        sql=sql+" and scheduleInfo.infoId = '"+"1" + "'";
        List scheduleList = scheduleInfoManager.queryScheduleInListBySql(sql);
        ScheduleInfo scheduleInfo = (ScheduleInfo)scheduleList.get(0);
        String dbCronExpression = scheduleInfo.getCronExpression();
        return dbCronExpression;
    }
    ③ 在spring配置文件的scheduleInfoAction配置了相应的property(scheduler/ scheduleInfoManager),要为其设置setter方法
    private Scheduler scheduler;
    // 设值注入,通过setter方法传入被调用者的实例scheduler
    public void setScheduler(Scheduler scheduler)
    {
        this.scheduler = scheduler;
    }
    private ScheduleInfoManager scheduleInfoManager;
    // 设值注入,通过setter方法传入被调用者的实例scheduleInfoManager
    public void setScheduleInfoManager(ScheduleInfoManager s