Spring Batch：具有自定义 ItemReader 的 MultiResourceItemReader 无限读取相同的文件答案

【问题标题】：Spring Batch: MultiResourceItemReader with custom ItemReader reads the same file ad infinitumSpring Batch：具有自定义 ItemReader 的 MultiResourceItemReader 无限读取相同的文件
【发布时间】：2015-03-31 16:52:46
【问题描述】：

我有一个带有自定义 ItemReader 作为委托的 MultiResourceItemReader。我面临的问题是，当我启动作业时，会一遍又一遍地读取同一个文件。

这是委托类：

public class AllegatiReader implements ResourceAwareItemReaderItemStream<Allegato> {

    @PersistenceContext
    protected EntityManager em;

    private Resource resource;

    @Override
    public void close() throws ItemStreamException {
    }

    @Override
    public void open(ExecutionContext arg0) throws ItemStreamException {    
    }

    @Override
    public void update(ExecutionContext arg0) throws ItemStreamException {
    }

    @Override
    public Allegato read() throws Exception, UnexpectedInputException,
            ParseException, NonTransientResourceException {

        // DO SOMETHING ...     

        byte[] fileContent = new byte[(int) resource.getFile().length()];

        resource.getInputStream().read(fileContent);
        resource.getInputStream().close();

        allegato.getFile().setFile(fileContent);

        return allegato;
    }

    @Override
    public void setResource(Resource arg0) {
        this.resource = arg0;       
    }
}

这是我的 Spring Batch XML 配置文件：

<batch:job id="allegati" incrementer="jobParametersIncrementer">
    <batch:step id="allegati-import">
        <batch:tasklet>
            <batch:chunk reader="allegati-reader" writer="allegati-writer" commit-interval="1"/>
        </batch:tasklet>
    </batch:step>
</batch:job>

<bean id="allegati-reader" class="org.springframework.batch.item.file.MultiResourceItemReader" scope="step">
    <property name="resources" value="file:#{jobParameters['FILEPATH']}/*" />
    <property name="delegate" ref="allegati-filereader" />
</bean>

<bean id="allegati-writer" class="org.springframework.batch.item.database.JpaItemWriter">
    <property name="entityManagerFactory" ref="entityManagerFactory" />
</bean>

<bean id="allegati-filereader" class="it.infogroup.vertenze.porting.reader.AllegatiReader" />

如何告诉 Spring Batch 移动到下一个文件？

【问题讨论】：

你能提供你的配置吗？
读完所有内容后，您的 read() 是否会返回 null？不返回 null Spring Batch 不知道 Reader 何时完成
@MichaelMinella 我已经添加了配置文件
@MichaelPralow 不，我的读者从不返回 null ......这可能是问题

标签： java spring-batch

【解决方案1】：

您的自定义阅读器必须在完成所有操作后显示 Spring Batch，请参阅 http://docs.spring.io/spring-batch/trunk/apidocs/org/springframework/batch/item/ItemReader.html#read--

读取一段输入数据并前进到下一个。实现必须在输入数据集的末尾返回 null。

在您的情况下，我将使用私有属性来保存* 此阅读器实例的资源已处理的状态，它可能是 Allegato 对象，但这似乎是一个相当大的对象

*) 你的阅读器在设计上是有状态的，所以另一个状态属性应该没问题

【讨论】：