Spring Batch是否支持每条条目写入后的回调监听器？如何实现？

Spring Batch本身没有提供专门针对单条记录写入成功后的独立监听器，但可以通过以下几种严谨合理的方式实现需求：

1. 自定义ItemWriter包装器 #

这是最灵活的方案，通过包装原生ItemWriter，在每条记录写入完成后直接执行回调逻辑：

public class CallbackItemWriter<T> implements ItemWriter<T> {

    private final ItemWriter<T> delegate;
    private final Consumer<T> postWriteCallback;

    public CallbackItemWriter(ItemWriter<T> delegate, Consumer<T> postWriteCallback) {
        this.delegate = delegate;
        this.postWriteCallback = postWriteCallback;
    }

    @Override
    public void write(List<? extends T> items) throws Exception {
        // 先执行原生写入逻辑
        delegate.write(items);
        // 遍历每条记录执行自定义回调
        items.forEach(postWriteCallback);
    }
}

使用时只需将原有ItemWriter注入包装类，传入你的回调逻辑（比如更新记录状态、写入审计日志等）即可。

2. 利用ItemWriteListener的细粒度处理 #

Spring Batch内置的ItemWriteListener提供了afterWrite方法，默认在整个chunk写入成功后触发，你可以在该方法内遍历chunk中的每条记录，实现单条回调：

@Component
public class CustomItemWriteListener implements ItemWriteListener<YourRecordType> {

    @Override
    public void afterWrite(List<? extends YourRecordType> items) {
        items.forEach(item -> {
            // 此处编写单条记录写入成功后的逻辑
            item.setWriteStatus("SUCCESS");
            // 其他操作如持久化状态、发送通知等
        });
    }
}

将该监听器注册到step即可生效：

@Bean
public Step yourBusinessStep(StepBuilderFactory stepBuilderFactory,
                             ItemReader<YourRecordType> reader,
                             ItemProcessor<YourRecordType, YourRecordType> processor,
                             ItemWriter<YourRecordType> writer,
                             CustomItemWriteListener writeListener) {
    return stepBuilderFactory.get("yourBusinessStep")
            .<YourRecordType, YourRecordType>chunk(10)
            .reader(reader)
            .processor(processor)
            .writer(writer)
            .listener(writeListener)
            .build();
}

注意：该方法遵循Spring Batch的事务机制，只有整个chunk写入成功才会触发afterWrite，若chunk内有记录失败导致回滚，回调不会执行，保证了数据一致性。

3. 错误记录的差异化处理 #

如果需要区分成功与失败的记录，可配合ItemWriteListener的onWriteError方法处理写入失败的记录：

@Override
public void onWriteError(Exception exception, List<? extends YourRecordType> items) {
    items.forEach(item -> {
        // 标记写入失败状态或执行错误处理逻辑
        item.setWriteStatus("FAILED");
    });
}

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