在实际应用中，我们的 Job 可能必须要包含多个 Step，为了提高性能，我们可能需要考虑 Job 的并发问题。Spring Batch 在这些方面又提供了哪些好的特性呢？让我们继续。
Step Flow
通过前文我们已经知道，Step 是一个独立的、顺序的处理步骤，包含完整的输入、处理以及输出。但是在">企业应用中，我们面对的更多情况是多个步骤按照一定的顺序进行处理。因此如何维护步骤之间的执行顺序是我们需要考虑的。Spring Batch 提供了 Step Flow 来解决这个问题。
示例改进
让我们回到用户缴费通知的 Job。客户提出了进一步的需求：计费、扣费、缴费通知要确保顺序执行。首先，为每个用户生成账单，然后从用户余额上进行扣除，对于余额不足的用户，发送缴费通知。下面看一下如何使用 Step Flow 实现该需求。
在讲解 Step Flow 之前，我们先对第 1 部分的示例进行改进，将其由文件操作迁移到数据库上，这样便于我们后续的讲解。数据库初始化脚本见 init_db_mysql.sql（位于示例代码包 batch_sample 根目录下），具体配置如清单 1 所示：
清单 1. billing_job.xml
<beans:bean id="job
Repository" class="org.springframework.batch.core.repository.support.JobRepository
FactoryBean"> <beans:property name="dataSource" ref="dataSource" /> <beans:property name="transactionManager" ref="transactionManager" /></beans:bean><beans:bean id="
userDbReader" class="org.springframework.batch.item.database.JdbcPagingItemReader"> <beans:property name="dataSource" ref="dataSource" /> <beans:property name="rowMapper" ref="userDbMapper" /> <beans:property name="queryProvider" ref="userQueryProvider" /></beans:bean><beans:bean id="userDbMapper" class="org.springframework.batch.sample.UserDbMapper" /><beans:bean id="userQueryProvider" class="org.springframework.batch.item.database.support.MySqlPagingQueryProvider"> <beans:property name="selectClause" value="u.id,u.name,u.age,u.balance" /> <beans:property name="fromClause" value="users u" /> <beans:property name="sortKey" value="u.id" /></beans:bean><beans:bean id="messageDbWriter" class="org.springframework.batch.item.database.JdbcBatchItemWriter"> <beans:property name="dataSource" ref="dataSource" /> <beans:property name="sql" value="insert into messages(id,user_id,content) values(:id,:user.id,:content)" /> <beans:property name="itemSqlParameterSourceProvider" ref="itemSqlParameterSourceProvider" /></beans:bean><beans:bean id="itemSqlParameterSourceProvider"class="org.springframework.batch.item.database.BeanPropertyItemSqlParameterSourceProvider" />
我们分别使用 Spring Batch 提供的 JdbcPagingItemReader 和 JdbcBatchItemWriter 进行读写。同时，我将 jobRepository 修改为 JobRepositoryFactoryBean，因此，运行示例前，您还需要执行 Spring Batch 提供的 schema-mysql.sql（位于 core 包 org\springframework\batch\core 目录下）。相关内容将在第 3 部分详细讲解，此处不再赘述。
第一个流程
在配置 Step 时，我们可以指定其 next 属性，该属性指向另一个 Step。通过配置 Step 的 next 属性，我们便可以轻易实现上述流程。具体如清单 2 所示
清单 2. billing_job.xml
<job id="billingJob" restartable="true"> <step id="billingStep" next="payStep"> <tasklet> <chunk reader="userDbReader" processor="billingProcessor" writer="billDbWriter" commit-interval="5" chunk-completion-policy=""> </chunk> </tasklet> </step> <step id="payStep" next="messageStep"> <tasklet> <chunk reader="billDbReader" processor="payProcessor" writer="payDbWriter" commit-interval="5" chunk-completion-policy="" skip-limit="100" ><skippable-exception-classes> <include class="org.springframework.batch.sample.MoneyNotEnoughException" /> </skippable-exception-classes> </chunk> </tasklet> </step> <step id="messageStep"> <tasklet> <chunk reader="billArrearsDbReader" processor="messageProcessor" writer="messageDbWriter" commit-interval="5" chunk-completion-policy=""> </chunk> </tasklet> </step></job>
我们将 billStep 的 next 设置为 payStep，将 payStep 的 next 设置为 messageStep，同时分别指定了读、处理、写接口。Spring Batch 在运行 billingJob 时，首先执行 billingStep，查找用户信息生成账单费用，然后执行 payStep，查找账单信息生成扣费记录，如果用户余额不足则跳过。最后，查找欠费账单，生成缴费通知。只有当上一步执行成功后，才会执行下一步。