如何知道它是否是 Spring Batch 的 ItemProcessor 中的最后一项

Question

我有以下 ItemProcessor，我需要知道该项目是否是阅读器发送的最后一个项目。这可能吗？

流程是：

• ItemReader - 从数据库中读取行数（预计数百万行）
• ItemProcessor - 对每一行执行一些验证，发送到 webservice 并使用 webservice 响应执行更多验证。
• ItemWriter - 从验证中写入数据库错误，并更改线路状态。

另一个可能的解决方案是 ItemReader 发送 Line 大小为 NUMBER_OF_LINES_TO_CALL_WEBSERVICE 的列表，但我找不到有关如何修改 JpaPagingItemReader 的示例。

    @Override
    public List<Line> process(Line line) {
        

        lineList.add(line);

        if (lineList.size() == NUMBER_OF_LINES_TO_CALL_WEBSERVICE) {

            callWs(lineList);
            
            return lineList;    // goes to ItemWriter to write the response from ws in database 
        }
        
        if( /* TODO if last line */) {      
            
            callWs(lineList);

            return lineList;
        }
        

        return null;
    }
    
    private void callWs(List<Line> lineList){
        ...
        //Get response from webservice and add info to lines
    }

    @Override
    public void afterChunk(ChunkContext chunkContext) {

        if (lineList.size() == NUMBER_OF_LINES_TO_CALL_WEBSERVICE) {
            lineList.clear();
        }

    }
    

读者是JpaPagingItemReader：

    @Bean
    @StepScope
    public JpaPagingItemReader<Line> itemReader(@Qualifier("EntityManagerFactory") EntityManagerFactory entityManagerFactory) {


        String queryStr = "select l from Line l" ;

        return new JpaPagingItemReaderBuilder<Linha>()
                .name("lineReader")
                .entityManagerFactory(entityManagerFactory)
                .queryString(queryStr)
                .pageSize(PAGE_SIZE)
                .build();
    }

Answer 1

我想将包含 100 个元素的列表中的行分组以发送到 Web 服务，当最后一项发送到处理器时，剩余的行将发送到 Web 服务。

您可以使用块大小为 100 的面向块的步骤。该步骤将为您进行缓冲，并且您可以访问项目列表的过程中的第一个点位于 ItemWriteListener#beforeWrite(List items) 中。因此，您可以使用该侦听器执行 Web 服务调用，也可以在 ItemWriter 本身中执行此操作（如果这是您需要执行的唯一 write 操作）。

一旦你有了项目列表，你就可以对它做任何你想做的事情（即检查最后一个项目，过滤前 99 个项目并将它们发送到网络服务等）。