Spring Batch中FlatFileItemWriter重复覆盖文件及增量命名需求

看起来你遇到的核心问题是Spring Bean的单例特性导致文件名在容器启动时就被固定，后续作业执行不会重新生成新的文件名。你的OrderFileManager逻辑本身是对的，但因为FlatFileItemWriter作为单例Bean只会初始化一次，所以每次作业都会复用同一个初始文件名，导致文件被覆盖。下面是具体的修复方案：

问题根源 #

Spring默认的Bean是单例模式，你的writer方法被标记为@Bean，所以在容器启动时就会执行一次，调用getEmptyOrderNameString()获取文件名并固定下来。后续每次作业执行时，都会复用这个已经初始化好的Writer实例，自然会写入同一个文件。

解决方案：让文件名在作业执行时动态生成 #

我们可以通过StepScope来实现Writer的动态初始化，确保每次作业执行时都会重新调用OrderFileManager生成新的文件名。

1. 修改Writer的Bean配置，添加StepScope

使用@StepScope注解让Writer成为Step级别的Bean，这样每次Step执行时都会重新创建实例，并通过SpEL表达式动态调用OrderFileManager的方法获取最新文件名：

import org.springframework.batch.core.configuration.annotation.StepScope;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.batch.item.file.FlatFileItemWriter;
import org.springframework.batch.item.file.transform.BeanWrapperFieldExtractor;
import org.springframework.batch.item.file.transform.DelimitedLineAggregator;
import org.springframework.core.io.FileSystemResource;

@Configuration
public class BatchConfig {

    @Bean
    @StepScope // 关键：让Writer在每次Step执行时重新初始化
    public FlatFileItemWriter<UltravisionOrder> writer(
            @Value("#{orderFileManager.getEmptyOrderNameString()}") String fileName) {
        FlatFileItemWriter<UltravisionOrder> writer = new FlatFileItemWriter<>();
        writer.setResource(new FileSystemResource(fileName));
        
        DelimitedLineAggregator<UltravisionOrder> delimitedLineAggregator = new DelimitedLineAggregator<>();
        delimitedLineAggregator.setDelimiter(";");
        
        BeanWrapperFieldExtractor<UltravisionOrder> fieldExtractor = new BeanWrapperFieldExtractor<>();
        fieldExtractor.setNames(new String[] { "col1", "col2", "col3" }); // 替换为你的实际字段
        delimitedLineAggregator.setFieldExtractor(fieldExtractor);
        
        writer.setLineAggregator(delimitedLineAggregator);
        return writer;
    }

    // 其他配置：Reader、Processor、Step、Job...
}

2. 优化OrderFileManager（可选但推荐）

• 增加输出目录管理，避免工作目录混乱
• 添加同步锁防止并发作业时的文件名冲突

import java.io.File;
import org.springframework.stereotype.Component;

@Component
public class OrderFileManager {
    private final String orderDesc = "order";
    private final String fileEnding = ".csv";
    private final String outputDir = "./batch-output/"; // 指定固定输出目录

    // 加同步锁避免多作业并发时的文件名冲突
    public synchronized String getEmptyOrderNameString() {
        // 确保输出目录存在
        File dir = new File(outputDir);
        if (!dir.exists()) {
            dir.mkdirs();
        }

        int fileNumber = 1;
        String filePath = outputDir + orderDesc + fileNumber + fileEnding;
        while (new File(filePath).exists()) {
            fileNumber++;
            filePath = outputDir + orderDesc + fileNumber + fileEnding;
        }
        return filePath;
    }
}

3. 确认Step配置正确

在Step中直接引用上述的Writer Bean即可，无需手动传递文件名：

@Bean
public Step exportStep(FlatFileItemWriter<UltravisionOrder> writer,
                       ItemReader<UltravisionOrder> reader,
                       ItemProcessor<UltravisionOrder, UltravisionOrder> processor,
                       StepBuilderFactory stepBuilderFactory) {
    return stepBuilderFactory.get("exportStep")
            .<UltravisionOrder, UltravisionOrder>chunk(100)
            .reader(reader)
            .processor(processor)
            .writer(writer)
            .build();
}

为什么这样能解决问题？ #

• @StepScope会让Spring在每次Step执行时创建一个新的Writer实例，而不是复用单例
• 通过@Value("#{orderFileManager.getEmptyOrderNameString()}")，每次创建Writer时都会调用OrderFileManager的方法生成新的文件名，确保不会覆盖已有文件

内容的提问来源于stack exchange，提问作者eckad158