spring批处理在下一步骤阅读器中从作业上下文检索数据

Question

我是新的spring批处理，只是寻找一些帮助通过一个步骤之间的列表。在step 1 writer中，我将向ExecutionContext添加一个列表。

ExecutionContext stepContext = this.stepExecution.getExecutionContext();
stepContext.put("messageList", messages);

在第二步的阅读器中，我通过执行以下操作返回数据：

JobExecution jobExecution = stepExecution.getJobExecution();
    ExecutionContext jobContext = jobExecution.getExecutionContext();
    this.messages=  jobContext.get("messageList");

这样做起作用了，我得到了列表，但我遇到的问题是，我想把这个列表传递给处理器，但是ItemReader中的read（）方法会连续循环返回列表，因为我只想返回一次列表。在这样做的同时，处理器也会循环。在第二步中，有没有一种方法可以将列表传递给阅读器，而不需要read（）方法执行此操作？贝娄是我的留言阅读器

public class MessageReader implements ItemReader<Object> {

private Object messages;
@Override
public Object read() throws Exception, UnexpectedInputException, ParseException, NonTransientResourceException {

    return messages;
}
    @BeforeStep
public void retrieveSharedStepDate(StepExecution stepExecution){
    JobExecution jobExecution = stepExecution.getJobExecution();
    ExecutionContext jobContext = jobExecution.getExecutionContext();
    this.messages=  jobContext.get("messageList");
}

所以基本上，我要做的是让我的读者在第二步中阅读我的writer在第一步中生成的列表。

Answer 1

我设法找到了问题的根本原因。来自ItemReader API

读取一段输入数据并前进到下一段。实现必须在输入数据集的末尾返回null

我的阅读器从来没有返回null，所以它进入了一个无限循环。为了修复，我修改了它，所以一旦我发送了我想要的数据，我就返回NULL。