如何使用单个读取器配置 Spring 批处理作业，并根据返回的对象调用多个写入器

Question

下面是我目前正在使用的作业文件。

<batch:job id="job1">
    <batch:step id="step1">
        <batch:tasklet>
            <batch:chunk reader="reader" processor="processor" writer="ItemWriter" commit-interval="3">
            </batch:chunk>
        </batch:tasklet>
    </batch:step>
</batch:job>

Answer 1

忘记添加我找到的解决方案。下面的解决方案对我很有用。编译了代码，效果很好。

首先，您需要一个分类器。实现分类器接口或使用@Classifier注释Classifier（）方法。

这里我使用了注释。

public class MyClassifier 
{ 
  @Classifier public String classify(Policy pol)
  { 
    return pol.getPolCode;// returns "01", "02" 
  } 
}

添加分类器 Bean

<bean id="myClassifier" class="org.springframework.batch.classify.BackToBackPatternClassifier">
   <property name="routerDelegate"> 
     <bean class="MyClassifier" /> 
   </property> 
   <property name="matcherMap"> 
     <map> 
       <entry key="01" value-ref="pol01ItemWriter" /> 
       <entry key="02" value-ref="pol02ItemWriter" />
     </map>
   </property>
</bean>

添加您的作家豆，如下所示

<bean id="ItemWriter" class="org.springframework.batch.item.support.ClassifierCompositeItemWriter">
   <property name="myClassifier" ref="myClassifier" /> 
</bean>

上面的代码可能会抛出WriterNotOpenException。为此，您需要将 batch：stream 添加到该步骤中。

<batch:step id="step1">
  <batch:tasklet> 
    <batch:chunk reader="reader" processor="processor" writer="ItemWriter" commit-interval="3">
      <batch:streams> 
        <batch:stream ref="pol01ItemWriter"/>
        <batch:stream ref="pol02ItemWriter"/>
      </batch:streams>
    </batch:chunk>
  </batch:tasklet>
</batch:step>

Answer 2

正如Luca的评论中所说，您可以使用ClassifierCompositeItemWriter，它需要org.springframework.classify.Classifier。

后者为数不多的实现之一是org.springframework.classify.BackToBackPatternClassifier，它又需要一个路由器Delegate和一个匹配器Map。

routerServer ate是一个bean，它将具有一个用@分类器注释的方法。此方法将获取一个Object并返回一个String。然后，此字符串将与您在模块上下文中声明的值匹配，并相应地调用ItemWriter。

这里有一个例子：

<bean class="org.springframework.batch.item.support.ClassifierCompositeItemWriter">
    <property name="classifier">
        <bean class="org.springframework.classify.BackToBackPatternClassifier">
            <property name="routerDelegate">
                <bean class="xx.xx.xx.YourClassifier"></bean>
            </property>
            <property name="matcherMap">
                <map>
                    <entry key="value1">
                        <bean class="xx.xx.xx.YourItemWriter1></bean>
                    </entry>
                    <entry key="value2">
                        <bean class="xx.xx.xx.YourItemWriter2></bean>
                    </entry>
                </map>
            </property>
        </bean>
    </property>
</bean>

下面是一个分类器的样子(这是一个通用分类器，使用Reflect API调用一个方法作为对象的参数传递) :

public class GenericClassifier<T> {

    private String methodName;

    @Classifier
    public String classify(T classifiable) {

        Method method;
        String value = "";

        try {
            // Get the method with Reflect
            method = classifiable.getClass().getMethod(methodName);

            // Call the method with Reflect
            value= (String) method.invoke(classifiable);
        } catch (Exception e) {
            // Error management
        }

        return value;
    }

    public void setMethodName(String methodName) {
        this.methodName = methodName;
    }
}

此分类器的用法如下，其中< code>YourMethod是要分类的对象的类的公共方法(不带括号) :

<bean class="xx.xx.xx.GenericClassifier">
    <property name="methodName" value="YourMethod"></property>
</bean>

然后将分类器返回的valueString与matcherMap的条目的key匹配。