Spring批量保存拒绝文件中跳过的读卡器行

@Component
public class MySkipListener<T> implements SkipListener<T, T> {

    private String rejectedFile = "rejected.txt";
    private FileWriter writer;

    @PostConstruct
    public void init() throws IOException {
        writer = new FileWriter(rejectedFile);
    }

    @Override
    public void onSkipInRead(Throwable t) {
        // 在读取器遇到无法解析的行时调用
        String skippedLine = // 获取无法解析的行内容
        writer.write(skippedLine + "\n"); // 将行写入拒绝文件
    }

    // 省略其他方法...
}

@Configuration
@EnableBatchProcessing
public class BatchConfig {

    @Autowired
    private JobBuilderFactory jobBuilderFactory;

    @Autowired
    private StepBuilderFactory stepBuilderFactory;

    @Autowired
    private MySkipListener mySkipListener;

    @Bean
    public ItemReader<T> itemReader() {
        // 配置读取器
    }

    @Bean
    public ItemWriter<T> itemWriter() {
        // 配置写入器
    }

    @Bean
    public Step step(ItemReader<T> itemReader, ItemWriter<T> itemWriter) {
        return stepBuilderFactory.get("myStep")
                .<T, T>chunk(10)
                .reader(itemReader)
                .writer(itemWriter)
                .faultTolerant()
                .skip(Exception.class)
                .skipLimit(1000)
                .listener(mySkipListener)
                .build();
    }

    @Bean
    public Job job(Step step) {
        return jobBuilderFactory.get("myJob")
                .start(step)
                .build();
    }
}