在Spring Batch应用程序中自定义一个步骤的参数

Question

我正在使用Spring Batch（使用Spring boot）。我的要求是从db读取数据，处理它（验证和stuffs)，并将其写入文件。我试图实现这一点使用一个批处理步骤。

问题是，如果我定义了一个步骤，读取器、处理器和编写器应该有相似的参数。（从我看到的示例和错误来看）就像如果我的读取器返回一个db域对象，处理器和编写器应该有域对象参数一样。

我正在寻找的是，阅读器应该返回域对象，处理器应该接收域对象并将其转换为dto/POJO（经过验证和数据转换），并返回dto对象。Writer应该正在接收dto对象并将其写入文件。

请让我知道，如果这是可能的在一个单一的批处理步骤有不同类型的参数。如果是这样，请给我任何例子/链接到它。

Answer 1

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

项目处理器很简单。给定一个对象，转换它并返回另一个。所提供的对象可以是也可以不是同一类型的

因此，在您的例子中，读取器可以返回由项处理器转换为DTOS的域对象。然后，编写器将获取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();
}