文件可用后立即运行Spring批处理作业

Question

当共享文件夹中的文件可用时，我希望立即运行Spring批处理作业。我已经制作了一个观察器服务来检查目录中的新条目，但是我如何触发我的批处理作业呢？

我做了以下更改-

  @Component
public class ScheduleJob {

    private Logger log = LoggerFactory.getLogger(this.getClass());

    @Autowired
    private JobLauncher jobLauncher;

    @Autowired
    private UtilizationBatchConfiguration utilizationBatchConfiguration;

    @Value("${excel.to.database.job.source.file.source.path}")
    private String PROPERTY_EXCEL_SOURCE_FILE_PATH;


    //@Scheduled(cron = "${excel.to.database.job.cron}")
    public void runJob() {
        //String fileSource = PROPERTY_EXCEL_SOURCE_FILE_PATH.concat(PROPERTY_EXCEL_SOURCE_FILE_NAME)+".xlsx";
        Path path = Paths.get(PROPERTY_EXCEL_SOURCE_FILE_PATH);
        WatchKey key;
        WatchService watchService = null;
        try {
            watchService = FileSystems.getDefault().newWatchService();
            path.register(watchService, StandardWatchEventKinds.ENTRY_CREATE);

            while ((key = watchService.take()) != null) {
                for (WatchEvent<?> event : key.pollEvents()) {

                    System.out.println(
                            "Event kind:" + event.kind()
                                    + ". File affected: " + event.context() + ".");
                    if(event.kind().equals("ENTRY_CREATE")) {
                        impoerJob();
                    }
                }
                key.reset();
            }
        } catch (IOException | InterruptedException e) {
            e.printStackTrace();
        }
    }

    private void impoerJob() {

        // make unique JobParameters so now instance of job can be started
        Map<String, JobParameter> confMap = new HashMap<String, JobParameter>();
        confMap.put("time", new JobParameter(System.currentTimeMillis()));
        JobParameters jobParameters = new JobParameters(confMap);
        try {
            JobExecution ex = jobLauncher.run(utilizationBatchConfiguration.importExcelJob(), jobParameters);
            log.info(String.format("Execution status-----> %s, Execution Start Time ------> %s, Execution End Time %s", ex.getStatus(), ex.getStartTime(), ex.getEndTime()));
        } catch (JobExecutionAlreadyRunningException | JobRestartException | JobInstanceAlreadyCompleteException
                | JobParametersInvalidException e) {
            //
            e.printStackTrace();
        }
    }
}

@Component
public class UtilizationBatchConfiguration {
---- removed for brevity

@Bean
    public Job importExcelJob() {
        return jobBuilderFactory.get("importExcelJob")
            .incrementer(new RunIdIncrementer())
            .preventRestart()
            .listener(listener)
            .flow(step1())
            .end()
            .build();
    }
}

现在，如果我尝试运行代码，我会得到下面的响应-

10.506秒内启动应用程序（JVM运行为11.676）2018-07-23 16:55:53.646信息18200---[Thread-2]S.C.A.AnnotationConfigApplicationContext:关闭org.springframework.context.annotationConfigApplicationContext@7b9a4292:启动日期[Mon Jul 23 16:55:44 IST 2018]；上下文层次结构的根目录2018-07-23 16:55:53.649信息18200---[线程-2]O.S.J.E.A.注释MBeanExporter：在关机时注销JMX公开的beans 2018-07-23 16:55:53.650信息18200---[
线程-2]O.S.J.E.A.注释MBeanExporter：注销JMX公开的beans 2018-07-23 16:55:53.654信息18200---[
线程-2]J.LocalContainerEntityManagerFactoryBean:为持久性单元“Default”关闭JPA 655信息18200---[线程-2]com.zaxxer.hikari.hikaridataSource：HikariPool-1-关机启动...2018-07-23 16:55:53.683信息18200---[线程-2]com.zaxxer.hikari.hikaridataSource：HikariPool-1-关闭完成。

另外，我如何确保每次都读取一个新文件，而不是再次读取旧文件？

Answer 1

我不能支持WatchService，但通常JVM需要至少一个非守护进程线程来防止它关闭。看起来您的应用程序没有这个功能（所以它正在关闭）。在这个用例中使用Spring Integration是很常见的，我们在下面的文档中有这一点:https://docs.Spring.io/spring-batch/trunk/reference/html/springbatchintegration.html#tunning-batch-jobs-through-messages