如何使用Cron表达式在Spring运行作业

Question

我想基于cron表达式运行一个作业，但它应该在rest调用后从DB中查找cron表达式。

@SpringBootApplication
@EnableScheduling
public class DemoApplication {
    public static void main(String[] args) {
        SpringApplication.run(DemoApplication.class, args);
    }
}


Controller
**************
        @PostMapping
    @RequestMapping(value = "/addProduct")
    public ResponseEntity saveProduct(@RequestBody Product product){

        prodList.add(product);
        startJob();
        return new ResponseEntity("Product saved successfully", HttpStatus.OK);
    }

    @Scheduled(cron = "*/2 * * * * *")
    public void startJob() {
        System.out.println("printing"+ new Date());
    }

一旦rest api被命中，它应该等待cron表达式，我们可以从数据库或任何方法获得它，然后它应该在指定的时间启动。

它的工作方式与普通的方法调用类似。

Answer 1

您可以让控制器实现SchedulingConfigurer，它有一个名为configureTasks（）的回调，当Spring启动时将调用该回调。

在这个回调中，您可以访问ScheduledTaskRegistrar，它是一个助手bean，可用于以编程方式安排任务。因此，将这个助手bean保存到控制器的内部字段中，这样控制器就可以访问它，以便以后安排新任务。

@RestController
public class MyController implements SchedulingConfigurer{

    private ScheduledTaskRegistrar scheduledTaskRegistrar;

    @Override
    public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
        this.scheduledTaskRegistrar = taskRegistrar;
    }

    @PostMapping
    @RequestMapping(value = "/addProduct")
    public ResponseEntity saveProduct(@RequestBody Product product){

        //.....

        //Load the cron expression from database 
        String cronExpression = loadCronExpressionFromDatabase();
        CronTask cronTask = new CronTask(() -> startJob() ,cronExpression);
        scheduledTaskRegistrar.scheduleCronTask(cronTask);


        return new ResponseEntity("Product saved successfully", HttpStatus.OK);
    } 

    public void startJob() {
        System.out.println("printing"+ new Date());
    }
}