如何在特定时间窗口中运行方法

Question

我有一个微服务，它会收到一条消息，大概是这样的：

["00:12", "12:20", "15:40"]

是否有任何开箱即用的解决方案允许方法每天在给定时间运行？使用 Spring 中的 cron 不涉及在运行时更改时间。我需要使用更灵活的选项（更改运行时，多次启动）

谢谢！

Answer 1

最佳解决方案取决于(几乎总是)您的基础设施必须工作的环境。

您可以使用@Scheduled（即在集群环境中运行的SpringScheduled Task），但它在集群中的性能不佳（通常只有一个节点在运行作业）。

我将提出一种在简单性，效率和可靠性之间取得良好平衡的解决方案。稍后我将讨论它的一些属性。

建议的解决方案：

1. 使用具有保证原子性的有序列表（消息队列、redis排序列表、db表…）。
2. 客户的请求，它会简单地将一个项目添加到该列表中。
3. 您将根据需要培养尽可能多的工人，他们可以是一个、几个或根据需要自动扩展。
4. 每个工作人员将（原子地）检查他是否必须处理作业。注意：最佳方法是对列表有一个钩子，这样当列表发生变化时，它们就会得到推送，这样就不需要重复读取列表（工作人员只需等待最近的时刻）。

这种方法值得注意的特性:

1. 可能有一个或多个节点同时运行作业。
2. 节点可能会损坏、需要很长时间等，而不会影响挂起的作业（只需看到没有空闲工作线程即可执行自动缩放）。
3. 您可以轻松检查作业是否丢失（例如，运行它的节点已损坏），是否尝试多次运行但没有成功，等等......
4. 状态为持续，您可以检查是否错过了作业，恢复作业等...
5. 根据您需要解决方案的效率，它可以非常复杂（钩子，自动缩放状态等）或非常简单（简单的开始转换;从作业中选择1个ID 时间

Answer 2

Spring有@Scheduled注释。有几种方法可以配置它，一种方法是像 unix cron 作业一样配置它。

例如像这样：

@Scheduled(cron = "0 15 10 15 * ?")
public void scheduleTaskUsingCronExpression() {
 
    long now = System.currentTimeMillis() / 1000;
    System.out.println(
      "schedule tasks using cron jobs - " + now);
}

这里的任务安排在每月15日上午10:15执行。

但是也有一些方法可以在运行时动态地配置延迟或速率，例如如下（取自baeldung.com）：

@Configuration
@EnableScheduling
public class DynamicSchedulingConfig implements SchedulingConfigurer {

    @Autowired
    private TickService tickService;

    @Bean
    public Executor taskExecutor() {
        return Executors.newSingleThreadScheduledExecutor();
    }

    @Override
    public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
        taskRegistrar.setScheduler(taskExecutor());
        taskRegistrar.addTriggerTask(
          new Runnable() {
              @Override
              public void run() {
                  tickService.tick();
              }
          },
          new Trigger() {
              @Override
              public Date nextExecutionTime(TriggerContext context) {
                  Optional<Date> lastCompletionTime =
                    Optional.ofNullable(context.lastCompletionTime());
                  Instant nextExecutionTime =
                    lastCompletionTime.orElseGet(Date::new).toInstant()
                      .plusMillis(tickService.getDelay());
                  return Date.from(nextExecutionTime);
              }
          }
        );
    }

}

Instant nextExecutionTime = ...这一行可以替换为你自己的逻辑来设置下一个执行时间，就像解析数组中的时间一样。

看看这个baeldung教程：https://www.baeldung.com/spring-scheduled-tasks

另外，请查看这里的cron符号：https://www.netiq.com/documentation/cloud-manager-2-5/ncm-reference/data/bexyssf.html