SkipListener处理异常事件

Question

我有一个弹簧批处理作业，它使用SkipListener将任何错误输出到错误文件。在一个步骤（读取，处理，写入）中可能出现各种类型的错误，并且跳过监听器知道如何处理它们。这工作得很好。

但是，我已经注意到错误正在写入到输出无序。这意味着来自处理器的错误在来自阅读器的任何错误之前被写入。

这导致了我很大的问题，因为我需要在它们的读取的相同的顺序写出错误（你会发现，跳跃极限是出奇的高，提交间隔为1，因此这不是一个大块的问题）。出于所有实际的目的，这是一项非常平凡的工作，并且不会做任何会导致我相信这是造成这种情况的实际读者或处理器内的事情。

这整件事让我感到困惑;这很奇怪。我希望有人能指出我如何解决这个问题的正确方向。即使答案是“这就是它的样子，而且你不能改变它。”

这里是作业定义的相关部分：

<job id="devJob" xmlns="http://www.springframework.org/schema/batch"> 
    ... some steps ... 
    <step id="devProcessStep" next="REMOVED_FOR_SO"> 
     <tasklet> 
      <chunk reader="devFileReader" processor="devItemProcessor" writer="devOutputWriter" commit-interval="1" skip-limit="999999"> 
       <streams> 
        <stream ref="devInputReaderStream" /> 
        <stream ref="devErrorOutputWriterStream" /> 
        <stream ref="devOutputWriterStream" /> 
       </streams> 
       <skippable-exception-classes> 
        <include class="org.springframework.batch.item.ItemReaderException"/> 
        ... others, but removed since it doesn't matter for this question ... 
        <exclude class="org.springframework.batch.item.NonTransientResourceException"/> 
       </skippable-exception-classes> 
      </chunk> 
      <listeners> 
       <listener ref="devSkipListener" /> 
      </listeners> 
     </tasklet> 
    </step> 
    ... more steps ... 
</job> 
... 
<bean id="devSkipListener" class="you.have.to.guess.DevSkipListener" scope="job"> 
    <property name="writer" ref="devErrorOutputWriterStream" /> 
    ... other properties that are based on job parameters ... 
</bean> 
... 
<bean id="devErrorOutputWriter" 
    class="org.springframework.batch.item.file.FlatFileItemWriter" scope="job"> 
    ... a bunch of properties based on job parameters etc. 
</bean> 

这里是SkipListener，只有相关部分包括（请注意，我使用Groovy不是Java，因为这是一个Grails应用程序）

package you.have.to.guess 
// bunch of imports (removed for SO) 
class DevSkipListener implements SkipListener { 

    private static def log = LogFactory.getLog(this) 
    ItemWriter writer 
    // some other properties, not important 

    @Override 
    void onSkipInRead(Throwable e) { 
     log.debug("Skip error in read", e) 
     // some stuff here to figure out the lines 
     writer.write(lines) 
    } 

    @Override 
    void onSkipInProcess(Object item, Throwable e) { 
     log.debug("Skip error in process", e) 
     // some stuff here to figure out the lines 
     writer.write(lines) 
    } 

    @Override 
    void onSkipInWrite(Object item, Throwable e) { 
     log.debug("Skip error in write", e) 
     // some stuff here to figure out the lines 
     writer.write(lines) 
    } 
} 

Answer 1

简而言之，SkipListener的合同不保证要处理的项目的顺序。只有侦听器上的方法每跳过一次才会被调用。