Spring Batch之配置Tasklet(十四)

一、重启Step

        Spring Batch框架支持状态为非“COMPELETED”的Job实例重新启动，Job实例重启的时候，会从当前失败的Step重新开始执行，同时可以通过start-limit属性控制任务启动的次数和allow-start-if-complete属性来决定已完成的任务是否可以重新启动。

1.start-limit属性控制启动次数限制

        默认情况下，作业实例可以无限次地重复启动。在有些场景下需要限制作业实例的启动次数。

<batch:step id="startLimitStep">
    <batch:tasklet start-limit="1">
        <batch:chunk reader="reader" processor="processor" writer="writer"/>
    </batch:tasklet>
</batch:step>      

定义了startLimitStep只能启动1次，第二次启动的时候就会抛出异常。start-limit默认值是Integer.MAX_VALUE，表示任务可以无限次启动。

2.allow-start-if-complete属性控制完成的任务是否可以重启

        默认情况下，Job Instance重新启动的时候，已经完成的任务不会再次被执行。仅在特殊的情景下，已经完成的Step在任务重启的时候需要再次执行，这可以通过allow-start-if-complete来设置。

<batch:step id="startLimitStep">
    <batch:tasklet allow-start-if-complete="true">
        <batch:chunk reader="reader" processor="processor" writer="writer"/>
    </batch:tasklet>
</batch:step>      

通过设置属性allow-start-if-complete为true，表示已经完成的Step可以被再次启动。

二、事务

1.事务管理器

为了使用事务管理器，需要在配置文件中声明标准Spring方式的事务管理器。

（1）Job执行期的元数据，存放在内存中的事务管理器配置方式

<batch:step id="startLimitStep">
    <batch:tasklet transaction-manager="transactionManager">
        <batch:chunk reader="reader" processor="processor" writer="writer"/>
    </batch:tasklet>
</batch:step>      

<!--定义事务管理器，用于Spring Batch框架中对数据操作提供事务能力-->
<bean id="transactionManager" class="org.springframework.batch.support.transaction.ResourcelessTransactionManager"/>      

（2）Job执行期的元数据，存放在数据库中的事务管理器配置方式

<batch:step id="startLimitStep">
    <batch:tasklet transaction-manager="transactionManager">
        <batch:chunk reader="reader" processor="processor" writer="writer"/>
    </batch:tasklet>
</batch:step>      

<!--事务管理器-->
<bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
    <property name="dataSource" ref="dataSource"/>
</bean>

<!--数据源-->
<bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">
    <property name="driverClassName">
        <value>com.mysql.jdbc.Driver</value>
    </property>
    <property name="url">
        <value>jdbc:mysql://127.0.0.1:3306/spring_batch_demo2</value>
    </property>
    <property name="username" value="root"/>
    <property name="password" value="12345"/>
</bean>
      

其中，dataSource指定使用的数据源，在对此数据源的任何操作都将会得到事务的保障。

关于Job执行期的元数据存储方式，可以回看我的另一篇文章：

Spring Batch之配置Job Repository的两种方式(二)_人……杰的博客-CSDN博客

2.事务回滚

        在业务执行过程中，包括读、写、处理数据如果发生了异常会导致事务回滚，Spring Batch框架提供了发生特定异常不触发事务回滚的能力，可以在tasklet中通过子元素no-rollback-exception-classes来定义特定异常不回滚。

<batch:step id="startLimitStep">
    <batch:tasklet transaction-manager="transactionManager">
        <batch:chunk reader="reader" processor="processor" writer="writer"/>
        <batch:no-rollback-exception-classes>
            <batch:include                      class="org.springframework.batch.item.validator.ValidationException"/>
        </batch:no-rollback-exception-classes>
    </batch:tasklet>
</batch:step>      

配置后，如果发生ValidationException异常或者其子类异常时，不会触发事务的回滚操作。