Spring Batch 2.1.8 当石英 cron 触发器触发时运行作业的单个实例

Question

我设置了一个弹簧批石英。我有两个作业配置并并行运行。这些作业正在读取文件，然后将一些数据写入数据库。这是棘手的部分，文件名是在我的执行侦听器的 beforeJob() 方法中计算的。每个作业完成后，afterJob() 将计算下一个文件名。文件名具有以下模式 xxxxxx.nnnn ，其中 nn.. 是数字，有时序列可能会缺少数字，因此我尝试“跳过”那些缺少的段落，当我找到现有数字时启动作业。
我想知道是否可以限制每次 cron 触发器触发时启动的作业数量？我想在 chron 触发器触发后启动一项作业。

例如：

1. 中午 12.30 作业启动。
2. 该作业尝试找到正确的文件
3. 作业因 FileNotFound 而失败（配置为不可跳过的异常）
4. 作业完成后，文件名计数器递增

现在，当触发器触发时，我会得到 4 个或更多作业异步执行相同类型。在我的批量设置中，我有两个 配置为每小时启动一个，间隔 5 分钟。这些工作都遵循示例中提供的流程。结论：是否可以在 cron 触发器触发后启动单个作业并使两种作业类型并行运行。

彼得

Answer 1

您的作业在执行之前应该知道要处理什么文件。例如，文件名应作为作业参数传递。删除 JobExecutionListener 并添加 StepExecutionListener 以通过 StepExecution#getJobParameters() 访问作业参数。一份工作=一份文件。

现在，您希望通过调度程序确保在某个时间点仅运行一项作业。您可以通过两种方式实现此目的：

• 使用异步任务执行器。在这种情况下，每次启动作业时，它都不会在后台执行（除非您的调度程序不会每次在新线程中触发计时器事件）。

<bean id="jobLauncher" class="org.springframework.batch.core.launch.support.SimpleJobLauncher">
    <property name="jobRepository" ref="jobRepository" />
    <property name="taskExecutor" ref="taskExecutor" />
</bean>

<bean id="taskExecutor" class="org.springframework.core.task.SimpleAsyncTaskExecutor" />

• 如果您对其他需要在后台执行的作业使用相同的作业启动器，则需要使用 ThreadPoolTask​​Executor，但您可以手动检查作业是否正在运行：

for (final JobInstance jobInstance : jobExplorer.getJobInstances(jobName(), 0, LOOK_BEHIND_INSTANCES)) {
    for (final JobExecution jobExecution : jobExplorer.getJobExecutions(jobInstance)) {
        final BatchStatus status = jobExecution.getStatus();

        if (status.isRunning()) {
            // Ops:
            break;
        }
    }
}