Spring批处理链式复合项目处理器和编写器

Question

我必须像这样配置批处理作业流。

XML文件阅读器-

我的定制处理器是这样的

public class MyCompositeProcessor implements ItemProcessor<MySource, MyCompositeResult> {

@Override
    public MyCompositeResult process(MySource item) throws Exception {
       MyResult1 result1 = myProcessor1.process(item);
       MyResult2 result2 = myProcessor2.process(result1);
        return MyCompositeResult(result1, result2);
    }
}


public class MyCompositeWriter implements ItemWriter<MyCompositeResult> {
    
    @Override
    public void write(List<? extends MyCompositeResult> items) throws Exception {
        myWriter1.write(item.getResult1());
        myWriter2.write(item.getResult2());
    }
}

这是一个好的方法吗？我看到了一些CompositeProcess、CompositeWriter的例子，但没有一个适合我的案例。

提前谢谢。

Answer 1

如果我理解正确，您的要求如下：

item reader → item processor 1  → item processor 2
                   ↓                   ↓
              item writer 1       item writer 2

复合项处理器/写入器路由在您的情况下不起作用，因为它类似于：

item reader → composite item processor    →   composite item writer
              (processor 1 → processor 2)     (writer 1 → writer 2)

这不是你想要的。您的需求是特定的，您需要一个定制的ChunkProcessor实现，特别是一个复合块处理器：

item reader → chunk processor 1  → chunk processor 2
              (item processor 1)   (item processor 2)
              (     ↓          )   (     ↓          )
              (item writer 1   )   (item writer 2   )