java - 如何在 Spring Batch 中从 ItemReader 动态设置 MultiResourceItemWriter 的资源

Question

批处理作业是:

• 从 csv 文件读取

• 为 csv 中的每条记录(行)创建一个名为 Patent.ID.xml 的 xml 文件(其中 ID 是 csv 中的一个字段，Patent 是我的模型类)，示例:1.xml，2 .xml

问题是我找不到一种方法来为 csv 文件中的每个 ID 动态设置文件名

这是我的配置:

<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:batch="http://www.springframework.org/schema/batch"xmlns:task="http://www.springframework.org/schema/task"
    xmlns:util="http://www.springframework.org/schema/util"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://www.springframework.org/schema/batch
        http://www.springframework.org/schema/batch/spring-batch-2.2.xsd
        http://www.springframework.org/schema/beans 
        http://www.springframework.org/schema/beans/spring-beans-3.2.xsd
        http://www.springframework.org/schema/util 
        http://www.springframework.org/schema/util/spring-util-3.2.xsd">


    <!-- My beans -->   
    <bean id="patent" class="com.example.model.Patent" scope="prototype" />
    <bean id="xmlsuffix" class="com.example.filename.PatentFileSuffixCreator"/>
    <bean id="noInputException"     class="com.example.listener.NoWorkFoundStepExecutionListener"/>

    <batch:job id="csvtoxml">
        <batch:step id="step1">
            <batch:tasklet>             
                <batch:chunk reader="fileReader"     writer="multiResourceItemWriter" commit-interval="1">
                </batch:chunk>
                <batch:listeners>
                    <batch:listener ref="noInputException"/>
                </batch:listeners>  
            </batch:tasklet>
        </batch:step>
    </batch:job>

    <bean id="multiResourceItemWriter"
    class="org.springframework.batch.item.file.MultiResourceItemWriter">
        <property name="resource" value="file:xml/#{patent.ID}" />
        <property name="delegate" ref="XMLwriter"/>
        <property name="itemCountLimitPerResource" value="1"/>
        <property name="resourceSuffixCreator" ref="xmlsuffix"/>
    </bean>

    <bean id="XMLwriter" 
                class="org.springframework.batch.item.xml.StaxEventItemWriter">
        <property name="marshaller" ref="patentUnmarshaller" />
        <property name="rootTagName" value="Patents" />
    </bean>

    <bean id="patentUnmarshaller" 
     class="org.springframework.oxm.xstream.XStreamMarshaller">
        <property name="aliases">
            <map>
                <entry key="Patent"
                value="com.example.model.Patent" />
            </map>
        </property>
    </bean>

  <bean id="fileReader"
        class="org.springframework.batch.item.file.FlatFileItemReader" scope="step">
        <property name="lineMapper" ref="lineMapper"/>
        <property name="resource" value="file:dbbrev_sample_m.csv"/>
        <property name="linesToSkip" value="1"/>
    </bean>

    <bean id="lineMapper"
        class="org.springframework.batch.item.file.mapping.DefaultLineMapper">
        <property name="fieldSetMapper" ref="fieldSetMapper"/>
        <property name="lineTokenizer" ref="lineTokenizer"/>
    </bean>

    <bean id="lineTokenizer"
        class="org.springframework.batch.item.file.transform.DelimitedLineTokenizer">
        <property name="delimiter" value=","/>
        <property name="names" value="ID,TYPE,NOPUBLICATION" />
    </bean>

    <bean id="fieldSetMapper"
        class="org.springframework.batch.item.file.mapping.BeanWrapperFieldSetMapper">
        <property name="targetType" value="com.example.model.Patent"/>
    </bean>
</beans>

Answer 1

创建一个 ItemWriteListener，注入(inject) multiResourceItemWriter bean 并将监听器绑定(bind)到您的步骤。
在 ItemWriteListener.beforeWrite() 中创建一个新的 ResourceSuffixCreator 对象，使用您将要编写的项目作为创建资源扩展(后缀)的基础。
MultiResourceItemWriter.resource 可能需要更改为 file:xml/，因为将使用自定义 ResourceSuffixCreator 附加 1.xml、2.xml 等> 为您正在编写的每个项目动态创建。

由于 commit-interval=1，此解决方案很脏并且(可能)有效；如果你改变我的答案(可能)会失败。

我希望我说清楚了，英语不是我的母语。