Spring批处理将文件写入多个目标

Question

我目前正在编写spring batch，在这里我读取一个XML数据，对其进行处理，然后将处理结果作为< code>map传递

 <Company att1="value">
      <employees>
        <employee></employee>
         <employee></employee>
         <employee></employee>
      <employees>
    </Company>

生成用于编组和解组的JAXB xjc类。JAXB生成的类如下所示。

@XmlRootElement(name="Company")
public class Company{
@XmlElements(name="employees" required="true")
}

JAXB员工类

@XmlRootElement(name="employees")
public class Employees
{
@XmlElement(name="Employee")
protected List<Employees> employee;
}

Spring XML配置文件

<batch:job id="reportJob">
<batch:step id="step1">
<batch:tasklet>
<batch:chunk reader="xmlItemReader" 
 writer="compositeItemWriter" processor="filterReportProcessor"
 commit-interval="2">
 </batch:chunk>
 </batch:tasklet>
</batch:step>
</batch:job>



<!-- Filtering process -->
<bean id="filterReportProcessor" class="com.examples.FilterReportProcessor" />

<bean id="xmlItemReader" 
    class="org.springframework.batch.item.xml.StaxEventItemReader">
<property name="fragmentRootElementName" value="record" />
<property name="resource" value="classpath:xml/company.xml" />
<property name="unmarshaller" ref="reportUnmarshaller" />
</bean>

<!-- Read and map values to object, via jaxb2 -->
<bean id="reportUnmarshaller" class="org.springframework.oxm.jaxb.Jaxb2Marshaller">
<property name="classesToBeBound">
<list>
    <value>com.examples.Company</value>
    <value>com.examples.Employees</value>
    <value>com.examples.Employee</value>
</list>
</property>
</bean>

<bean id="compositeItemWriter" class="org.springframework.batch.item.support.CompositeItemWriter">
<property name="delegates"/>
    <list>
       <ref bean="testXMlWriter">
  </list>
</bean>
<bean id="testXMlWriter" class="com.test.example.TestXMLWriter">

处理器和写入器：

    public class FilterReportProcessor
    implement ItemProcessor<Employee,Map<String,Object>>{
    public Map<String,Object> process(Employee emplpyee) throws Exception{
    Map<String,Object> evnt = Mapper.crateMapping(emplpyee);
    return event; 
    }

    public class TestXMLWriter implemtes ItemWriter(Map<String,Object>){
    write(List <? extends Map<String, object>> lst){

    Employee e1 = new Employee();
    e1.setxxx(mapelementdata.item());

    Employees employs = new Employees();
    employs.add(e1);
    Comapany c1 = new Company();
    c1.add(employs);

   Marshaller m = context.createMarshaller();
   m.marshal(c1, resource.getFile());
  }

问题：

XML文件对于每个固定的提交间隔都是重写的，很明显，XML文件是在每个提交级别之后创建的。但我必须附加所有




Answer 1

我认为您想要写入同一个文件，在这种情况下，我建议使用FlatFileItemWriter而不是您拥有的自定义编写器，并将属性appendAllowed设置为true，这将追加到文件(如果它已经存在)。将处理逻辑移至您的处理器，并使用lineAggregator将许多行批处理在一起进行写入。

如果您不想这样做，那么您必须求助于稍微复杂一点的编码，在WriterListener的beforeWrite方法中打开文件，读取内容，然后将其存储在上下文中，然后将其推送到Write方法。