时间戳

首页 > 解决方案 > 如何知道它是否是 SpringBatch 的 ItemProcessor 中的最后一项

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

问题描述

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

流程是：

另一种可能的解决方案是 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();
    }

标签： javaspringspring-batchitemprocessor

解决方案

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

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

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

推荐阅读