复用现有服务

批处理系统通常与其他应用程序风格结合使用。最常见的是在线系统，但它也可以通过迁移每种应用风格所需的大量数据来支持集成，甚至支持厚客户端应用程序。因此，许多用户希望在他们的批处理作业中重用现有的 DAO 或其他服务，这是很常见的。Spring 容器本身通过允许注入任何必要的类，使这一过程变得相当简单。然而，在某些情况下，现有服务可能需要充当 ItemReader 或 ItemWriter， either 是为了满足另一个 Spring Batch 类的依赖关系，还是因为它确实是一个步骤的主要 ItemReader。为每个需要包装的服务编写一个适配器类是相当简单的，但由于这是一个非常常见的需求，Spring Batch 提供了相应的实现： ItemReaderAdapter 和 ItemWriterAdapter。这两个类都通过调用委托模式实现了标准的 Spring 方法，并且设置起来相当简单。spring-doc.cadn.net.cn

以下 Java 示例使用了 ItemReaderAdapter：spring-doc.cadn.net.cn

Java 配置
@Bean
public ItemReaderAdapter itemReader() {
	ItemReaderAdapter reader = new ItemReaderAdapter();

	reader.setTargetObject(fooService());
	reader.setTargetMethod("generateFoo");

	return reader;
}

@Bean
public FooService fooService() {
	return new FooService();
}

以下 XML 示例使用了 ItemReaderAdapter：spring-doc.cadn.net.cn

XML 配置
<bean id="itemReader" class="org.springframework.batch.infrastructure.item.adapter.ItemReaderAdapter">
    <property name="targetObject" ref="fooService" />
    <property name="targetMethod" value="generateFoo" />
</bean>

<bean id="fooService" class="org.springframework.batch.infrastructure.item.sample.FooService" />

需要注意的一点是，targetMethod 的契约必须与 read 的契约相同：当资源耗尽时，它返回 null；否则，它返回一个 Object。任何其他行为都会导致框架无法判断处理何时应结束，具体取决于 ItemWriter 的实现，可能会引发无限循环或错误的失败。spring-doc.cadn.net.cn

以下 Java 示例使用了 ItemWriterAdapter：spring-doc.cadn.net.cn

Java 配置
@Bean
public ItemWriterAdapter itemWriter() {
	ItemWriterAdapter writer = new ItemWriterAdapter();

	writer.setTargetObject(fooService());
	writer.setTargetMethod("processFoo");

	return writer;
}

@Bean
public FooService fooService() {
	return new FooService();
}

以下 XML 示例使用了 ItemWriterAdapter：spring-doc.cadn.net.cn

XML 配置
<bean id="itemWriter" class="org.springframework.batch.infrastructure.item.adapter.ItemWriterAdapter">
    <property name="targetObject" ref="fooService" />
    <property name="targetMethod" value="processFoo" />
</bean>

<bean id="fooService" class="org.springframework.batch.infrastructure.item.sample.FooService" />