Spring Batch Stax XML 读取作业在输入不足时不会结束

Question

我正在使用 Spring Batch 设置一个作业来处理可能非常大的 XML 文件。我认为我已经正确设置了它，但在运行时我发现作业运行，处理其输入，然后挂起在执行状态（我可以通过查看 JobRepository 中的 JobExecution 状态来确认）。

我已多次阅读批处理文档，但没有看到任何明显的“输入不足时停止作业”配置。

这是我的应用程序上下文的相关部分：

<batch:job id="processPartnerUploads" restartable="true">
    <batch:step id="processStuffHoldings">
        <batch:tasklet>
            <batch:chunk reader="stuffReader" writer="stuffWriter" commit-interval="1"/>
        </batch:tasklet>        
    </batch:step>
</batch:job>

<bean id="stuffReader" class="org.springframework.batch.item.xml.StaxEventItemReader">
  <property name="fragmentRootElementName" value="stuff" />
  <property name="resource" value="file:///path/to/file.xml" />
  <property name="unmarshaller" ref="stuffUnmarshaller" />
</bean>

<bean id="stuffUnmarshaller" class="org.springframework.oxm.jaxb.Jaxb2Marshaller">
    <property name="contextPath" value="com.company.project.xmlcontext"/>
</bean>

<bean id="stuffWriter" class="com.company.project.batch.StuffWriter" />

如果重要的话，“StuffWriter”只是一个记录将要写入的项目的类。

如果我错过了与 Batch 和/或 Stax 相关的一些重要细微差别，请告诉我。

Answer 1

我已经自己解决了这个问题，尽管我对自己必须做的事情感到惊讶。通过 StaxEventItemReader 进行调试，我注意到当到达文档末尾时，moveCursorToNextFragment() 方法中的内部循环将无限循环。这是相关代码：

while (true) {
    while (reader.peek() != null && !reader.peek().isStartElement()) {
        reader.nextEvent();
    }
    if (reader.peek() == null) {
        return false;
    }
    QName startElementName = ((StartElement) reader.peek()).getName();
    if (startElementName.getLocalPart().equals(fragmentRootElementName)) {
        if (fragmentRootElementNameSpace == null
    || startElementName.getNamespaceURI().equals(fragmentRootElementNameSpace)) {
           return true;
        }
     }
    reader.nextEvent();
 }

reader.peek() 从未返回 null。在我看来，这段代码应该检查 peek() 期间遇到的 XMLEvent 是否位于文档末尾，但这并不是那么简单，因为 StaxEventItemReader 依赖于包装标准 XMLEventReader 的 DefaultFragmentEventReader。

我最终要做的是基于 StaxEventItemReader 滚动我自己的 ItemReader，但根本不使用 FragmentEventReader，然后调整内部循环代码以如下所示读取：

        if (reader.peek().getEventType() == XMLStreamConstants.END_DOCUMENT) {
            return false;
        }
        reader.nextEvent();

这完美地工作并允许我的批处理作业在输入结束时转到 COMPLETED 。

不过，我真的很惊讶我必须这样做。我想知道我使用的流式 XML 库的底层实现是否有错误，但我使用的是 Spring Batch 依赖项列表中引用的 stax2-api-3.0.1.jar。

我还发现我并不孤单 。