使用MultiResourceItemReader读取2个纯文本文件并写入单个文件

Question

我的批处理作业将生成每行字符串格式的2个文本文件。我创建了一个阅读器

<bean id="myMultiResourceReader"
    class=" org.springframework.batch.item.file.MultiResourceItemReader">
    <property name="resources" value="file:D:/MY/sample/*.txt" />
</bean> 
<bean id="myFinalWriter" class="org.springframework.batch.item.file.FlatFileItemWriter"
    scope="step">
    <property name="resource" value="${test.file3}" />
    <property name="lineAggregator">
        <bean
            class="org.springframework.batch.item.file.transform.PassThroughLineAggregator" />
    </property>
    <property name="footerCallback" ref="myFinalCustomItemWriter" />
    <property name="headerCallback" ref="myFinalCustomItemWriter" />
</bean>
<bean id="myFinalCustomItemWriter" class="my.process.MyWriter"
    scope="step">
    <property name="delegate" ref="myFinalWriter" />
    <property name="stepContext" value="#{stepExecution.stepName}" />
</bean>

我得到了这个错误：

Caused by: org.springframework.beans.ConversionNotSupportedException: Failed to convert property value of type 'com.sun.proxy.$Proxy68 implementing org.springframework.batch.item.file.ResourceAwareItemWriterItemStream,org.springframework.beans.factory.InitializingBean,org.springframework.batch.item.ItemStreamWriter,org.springframework.batch.item.ItemStream,org.springframework.aop.scope.ScopedObject,java.io.Serializable,org.springframework.aop.framework.AopInfrastructureBean,org.springframework.aop.SpringProxy,org.springframework.aop.framework.Advised' to required type 'org.springframework.batch.item.file.FlatFileItemWriter' for property 'delegate'; nested exception is java.lang.IllegalStateException: Cannot convert value of type [com.sun.proxy.$Proxy68 implementing org.springframework.batch.item.file.ResourceAwareItemWriterItemStream,org.springframework.beans.factory.InitializingBean,org.springframework.batch.item.ItemStreamWriter,org.springframework.batch.item.ItemStream,org.springframework.aop.scope.ScopedObject,java.io.Serializable,org.springframework.aop.framework.AopInfrastructureBean,org.springframework.aop.SpringProxy,org.springframework.aop.framework.Advised] to required type [org.springframework.batch.item.file.FlatFileItemWriter] for property 'delegate': no matching editors or conversion strategy found

public class MyWriter implements ItemWriter<String>, FlatFileFooterCallback, FlatFileHeaderCallback, ItemStream{
private static Logger log = Logger.getLogger(MyWriter.class);
private FlatFileItemWriter<String> delegate;
private int recordCount = 0;
private String stepContext;

public void writeFooter(Writer writer) throws IOException {
    writer.write("#" + recordCount);
}

public void writeHeader(Writer writer) throws IOException {
    writer.write("#" + StringUtil.getSysDate());
}

public void setDelegate(FlatFileItemWriter<String> delegate) {
    this.delegate = delegate;
}

public void write(List<? extends String> list) throws Exception {
     int chunkRecord = 0;
    for (String item : list) {
        chunkRecord++;
    }
    delegate.write(list);
    recordCount += chunkRecord;
}

public void close() throws ItemStreamException {
    this.delegate.close();
}

public void open(ExecutionContext arg0) throws ItemStreamException {
    this.delegate.open(arg0);
}

public void update(ExecutionContext arg0) throws ItemStreamException {
    this.delegate.update(arg0);
}

public void setStepContext(String stepContext) {
    this.stepContext = stepContext;
}

Answer 1

正如Luca Basso Ricci已经指出的，问题在于您在MyWriter中的委托定义。由于Spring为它的bean创建代理，它将无法将您的FlatFileItemReader识别为FlatFileItemWriter的实际实例，因此，setDelegate（FlatFileItemWriter委托）将失败。

在MyWriter中使用ItemStreamWriter正如您在异常消息中看到的，创建的代理确实提供了这个接口。因此，可以插入

这将解决委托写、打开、关闭和更新方法。为了编写页眉和页脚，您需要实现HeaderCallback和FooterCallback，并直接在FlatFileItemWriter的定义中设置它。

作为FooterCallback，创建您自己的bean。在FlatFileItemWriter中使用它来编写页脚。向它添加一个“recreeCount”方法，并在MyWriter Bean中使用它来增加写入计数。

public void write(List<? extends String> list) throws Exception {
    myFooterCallback.increaseCount(list.size());
    delegate.write(list);
}