使用步骤决定者和块时的春季批处理

debugcn 发表于 Dev

尼罗河

我开始使用Spring Batch，并且对使用步骤，决策程序和块时有一个疑问。

给出以下输入：

<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>

对于<UserAuthorization>文件中的每个，我都会根据制定不同的业务规则，以在对数据库执行查询之前进行验证<Action>。（示例：对于ADD，请验证UserName在数据库中是否唯一，并且仅由字母组成；对于DELETE，请验证表中是否存在ID）

然后，该<Action>值将确定我是否需要在数据库中插入，更新或删除一个值。（操作可能具有其他值，例如UPDATE_RIGHTS或RESET_PASSWORD）

最好的办法是什么？

我是否定义这样的工作：

<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文件并一次返回一个<UserAuthorization>。
itemProcessor将充满，if以根据其<Action>值验证当前项目的业务规则
itemWriter将把该项目保留在数据库中。如果要在执行查询之前执行更多操作，是否还需要在此处添加逻辑？

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

那是正确的做法吗？

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

卢卡·巴索·里奇（Luca Basso Ricci）

将SB用于此类问题是正确的决定，并且您只需要一个步骤（对于本用例）就可以了。

第一个解决方案：
读取器很简单（使用StaxEventItemReader），而处理器则没有用（除非您需要执行一些业务检查）。
比较有趣的一点是作者，因为您必须：

为每个AddItemWriter, UpdateItemWriter, DeleteItemWriter执行实际写入逻辑的操作（例如）定义一个自定义写入器
创建一个主编写器（由专门的编写器组成），在其中根据<ACTION>标记值将写操作分派给正确的编写器。

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

标准 StaxEventItemReader
自定义ItemProcessor转换<UserAuthorization>为自定义Action类封装操作（AddUserAuth, DeleteUserAuth, UpdateUserAuth例如）
为每个AddItemWriter, UpdateItemWriter, DeleteItemWriter执行实际写入逻辑的操作（例如）定义一个自定义写入器
作为主要作者使用ClassifierCompositeItemWriter基于SubclassClassifier; 该分类器使用Action从处理器创建的自定义类将其分发给正确的作者