重复

RepeatTemplate （重复模板）

批处理是关于重复作的，无论是作为简单的优化还是作为一部分的工作。为了制定和概括重复，并提供相当于 iterator 框架中，Spring Batch 具有RepeatOperations接口。这RepeatOperationsinterface 的定义如下：spring-doc.cadn.net.cn

public interface RepeatOperations {

    RepeatStatus iterate(RepeatCallback callback) throws RepeatException;

}

回调是一个接口，如以下定义所示，允许您将一些需要重复的业务逻辑：spring-doc.cadn.net.cn

public interface RepeatCallback {

    RepeatStatus doInIteration(RepeatContext context) throws Exception;

}

重复执行回调，直到 implementation 确定 iteration 应该结束。这些接口中的返回值是一个枚举值，该值可以可以是RepeatStatus.CONTINUABLE或RepeatStatus.FINISHED.一个RepeatStatus枚举将信息传达给重复作的调用方，说明是否任何工作都留下来。一般来说，RepeatOperations应检查RepeatStatus并将其用作结束迭代。任何希望向调用方发出没有工作的信号的回调可以返回RepeatStatus.FINISHED.spring-doc.cadn.net.cn

最简单的通用实现RepeatOperations是RepeatTemplate:spring-doc.cadn.net.cn

RepeatTemplate template = new RepeatTemplate();

template.setCompletionPolicy(new SimpleCompletionPolicy(2));

template.iterate(new RepeatCallback() {

    public RepeatStatus doInIteration(RepeatContext context) {
        // Do stuff in batch...
        return RepeatStatus.CONTINUABLE;
    }

});

在前面的示例中，我们返回RepeatStatus.CONTINUABLE，以表明存在还有更多的工作要做。回调还可以返回RepeatStatus.FINISHED，以向没有工作的调用者。某些迭代可以由回调中正在完成的工作所固有的注意事项。其他无限循环（就回调而言），完成决定是委托给外部策略，如前面的示例所示。spring-doc.cadn.net.cn

RepeatContext

的 method 参数RepeatCallback是一个RepeatContext.许多回调会忽略上下文。但是，如有必要，您可以将其用作属性包来存储 transient 数据。在iteratemethod 返回 Context 已不复存在。spring-doc.cadn.net.cn

如果正在进行嵌套迭代，则RepeatContext具有父上下文。这父上下文有时可用于存储需要共享的数据调用iterate.例如，如果您想计算事件的发生次数，并在后续调用中记住它。spring-doc.cadn.net.cn

RepeatStatus （重复状态）

RepeatStatus是 Spring Batch 使用的枚举，用于指示处理是否具有完成。它有两种可能RepeatStatus值：spring-doc.cadn.net.cn

表 1.RepeatStatus 属性
值spring-doc.cadn.net.cn	描述spring-doc.cadn.net.cn
`CONTINUABLE`spring-doc.cadn.net.cn	还有更多的工作要做。spring-doc.cadn.net.cn
`FINISHED`spring-doc.cadn.net.cn	不应再发生重复。spring-doc.cadn.net.cn

您可以组合RepeatStatusvalues 替换为逻辑 AND 运算and()method 中RepeatStatus.这样做的效果是对 continuable 标志。换句话说，如果任一状态为FINISHED，则为FINISHED.spring-doc.cadn.net.cn

完成策略

在RepeatTemplate，则iteratemethod 为由CompletionPolicy，它也是RepeatContext.这RepeatTemplate负责使用当前策略创建一个RepeatContext并将其传递给RepeatCallback在迭代的每个阶段。回调完成其doInIteration这RepeatTemplate必须拨打电话到CompletionPolicy要求它更新其 state（将存储在RepeatContext).然后，它会询问策略迭代是否完成。spring-doc.cadn.net.cn

Spring Batch 提供了一些简单的通用实现CompletionPolicy.SimpleCompletionPolicy允许执行最多固定次数（使用RepeatStatus.FINISHED强制随时提前完成）。spring-doc.cadn.net.cn

对于更复杂的情况，用户可能需要实施自己的完成策略决定。例如，阻止批处理作业执行的批处理窗口一旦在线系统投入使用，将需要一个自定义策略。spring-doc.cadn.net.cn

异常处理

如果在RepeatCallback这RepeatTemplate咨询一ExceptionHandler，它可以决定是否重新引发异常。spring-doc.cadn.net.cn

下面的清单显示了ExceptionHandler接口定义：spring-doc.cadn.net.cn

public interface ExceptionHandler {

    void handleException(RepeatContext context, Throwable throwable)
        throws Throwable;

}

一个常见的用例是计算给定类型的异常数量，并在达到 limit 时。为此，Spring Batch 提供了SimpleLimitExceptionHandler并且稍微灵活一些RethrowOnThresholdExceptionHandler.这SimpleLimitExceptionHandler有限制属性和异常类型，该类型应与当前异常进行比较。都 provided type 的子类也会被计算在内。给定类型的异常是 ignored 直到达到限制，然后重新抛出它们。其他类型的异常总是被重新抛出。spring-doc.cadn.net.cn

的一个重要可选属性SimpleLimitExceptionHandler是布尔标志叫useParent.是的false默认情况下，该限制仅计入当前RepeatContext.当设置为true，该限制在嵌套迭代（例如步骤中的一组块）。spring-doc.cadn.net.cn

听众

通常，能够接收横切关注点的其他回调是很有用的在许多不同的迭代中。为此，Spring Batch 提供了RepeatListener接口。这RepeatTemplate允许用户注册RepeatListener实现，并且它们会使用RepeatContext和RepeatStatus（在迭代期间可用）。spring-doc.cadn.net.cn

这RepeatListenerinterface 的定义如下：spring-doc.cadn.net.cn

public interface RepeatListener {
    void before(RepeatContext context);
    void after(RepeatContext context, RepeatStatus result);
    void open(RepeatContext context);
    void onError(RepeatContext context, Throwable e);
    void close(RepeatContext context);
}

这open和close回调出现在整个迭代之前和之后。before,after和onError适用于个人RepeatCallback调用。spring-doc.cadn.net.cn

请注意，当有多个侦听器时，它们位于一个列表中，因此有一个次序。在这种情况下，open和before以相同的顺序调用，而after,onError和close以相反的顺序调用。spring-doc.cadn.net.cn

并行处理

的实现RepeatOperations不限于执行回调顺序。一些 implementation 能够执行其 callback 的 Alpha 函数。为此，Spring Batch 提供了TaskExecutorRepeatTemplate，它使用 SpringTaskExecutor策略来运行RepeatCallback.默认使用SynchronousTaskExecutor，该在同一线程中执行整个迭代（与正常的RepeatTemplate).spring-doc.cadn.net.cn

声明式迭代

有时，您知道每次都要重复一些业务处理它发生了。这方面的经典示例是消息管道的优化。如果一批消息频繁到达，则处理它们比处理它们更有效承担每条消息的单独交易费用。Spring Batch 提供 AOP interceptor 将方法调用包装在RepeatOperationsobject 的目的。这RepeatOperationsInterceptor执行 intercepted 方法并重复根据CompletionPolicy在提供的RepeatTemplate.spring-doc.cadn.net.cn

Javaspring-doc.cadn.net.cn
XMLspring-doc.cadn.net.cn

以下示例使用 Java 配置来对名为processMessage（有关如何配置 AOP 拦截器，请参阅 Spring 用户指南）：spring-doc.cadn.net.cn

@Bean
public MyService myService() {
	ProxyFactory factory = new ProxyFactory(RepeatOperations.class.getClassLoader());
	factory.setInterfaces(MyService.class);
	factory.setTarget(new MyService());

	MyService service = (MyService) factory.getProxy();
	JdkRegexpMethodPointcut pointcut = new JdkRegexpMethodPointcut();
	pointcut.setPatterns(".*processMessage.*");

	RepeatOperationsInterceptor interceptor = new RepeatOperationsInterceptor();

	((Advised) service).addAdvisor(new DefaultPointcutAdvisor(pointcut, interceptor));

	return service;
}

下面的示例展示了使用 Spring AOP 名称空间的声明式迭代对名为processMessage（有关如何配置 AOP 拦截器，请参阅 Spring 用户指南）：spring-doc.cadn.net.cn

<aop:config>
    <aop:pointcut id="transactional"
        expression="execution(* com..*Service.processMessage(..))" />
    <aop:advisor pointcut-ref="transactional"
        advice-ref="retryAdvice" order="-1"/>
</aop:config>

<bean id="retryAdvice" class="org.spr...RepeatOperationsInterceptor"/>

前面的示例使用默认的RepeatTemplate在拦截器内部。更改策略、侦听器和其他详细信息中，您可以注入RepeatTemplate进入拦截器。spring-doc.cadn.net.cn

如果拦截的方法返回void，则拦截器始终返回RepeatStatus.CONTINUABLE（因此，如果存在CompletionPolicy没有有限的终点）。否则，它将返回RepeatStatus.CONTINUABLE直到 intercepted 方法的返回值为null. 此时，它会返回RepeatStatus.FINISHED.因此，业务逻辑可以通过返回null或者通过引发由ExceptionHandler在提供的RepeatTemplate.spring-doc.cadn.net.cn