java - 自定义 Spring Batch 应用程序中步骤的参数

Question

我正在使用 Spring Batch(使用 Spring boot)。 我的要求是从数据库读取数据，处理它(验证和内容)并将其写入文件。我正在尝试使用批处理步骤来实现这一目标。

问题是，如果我定义一个步骤，读取器、处理器和写入器应该具有类似的参数。(从我看到的示例和我得到的错误)就像我的读取器返回一个数据库一样域对象，处理器和编写器应该具有域对象参数。

我正在寻找的是，读取器应该返回域对象，处理器应该接收域对象并将其转换为 dto/pojo(在验证和数据转换之后)并返回 dto 对象。 Writer 应该接收 dto 对象并将其写入文件。

请告诉我是否可以在单个批处理步骤中具有不同类型的参数。如果是这样，请给我任何示例/链接。

Answer 1

转换项目是项目处理器的典型用例。以下是 ItemProcessor 的摘录文档部分:

An ItemProcessor is simple. Given one object, transform it and return another. The provided object may or may not be of the same type

因此，在您的情况下，读者可以将由项目处理器转换为 DTO 的域对象返回。然后，编写器将获取 DTO 并将它们写入文件。下面是一个将数字转换为字符串的简单示例:

@Bean
public ItemReader<Integer> itemReader() {
    return new ListItemReader<>(Arrays.asList(1, 2, 3, 4, 5, 6, 7, 8, 9, 10));
}

@Bean
public ItemProcessor<Integer, String> itemProcessor() {
    return item -> "foo" + item;
}

@Bean
public ItemWriter<String> itemWriter() {
    return items -> {
        for (String item : items) {
            System.out.println("item = " + item);
        }
    };
}

@Bean
public Step step() {
    return stepBuilderFactory.get("step")
            .<Integer, String>chunk(5)
            .reader(itemReader())
            .processor(itemProcessor())
            .writer(itemWriter())
            .build();
}