我是 Spring 批次的新手。
我需要计算读取、写入和出错的元素。
我定义了这样的步骤：
/*...*/
@Bean
public Step stepMain(StepBuilderFactory stepBuilderFactory) {
return stepBuilderFactory.get("stepMain").<T, T> chunk(this.chuckSize).reader(reader(null, null)).processor(new Processor()).writer(writer()).faultTolerant().skipPolicy(new AlwaysSkipItemSkipPolicy()).listener(new ListenerReader()).listener(new ListenerProcessor()).listener(new ListenerWriter()).listener(new ListenerChunk()).build();
}
/*...*/
例如，这样的 ListenerReader：
@Log4j2
public class ListenerReader implements ItemReadListener<T> {
@Value("#{jobExecution.executionContext}")
private ExecutionContext executionContext;
@Override
public void afterRead(T item) {
Integer read = (Integer) executionContext.get("reportRead");
read++;
executionContext.put("reportRead", read);
}
@Override
public void onReadError(Exception ex) {
Integer error = (Integer) executionContext.get("reportError");
error++;
executionContext.put("reportError", error);
}
}
但在 ListenerReader 中我看不到executionContext 字段。
我该如何解决？
你可以这样做
- 使用 JobScope 定义 Bean
- 像平常一样在 Step 中使用它
- 通过监听器注入它。
下面是一个例子
@Bean
@JobScope
public SimpleReaderListener simpleReaderListener() {
return new SimpleReaderListener();
}
@Bean
public Step step1() {
return stepBuilderFactory.get("step1").<SoccerTeam, SoccerTeam> chunk(1)
.reader(simpleReader()).listener(simpleReaderListener()).processor(new SimpleProcessor())
.writer(new SimpleWriter()).build();
}
public class SimpleReaderListener implements ItemReadListener<SoccerTeam> {
@Value("#{jobExecution.executionContext}")
private ExecutionContext executionContext;
@Override
public void afterRead(SoccerTeam soccerTeam) {
}
本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系:hwhale#tublm.com(使用前将#替换为@)
