3

我正在使用 Spring 批处理设计批处理应用程序，其中具有以下架构（层）：

  • 我放置所有spring批处理代码（读取文件，处理和写入）的顶级模块。这个顶级模块特定于文件的某种格式。所以，我将来可能会有一个新的并行模块，能够读取/处理/写入新格式。与格式无关，文件的每一行对应于要执行的特定操作。例如，每一行可以表示“将行项目 X 添加到订单 Y”的操作。因此，对于每一行，在完成读取和处理后，我使用一个自定义的 ItemWriter 来调用紧接其下层的所需操作。
  • 实现不同批处理操作的业务逻辑层。这些操作中的每一个都是使用域层对象实现的。例如，“添加订单项；X 到订单 Y”操作将通过使用 OrderRepository 检索订单然后调用订单的 addLineItem 方法来实现。
  • 我拥有所有域对象的域层。按照前面的示例，我有 Order 和 LineItem 实体。

我的问题是：

  • 是否有最佳实践（可能是特定的设计模式）用于顶级模块和业务逻辑层之间的接口？
  • 假设每个文件只包含一个订单的行。编写每一行的幼稚方法是每行调用一个批处理操作。在这种情况下，对于每一行，都会调用 OrderRepository 以检索订单，然后保存订单。我正在考虑另一种按块编写行的方法（就像我们使用 Spring 批处理一样）。写操作采用的参数类型为 List。按照第二种方法，我需要向业务操作传递将块添加到相关订单所需的数据。使用哪种形式在顶层模块和业务逻辑层之间传递信息？

谢谢

4

1 回答 1

4

是否有最佳实践（可能是特定的设计模式）用于顶级模块和业务逻辑层之间的接口？

afaik 没有真正的最佳实践，这与已知的最佳实践不同，但批次通常需要解决性能要求/约束​​，甚至更经常产生性能问题，所以我的最佳实践是：

  • 考虑数据和数据流
  • 多少数据？
  • 瓶颈是什么？（处理与写作，通常是写作部分）

给你一些关于writer和业务层的接口的启发

  1. 使用ItemWriterAdapter，它可以使用 businessLayer.addOrderItem 方法
  2. 编写自己的包装器
  3. 将业务层移入编写器，很少真正需要重用批量优化的业务层

我会选择选项 2，因为在批处理上下文中我想使用列表和批处理 SQL

像往常一样，这取决于您的具体要求:-)

ItemWriter 包装器示例

public class SimpleItemWriter implements ItemWriter<SimpleItem> {

    @Override
    public void write(List<? extends SimpleItem> items) throws Exception {        
        // do something, e.g. delegate to another spring bean
    }
}

ItemWriterAdapter 配置示例

<bean id="sample-item-writer-adapter" class="org.springframework.batch.item.adapter.ItemWriterAdapter">
    <property name="targetObject" ref="businessLayerBean" />
            <property name="targetMethod" value="doSomething"
</bean>

<step id="splitFilesStep">
     <tasklet>
         <chunk 
             reader="itemReader" 
             writer="sample-item-writer-adapter" 
             commit-interval="5">
         </chunk>
     </tasklet>
 </step>
于 2012-04-25T08:21:44.457 回答