如何将文件名输入到 Reader 项或 spring 批次的项处理器中？

Question

我正在使用 MultiResourceItemReader 来读取设置为 Resource[] 的多个资源，并且通过使用 Fixed Length Tokenizer 我能够设置数据到 POJO class。在 Item Processor 中，我能够获取由 Item Reader 创建的对象，并能够从对象中获取数据。

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

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

感谢您对此的帮助，谢谢

*这里是批量配置*

@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;
}

Answer 1

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

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

Answer 2

如已接受的答案中所述使用了 ResourceAware，并且效果很好。添加一个简单的视觉辅助示例。

@Data
public class Contact implements ResourceAware {
    private String name;
    private String phoneNumber;
    private String inputSrcFileName;
    private Resource resource;

    @Override
    public void setResource(Resource resource) {
        this.resource = resource;
        this.inputSrcFileName = resource.getFilename();
    }
}

在 reader 输入 POJO 上实现

如何将文件名输入到 Reader 项或 spring 批次的项处理器中？

How to get File Name in to the Item Reader or Item Processor of spring batch?

java

spring-batch

spring-batch-admin

spring-boot