Spring Batch作业参数列表访问及动态文件处理问题

嘿，针对你这个Spring Batch动态处理文件的需求，我给你整理了一套清晰的实现思路和代码示例，应该能解决你的问题：

先明确下你的核心诉求：

• 每日自动读取并处理两个对应不同市场的文件
• 文件路径/名称需要根据**前一个工作日（previousWorkingDate）**动态生成，文件名规则由枚举定义
• 自定义的FileMovingTasklet需要能访问JobParameters中的日期和市场相关参数
• 遍历市场列表，动态处理每个市场对应的文件

1. 定义文件名枚举，规范不同市场的文件命名模板 #

首先用枚举统一管理不同市场的文件名格式，这样后续新增市场时只需扩展枚举即可：

public enum MarketFileType {
    US_MARKET("us_market_data_%s.csv"),
    EU_MARKET("eu_market_data_%s.csv");

    private final String fileNameTemplate;

    MarketFileType(String fileNameTemplate) {
        this.fileNameTemplate = fileNameTemplate;
    }

    // 根据日期生成完整文件名
    public String generateFileName(String dateStr) {
        return String.format(fileNameTemplate, dateStr);
    }
}

2. 构建包含必要参数的JobParameters #

在启动Job前，需要计算出前一个工作日，并把日期、市场列表等参数传入JobParameters，这样Tasklet就能拿到这些动态值：

// 自定义工具类计算前一个工作日（需处理节假日/周末逻辑）
LocalDate previousWorkingDate = WorkingDateUtils.getPreviousWorkingDate(LocalDate.now());
String dateStr = previousWorkingDate.format(DateTimeFormatter.ofPattern("yyyyMMdd"));

// 构建JobParameters
JobParametersBuilder paramsBuilder = new JobParametersBuilder();
// 传入前一个工作日
paramsBuilder.addString("previousWorkingDate", dateStr);
// 传入需要处理的市场列表（直接用枚举名称拼接）
String marketList = String.join(",", Arrays.stream(MarketFileType.values()).map(Enum::name).toArray(String[]::new));
paramsBuilder.addString("targetMarkets", marketList);

// 启动Job
jobLauncher.run(dailyFileProcessingJob, paramsBuilder.toJobParameters());

3. 改造FileMovingTasklet，实现动态文件获取与移动 #

让Tasklet通过ChunkContext获取JobParameters，然后遍历市场列表，动态生成文件路径并执行移动操作：

@Component
public class FileMovingTasklet implements Tasklet {

    // 从配置文件读取文件共享根路径和处理后文件存放路径
    @Value("${file.share.root-path}")
    private String fileShareRootPath;

    @Value("${file.processed.target-path}")
    private String processedTargetPath;

    @Override
    public RepeatStatus execute(StepContribution contribution, ChunkContext chunkContext) throws Exception {
        // 从ChunkContext中拿到JobParameters
        JobParameters jobParams = chunkContext.getStepContext().getStepExecution().getJobParameters();
        String workingDate = jobParams.getString("previousWorkingDate");
        String[] targetMarkets = jobParams.getString("targetMarkets").split(",");

        for (String marketName : targetMarkets) {
            MarketFileType marketType = MarketFileType.valueOf(marketName);
            String fileName = marketType.generateFileName(workingDate);
            
            // 拼接源文件和目标文件路径
            Path sourceFile = Paths.get(fileShareRootPath, fileName);
            Path targetFile = Paths.get(processedTargetPath, fileName);

            // 检查源文件是否存在，再执行移动
            if (Files.exists(sourceFile)) {
                // 移动文件，支持覆盖已存在的目标文件
                Files.move(sourceFile, targetFile, StandardCopyOption.REPLACE_EXISTING);
                contribution.incrementWriteCount(1);
                System.out.printf("成功移动文件: %s -> %s%n", sourceFile, targetFile);
            } else {
                System.err.printf("未找到源文件: %s%n", sourceFile);
                // 这里可以根据业务需求选择抛出异常终止Job，或者跳过继续处理其他文件
                // throw new FileNotFoundException("源文件不存在: " + sourceFile);
            }
        }

        return RepeatStatus.FINISHED;
    }
}

• 日期处理优化：如果需要处理节假日，建议集成成熟的日期工具库，或者自己维护节假日配置表来准确计算前一个工作日。
• 异常重试机制：如果文件移动可能出现临时失败（比如文件被占用），可以给Tasklet添加Spring Batch的重试注解@Retryable，配置重试次数和重试条件。
• 动态生成Step：如果每个市场的文件处理逻辑差异较大，可以考虑在Job配置中动态遍历市场列表，为每个市场生成独立的Step，实现更细粒度的控制。
• 参数校验：在Job启动前对previousWorkingDate、targetMarkets等参数做非空校验，避免空值导致的运行时错误。

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