Spring Scheduler 动态更改 cron 表达式 [英] Spring Scheduler change cron expression dynamically

问题描述

我能够在 applicationContext.xml 中创建一个 taskScheduler，并且我的工作是根据 cron 属性定期触发的.

I am able to create a taskScheduler in applicationContext.xml, and my job is triggered periodically based on the cron attribute.

我想在调度程序启动后更改这个 cron 表达式(触发周期)，我的意思是在 JavaEE 应用程序运行时.

I would like to change this cron expression(triggering period) after scheduler start, I mean while JavaEE application is running.

使用 Spring 3.XX

using Spring 3.XX

推荐答案

其实我也遇到过同样的问题

Actually I've faced same issue

我假设您需要从用户那里获取日期(1-31)、时间、星期几、调度程序类型(每日、每月、每周).

I am assuming you will need to get date(1-31) , time, day of week ,type of scheduler (Daily , monthly , weeekly ) from user.

首先，您需要根据用户的给定日期时间创建 cron 表达式以下代码将创建 cron 表达式，它需要一个映射并将 cron 表达式作为字符串返回.

First, you need to create cron expression from the given date time from user Following code will create cron expression it takes an map and return cron expression as string.

public String  getCronExp(final Map<String, Object> configMap) {

    LOGGER.debug(">>  getCronExp");

    String exp = "";

    final String type = (String) configMap.get(SCHEDULER_TYPE);
    final String time = (String) configMap.get(TIME);
    final String[] split = time.split(this.COLON);
    String hour = split[0];
    String min = split[1];

    if ("00".equalsIgnoreCase(min)) {
        min = ZERO;
    }
    if ("00".equalsIgnoreCase(hour)) {
        hour = "0";
    }
    if ("daily".equalsIgnoreCase(type)) {

        exp = this.ZERO + this.WHITE_SPACE + min + this.WHITE_SPACE + hour + this.WHITE_SPACE + this.ASTERISK + this.WHITE_SPACE + this.ASTERISK
                + this.WHITE_SPACE + "?";

    } else if ("monthly".equalsIgnoreCase(type)) {
        final String date = (String) configMap.get(START_DATE);
        exp = this.ZERO + this.WHITE_SPACE + min + this.WHITE_SPACE + hour + this.WHITE_SPACE + date + this.WHITE_SPACE + this.ASTERISK + this.WHITE_SPACE
                + "?";

    } else if ("weekly".equalsIgnoreCase(type)) {

        final String dayOfWeek = (String) configMap.get(DAY_OF_WEEK);

        exp = this.ZERO + this.WHITE_SPACE + min + this.WHITE_SPACE + hour + this.WHITE_SPACE + "?" + this.WHITE_SPACE + this.ASTERISK + this.WHITE_SPACE
                + dayOfWeek;
    }

    LOGGER.info("Latest cron  expression scheduler " + exp);
    LOGGER.debug("<<  getCronExp");
    return exp;
}

在获得 cron 表达式后，我们遇到了触发调度程序的问题.

After we get cron expression we have issue of triggering the scheduler.

创建一个扩展可运行的类:

Create a class that extends runnable:

public  class Scheduler implements Runnable {

@SuppressWarnings("rawtypes")
ScheduledFuture scheduledFuture;

TaskScheduler taskScheduler ;

//this method will kill previous scheduler if exists and will create a new scheduler with given cron expression
public  void reSchedule(String cronExpressionStr){
 if(taskScheduler== null){
        this.taskScheduler = new ConcurrentTaskScheduler();
    }
     if (this.scheduledFuture() != null) {
        this.scheduledFuture().cancel(true);
    }
 this.scheduledFuture = this.taskScheduler.schedule(this, new CronTrigger(cronExpressionStr));
}

@Override
public  void run(){
// task to be performed 
}

//if you want on application to read data on startup from db and schedule the schduler use following method
 @PostConstruct
  public void initializeScheduler() {
    //@postcontruct method will be called after creating all beans in application context
    // read user config map from db 
    // get cron expression created 
    this.reSchedule(cronExp);
  }

}

这篇关于Spring Scheduler 动态更改 cron 表达式的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！