聚合處理器或聚合閱讀器

Question

我有一個需求，就像我從一個數據庫中讀取項目，如果可能以分頁方式代表稍後的「批量大小」，我會執行一些處理步驟，如過濾等那麼我想積累這些物品，將它發送到一個可以批量發送的休息服務，例如他們中的一個，而不是一個接一個。

在步驟級別上並行化是我正在做的，但我不確定如何讓批處理工作，我是否需要實現一個返回列表的處理器和接收列表的處理器？如果是這樣，我讀到你將沒有一個適當的帳號處理的帳號。

我試圖找到一種方法來做到最合適的春天批處理方式，而不是黑客修復，我還假設我需要保持讀者的狀態，並想知道是否有更好的方法不要。

Answer 1

你不能像聚合處理器那樣。每一個被讀取的項目都被處理爲單個項目。

但是，您可以實現將項目分組並將其作爲整個組轉發的Reader。得到一個想法，如何做到這一點看看我的回答這個問題Spring Batch Processor或迪克拉克的答案在這裏Spring Batch-How to process multiple records at the same time in the processor?。

兩者都使用SpringBatch的SingleItemPeekableItemReader。