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

问题描述

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

流程是：

• ItemReader - 从数据库中读取行（预计数百万行）
• ItemProcessor - 在每一行上执行一些验证，发送到网络服务并使用网络服务响应执行更多验证。
• 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();
    }

解决方法

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

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

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