如何将文件名输入到 Spring Batch 的 Item Reader 或 Item Processor 中？

Posted 2023-02-27

【中文标题】如何将文件名输入到 Spring Batch 的 Item Reader 或 Item Processor 中？

【英文标题】：How to get File Name in to the Item Reader or Item Processor of spring batch?

【发布时间】：2021-09-25 11:29:21

【问题描述】：

我正在使用 MultiResourceItemReader 来读取设置为 Resource[] 的多个资源，并且通过使用 Fixed Length Tokenizer 我可以将数据设置为 POJO 类。 在项目处理器中，我能够获取项目阅读器创建的对象，并能够从对象中获取数据。

我面临的挑战是获取已创建或处理并传递给项目处理器的特定对象的文件名。

我需要将文件名连同特定对象数据一起存储到数据库中。

感谢您的帮助，谢谢

*这里是批量配置*

@Configuration
@EnableBatchProcession
    public class BatchConfig 
    
    
    @Value("")
    private Resource[] resource;

    /* Job */
    public Job job()
    return jobBuilderFactory.get("job").listerner(listener()).incrementer(new 
    RunIdIncrementer())
           .start(step()).build();
    
    /*  Step */
    public Step step()
    return stepBuilderFactory.get("step")<mypojo,mypojo>chunk(10)
    .reader(multiREsourceItemReader()).processor(processor()).writer(writer()).build();
    
    
    /* Multi Resource Item Reader */
    @Bean
    @StepScope
    public MultiResourceItemReader<mypojo> multiResourceItemReader() 
    MultiResourceItemReader<mypojo> multireader = new MultiResourceItemReader<mypojo>();
    multireader.setResource(resources);
    multireader.setDelegate(reader());
    return mutlireader;
    

   /* Flat FIle Item Reader */
   @Bean 
   public FlatFileItemReader<mypojo> reader() 
   FlatFileItmeReader<mypojo> reader = new FlatFileItemReader<mypojo>();
   reader.setLineMapper(new DefaultLineMapper() 
   
   setLineTokenizer(new FixedLengthTokenizer()   
   setName(new String[]"my pojo class attributes ...");
   setColumns( new Range  new Range[1,3] .....);
   setStrickt(false);
      
   );
   setFieldSetMapper(new BeanWrapperFieldsSetMapper<mypojo>()
      
    setTargetType(AckResponse.class):
    
   );  );
   return reader;
   

  @Bean
  public CustomItemProcessor processor()
  return new ResponseFileProcessor();
   

  @Bean
  public CustomFileWriter<mypojo> writer()
  return new CustomFileWriter<mypojo>();
  
  
  

/ 这里是项目处理器 /

public class CustomProcessor implements ItemProcessor<mypojo,mypojo>

public mypojo process(mypojo item) thows Exception 

return item;

【参考方案1】：

我已经通过在 Spring Batch 中使用 ResourceAware 接口找到了解决方案。 Mypojo 需要实现 ResourceAware 并覆盖 setResource 方法，我们可以在那里获取 Resource 详细信息。

关于资源感知：https://docs.spring.io/spring-batch/docs/current/api/org/springframework/batch/item/ResourceAware.html