java - 如何基于某些Kafka事件暂停和恢复 Spring 批处理步骤

我们正在尝试创建一个中央批处理服务，该服务将在远程（微型）服务中调用批处理过程。在此期间，我们要暂停步骤执行，直到远程服务没有响应批处理服务为止。
Spring Batch可以实现吗？

最佳答案

您可以尝试实现StepListener，其中具有beforeStep和afterStep方法，您可以控制beforeStep方法调用以等待其他服务调用完成执行

public class StepTwoListener implements StepExecutionListener {
@Override
public void beforeStep(StepExecution stepExecution) {
     long start = System.currentTimeMillis();
        try {
            Thread.sleep(5000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("Sleep time in ms = "+(System.currentTimeMillis()-start));
    System.out.println("Before Step Execution");
}}

您可以在步骤中使用侦听器

@Bean
public Step stepTwo() {
    return stepBuilderFactory.get("stepTwo").tasklet(new StepTwo()).listener(new StepTwoListener()).build();
}