使用步骤决定器和块时的Spring批处理

Question

我开始使用Spring批处理，我有一个关于何时使用步骤、决策器和块的问题。

考虑到以下输入：

<UserAuthorizationEvent>
    <UserAuthorization>
        <Action>ADD</Action>
        <UserName>Name1</UserName>
        <!-- more properties here -->
    </UserAuthorization>
    <UserAuthorization>
        <Action>UPDATE</Action>
        <UserId>456</UserId>
        <UserName>NewName2</UserName>
        <!-- more properties here -->
    </UserAuthorization>
    <UserAuthorization>
        <UserId>789</UserId>
        <Action>DELETE</Action>
    </UserAuthorization>
    <!-- 1000 or more UserAuthorization here -->
</UserAuthorizationEvent>

对于每个

然后是<代码>

最好的做法是什么？

我是否这样定义一份工作：

<job id="myJob" xmlns="http://www.springframework.org/schema/batch">
    <step id="step1">
        <tasklet>
            <chunk reader="itemReader" processor="itemProcessor" writer="itemWriter" commit-interval="2" />
        </tasklet>
    </step>
</job>

• itemReader将读取xml文件并返回

这样做，我担心我没有正确使用Spring批处理。

这样做对吗？

我可以使用几个步骤和决定器来实现批处理的所有逻辑吗？你有一些例子吗？




Answer 1

Spring的一批看起来有点过头了。但如果使用，我预计会出现以下分工：

• itemReader从输入源读取项，并返回下一个要处理的项。这个类必须是线程安全的。
• 项目处理器只返回输入项。如果有关于操作的业务规则，它们就属于这里。这个类不需要是线程安全的，因为它是在自己的线程中调用的。这个类不应该写入数据库。
• itemWriter执行插入/更新/删除操作，并在块大小操作后提交。

另外，我怀疑ADD操作不会有userId。这通常是在插入记录时由数据库分配的。

Answer 2

使用SB解决这类问题是正确的决定，你只需要一个步骤（对于这个用例）。

第一个解决方案：
读卡器很简单（使用StateVentitemReader），处理器也没用（除非你需要执行一些业务检查）
更有趣的是作者，因为你必须：

1. 为执行实际写入逻辑的每个操作（例如addItemWriter， UpdateItemWriter， DeleteItemWriter）定义一个自定义写入器
2. 创建一个主写入器（由专门的写入器组成），您可以根据将写入发送到正确的写入器

第二种解决方案（可能更“复杂”）：

1. 标准statxeventitemreader

这个解决方案比解决方案一更容易扩展，因为你只需要为一个（新的）动作创建自定义的动作类，以及合适的编写器，编写只是一个配置问题。