如何在 Spring 中动态设置预定作业的固定费率？

以编程方式使用 Spring 调度作业：如何设置动态固定速率

Spring 框架提供了一种使用 @Scheduled 调度作业的便捷方法注解。然而，当需要在不重新部署应用程序的情况下调整所需的执行速率时，需要更动态的方法。

为了克服这个问题，Spring 允许使用触发器而不是注释。触发器可以动态计算下一个执行时间。

实现这种动态调度涉及几个关键步骤：

1. 创建触发器：实现一个类它扩展了 Trigger 接口并提供了 nextExecutionTime() 方法的实现。该方法根据所需逻辑计算下一次执行时间，例如以编程方式检索值。
2. 配置调度程序：使用 Spring 配置类中的 SchedulingConfigurer 接口来设置调度程序。这涉及创建一个 Executor bean 并使用自定义触发器实现注册一个触发器任务。
3. 调度作业：使用执行所需任务的 Runnable 来调度作业。触发器任务将根据您的自定义触发器处理执行调度。

以下是如何在代码中实现此方法的示例：

@Configuration
@EnableScheduling
public class MyAppConfig implements SchedulingConfigurer {

    @Autowired
    Environment env;

    @Bean
    public MyBean myBean() {
        return new MyBean();
    }

    @Bean(destroyMethod = "shutdown")
    public Executor taskExecutor() {
        return Executors.newScheduledThreadPool(100);
    }

    @Override
    public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
        taskRegistrar.setScheduler(taskExecutor());
        taskRegistrar.addTriggerTask(
                new Runnable() {
                    @Override public void run() {
                        myBean().getSchedule();
                    }
                },
                new Trigger() {
                    @Override public Date nextExecutionTime(TriggerContext triggerContext) {
                        Calendar nextExecutionTime =  new GregorianCalendar();
                        Date lastActualExecutionTime = triggerContext.lastActualExecutionTime();
                        nextExecutionTime.setTime(lastActualExecutionTime != null ? lastActualExecutionTime : new Date());
                        nextExecutionTime.add(Calendar.MILLISECOND, env.getProperty("myRate", Integer.class)); //you can get the value from wherever you want
                        return nextExecutionTime.getTime();
                    }
                }
        );
    }
}

通过此方法，您可以获得动态调整调度速率的灵活性，而无需重新部署 Spring 应用程序。以编程方式确定的执行率允许更高级的调度场景以及与外部系统的集成。

以上是如何在 Spring 中动态设置预定作业的固定费率？的详细内容。更多信息请关注PHP中文网其他相关文章！