6.10 重用已存在的 Service

批处理系统通常是与其他应用程序相结合的方式使用。最常见的是与一个在线应用系统结合, 但也支持与瘦客户端集成,通过移动每个程序所使用的批量数据。由于这些原因,所以很多用户想要在批处理作业中重用现有的DAO或其他服务。Spring容器通过注入一些必要的类就可以实现这些重用。但可能需要现有的服务作为 ItemReader 或者 ItemWriter, 也可以适配另一个Spring Batch类, 或其本身就是一个 step 主要的ItemReader。为每个需要包装的服务编写一个适配器类是很简单的, 而因为这是很普遍的需求,所以 Spring Batch 提供了实现: ItemReaderAdapter 和 ItemWriterAdapter。两个类都实现了标准的Spring方法委托模式调用，设置也相当简单。下面是一个reader的示例:

  1. <bean id="itemReader" class="org.springframework.batch.item.adapter.ItemReaderAdapter">
  2.     <property name="targetObject" ref="fooService" />
  3.     <property name="targetMethod" value="generateFoo" />
  4. </bean>
  6. <bean id="fooService" class="org.springframework.batch.item.sample.FooService" />

特别需要注意的是, targetMethod 必须和 read 方法行为对等: 如果不存在则返回null, 否则返回一个 Object。 其他的值会使框架不知道何时该结束处理, 或者引起无限循环或不正确的失败,这取决于 ItemWriter 的实现。 ItemWriter 的实现同样简单:

  1. <bean id="itemWriter" class="org.springframework.batch.item.adapter.ItemWriterAdapter">
  2.     <property name="targetObject" ref="fooService" />
  3.     <property name="targetMethod" value="processFoo" />
  4. </bean>
  6. <bean id="fooService" class="org.springframework.batch.item.sample.FooService" />