聚合处理器或聚合阅读器 [英] Aggregating processor or aggregating reader

问题描述

我有一个要求，就像我从一个数据库中读取项目，如果可能的话，以一种分页的方式，其中项目代表后来的"批量大小"，我做一些处理步骤，比如过滤等，然后我想累计这些项目，将其发送到睡觉服务，在那里我可以分批发送，例如一次n个，而不是逐个发送。

在步骤级别并行化是我正在做的事情，但是我不确定如何使批处理工作，我是否需要实现返回列表的读取器和接收列表的处理器？如果是这样的话，我读到您将不会有一个正确的账户数量的项目处理。

我正在努力寻找一种最合适的Spring Batch方法，而不是破解修复程序，我还假设我需要在阅读器中保持状态，并想知道是否有更好的方法不这样做。

推荐答案

您不能拥有像聚合处理器这样的东西。读取的每个项目都作为单个项目处理。

但是，您可以实现对项目进行分组并将其作为一个整体转发的Reader。要了解如何做到这一点，请看我对此问题的回答Spring Batch Processor或Dean Clark在此处的回答Spring Batch-How to process multiple records at the same time in the processor?。

两者都使用SpringBatch的SingleItemPeekableItemReader。

这篇关于聚合处理器或聚合阅读器的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！