Как запустить Spring Batch Job асинхронно

JobExecution jobExecution = jobLauncher.run(batchComponent.customJob("paramhere"), jobParameters);. Joblauncher будет ждать после завершения задания, прежде чем что-либо вернуть, поэтому ваша служба, вероятно, долго не отвечает, если это ваша проблема. Если вам нужны асинхронные возможности, вы можете взглянуть на Spring @EnableAsync и @Async.

@EnableAsync

Несмотря на то, что у вас есть собственный jobLauncher, вы запускаете задание с использованием стандартного jobLauncher, предоставленного Spring. Не могли бы вы автоматически подключить simpleJobLauncher к своему контроллеру и попробовать?

Попробуйте это, в вашей конфигурации вам нужно создать customJobLauncher с SimpleAsyncTaskExecutor, используя @Bean (name = "myJobLauncher"), и тот же @Qualifier будет использоваться в вашем контроллере.

@Bean(name = "myJobLauncher")
public JobLauncher simpleJobLauncher() throws Exception {
    SimpleJobLauncher jobLauncher = new SimpleJobLauncher();
    jobLauncher.setJobRepository(jobRepository);
    jobLauncher.setTaskExecutor(new SimpleAsyncTaskExecutor());
    jobLauncher.afterPropertiesSet();
    return jobLauncher;
}

В вашем контроллере

@Autowired
@Qualifier("myJobLauncher")
private JobLauncher jobLauncher;

Согласно документации Spring, чтобы вернуть ответ HTTP-запроса асинхронным, необходимо использовать org.springframework.core.task.SimpleAsyncTaskExecutor.

Any implementation of the spring TaskExecutor interface can be used to control how jobs are asynchronously executed.

весенняя пакетная документация

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

Если я посмотрю на ваш код, я вижу пару ошибок. Прежде всего, ваша настраиваемая конфигурация не загружается, потому что в противном случае внедрение не удастся для повторяющегося экземпляра bean-компонента для того же интерфейса.

В весенней загрузке много волшебства, но если вы не скажете ему про сканирование компонентов, ничего не будет загружено должным образом.

Вторая проблема, которую я вижу, - это ваш класс BatchConfig: он не расширяет DefaultBatchConfigure и не переопределяет getJobLauncher (), поэтому, даже если магия загрузки загрузит все, вы получите значение по умолчанию. Вот конфигурация, которая будет работать, и она соответствует документации @EnableBatchProcessing API

BatchConfig

@Configuration
@EnableBatchProcessing(modular = true)
@Slf4j
public class BatchConfig extends DefaultBatchConfigurer {

  @Override
  @Bean
  public JobLauncher getJobLauncher() {
    try {
      SimpleJobLauncher jobLauncher = new SimpleJobLauncher();
      jobLauncher.setJobRepository(getJobRepository());
      jobLauncher.setTaskExecutor(new SimpleAsyncTaskExecutor());
      jobLauncher.afterPropertiesSet();
      return jobLauncher;

    } catch (Exception e) {
      log.error("Can't load SimpleJobLauncher with SimpleAsyncTaskExecutor: {} fallback on default", e);
      return super.getJobLauncher();
    }
  }
}

Основная функция

@SpringBootApplication
@EnableScheduling
@EnableAsync
@ComponentScan(basePackageClasses = {BatchConfig.class})
public class SpringBatchTestApplication {

    public static void main(String[] args) {
        SpringApplication.run(SpringBatchTestApplication.class, args);
    }
}

Я знаю, что это старый вопрос, но я все равно отправляю этот ответ для будущих пользователей.

После просмотра вашего кода я не могу сказать, почему у вас возникла эта проблема, но я могу предложить вам использовать аннотацию Qualifier, а также использовать ThreadPoolTaskExecutor, как это, и посмотреть, решит ли это вашу проблему.

Вы также можете проверить это руководство: Асинхронная обработка пакетных заданий Spring для получения дополнительной информации. Это поможет вам настроить асинхронное пакетное задание Spring. Это руководство было написано мной.

@Configuration
public class BatchConfig {

 @Autowired
 private JobRepository jobRepository;

 @Bean
 public TaskExecutor threadPoolTaskExecutor(){

  ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setMaxPoolSize(12);
        executor.setCorePoolSize(8);
        executor.setQueueCapacity(15);

   return executor;
 }

 @Bean
    public JobLauncher asyncJobLauncher() throws Exception {
        SimpleJobLauncher jobLauncher = new SimpleJobLauncher();

        jobLauncher.setJobRepository(jobRepository);
        jobLauncher.setTaskExecutor(threadPoolTaskExecutor());
        return jobLauncher;
 }
}

Если вы используете Lombok, это может вам помочь:

TL; DR: Lombok @AllArgsConstructor не работает с аннотацией @QualifierРЕДАКТИРОВАТЬ: если вы включили аннотации @Qualifier в файле lombok.config, чтобы иметь возможность использовать @Qualifier с @AllArgsConstructor следующим образом:

lombok.copyableAnnotations += org.springframework.beans.factory.annotation.Qualifier

Я знаю старый вопрос, однако у меня была точно такая же проблема, и ни один из ответов не решил ее.

Я настроил средство запуска асинхронных заданий следующим образом и добавил квалификатор, чтобы убедиться, что этот jobLauncher введен:

 @Bean(name = "asyncJobLauncher")
 public JobLauncher simpleJobLauncher(JobRepository jobRepository) throws Exception {
        SimpleJobLauncher jobLauncher = new SimpleJobLauncher();
        jobLauncher.setJobRepository(jobRepository);
        jobLauncher.setTaskExecutor(new SimpleAsyncTaskExecutor());
        jobLauncher.afterPropertiesSet();
        return jobLauncher;
    }

И ввел его вот так

@Qualifier("asyncJobLauncher")
private final JobLauncher jobLauncher;

Я использовал Lombok @AllArgsConstructor после того, как изменил его на autowire, была введена правильная программа запуска задания, и теперь задание выполняется асинхронно:

@Autowired
@Qualifier("asyncJobLauncher")
private JobLauncher jobLauncher;

Также мне не пришлось расширять свою конфигурацию с DefaultBatchConfigurer