Могу ли я использовать FlatFileItemWriter для записи многоформатного файла в Spring Batch?

Вы можете использовать ClassifierCompositeItemProcessor с ClassifierCompositeItemWriter для этого. Идея состоит в том, чтобы классифицировать элементы в соответствии с их типом с помощью Classifier и вызывать соответствующий обработчик/записывающий элемент. Этот подход чище, чем использование нескольких проверок instance of в процессоре/писателе.

Есть несколько встроенных реализаций Classifier (думаю, SubclassClassifier вам подойдет), но при необходимости вы можете создать свои собственные.

Вы можете найти примеры в ClassifierCompositeItemProcessorTests и ClassifierCompositeItemWriterTests.

Решение, предложенное Махмудом, наконец-то сработало :) Однако есть несколько предостережений. ClassifierCompositeItemWriter предназначен для записи в разные файлы. т. е. если есть 3 разных типа записи, будет 3 разных выходных файла. Но в моем случае использования я ожидаю вывод в одном файле в том же порядке. Итак, я упомянул одно и то же имя файла в каждом бине Writer и добавил `writer.setAppendAllowed(true); Но после этого разные типы записей были объединены вместе, и порядок сортировки изменился. Итак, я уменьшил размер фрагмента с 50 до 3. 3 — это общее количество типов записей. Однако это ударит по производительности. С некоторыми подобными настройками, наконец, я получаю желаемый результат. Вот моя реализация (просто для справки, нужно больше очистки)

Configuration.java (StepBuilderFactory)

...chunk(3).reader(reader).processor(processor()).writer(writer).stream(recordType1FlatFileItemWriter()).stream(recordType2FlatFileItemWriter()).build();

Шаг процессора

@Bean
@StepScope
public ItemProcessor processor() {
            ClassifierCompositeItemProcessor<? extends RecordType, ? extends RecordType> processor = new ClassifierCompositeItemProcessor<>();
            ItemProcessor<RecordType1, RecordType1> recordType1Processor = new ItemProcessor<RecordType1, RecordType1>() {
                @Nullable
                @Override
                public RecordType1 process(RecordType1 recordType1) throws Exception {
                    //Processing logic
                    return recordType1;
                }
            };

            ItemProcessor<RecordType2, RecordType2> recordType2Processor = new ItemProcessor<RecordType2, RecordType2>() {
                @Nullable
                @Override
                public RecordType2 process(RecordType2 recordType2) throws Exception {
                    //Processing logic
                    return recordType2;
                }
            };

        SubclassClassifier classifier = new SubclassClassifier();
        Map typeMap = new HashMap();
        typeMap.put(RecordType1.class, recordType1Processor);
        typeMap.put(RecordType2.class, recordType2Processor);
        classifier.setTypeMap(typeMap);
        processor.setClassifier(classifier);
        return processor;
    }

Шаг писателя

    @Bean
    @StepScope
    public ClassifierCompositeItemWriter writer(@Value("#{stepExecutionContext[fileName]}") Resource file) throws Exception {
        ClassifierCompositeItemWriter<String> writer = new ClassifierCompositeItemWriter<>();
        SubclassClassifier classifier = new SubclassClassifier<>();
        Map typeMap = new HashMap<>();
        typeMap.put(RecordType1.class, recordType1FlatFileItemWriter());
        typeMap.put(RecordType2.class, recordType2FlatFileItemWriter());
        typeMap.put(RecordType3.class, recordType3FlatFileItemWriter());
        classifier.setTypeMap(typeMap);
        writer.setClassifier(classifier);
        return writer;
    }

Писатель

    @Bean
    public FlatFileItemWriter<RecordType1> recordType1FlatFileItemWriter() throws Exception{
        FlatFileItemWriter<RecordType1> writer = new FlatFileItemWriter<>();
        writer.setResource( new FileSystemResource(outputFolder + "test.txt"));
        writer.setAppendAllowed(true);
        writer.setLineAggregator(new DelimitedLineAggregator<RecordType1>() {{
            setDelimiter("#");
            setFieldExtractor(new BeanWrapperFieldExtractor<RecordType1>() {
                {
                    setNames(new String[] { "RecordType", "ID1", "ID2", "ID3");
                }
            });
        }});
        return  writer;
    }

    @Bean
    public FlatFileItemWriter<RecordType2> recordType2FlatFileItemWriter() throws Exception{
        FlatFileItemWriter<RecordType2> writer = new FlatFileItemWriter<>();
        writer.setResource( new FileSystemResource(outputFolder + "test.txt"));
        writer.setAppendAllowed(true);
        writer.setLineAggregator(new DelimitedLineAggregator<RecordType2>() {{
            setDelimiter("#");
            setFieldExtractor(new BeanWrapperFieldExtractor<RecordType2>() {
                {
                    setNames(new String[] { "RecordType", "ID9", "ID8",);
                }
            });
        }});
        return  writer;
    }