文档章节

Spring Batch

halbert918
 halbert918
发布于 2016/08/24 16:24
字数 455
阅读 173
收藏 0

【推荐】2019 Java 开发者跳槽指南.pdf(吐血整理) >>>

Spring Batch是由spring提供的批处理组件,官方文档见http://projects.spring.io/spring-batch/

batch主要的组成如下图:

    

    JobLauncher是用于加载执行job以及传递JobParameters参数等,Job的接口每个任务job包括多个step,每个step之间又包括ItemReader(读取数据)、ItemProcessor(处理每条数据相关逻辑)、ItemWriter(批量写入数据);各个节点通过JobRepository协调事务、执行状态等。

    每个step的执行流程如下图:

    

    上图为同步执行流程,batch还提供异步方式,详细可见官方文档。

    简单的实现:

    1、引入相关依赖

<dependencies>
    <dependency>
        <groupId>org.springframework.batch</groupId>
        <artifactId>spring-batch-core</artifactId>
        <version>3.0.7.RELEASE</version>
    </dependency>
</dependencies>

    2、配置job相关信息

<bean id="jobLauncher" class="org.springframework.batch.core.launch.support.SimpleJobLauncher">
   <property name="jobRepository" ref="jobRepository"/>
</bean>

<!-- 用于测试,job的相关状态都保存在内存中 -->
<bean id="jobRepository" class="org.springframework.batch.core.repository.support.MapJobRepositoryFactoryBean">
</bean>

<bean id="transactionManager"
     class="org.springframework.batch.support.transaction.ResourcelessTransactionManager"/>
<bean:import resource="spring-application.xml"/>

<job id="helloJob">
   <step id="first_step" next="end_step">
      <tasklet ref="firstTasklet" transaction-manager="transactionManager" />
   </step>
   <step id="end_step">
      <tasklet ref="endTasklet" transaction-manager="transactionManager" />
   </step>
</job>

<bean:bean id="firstTasklet" class="com.test.batch.simple.tasklet.FirstTasklet">
   <bean:property name="message" value="hello spring batch" />
</bean:bean>

<bean:bean id="endTasklet" class="com.test.batch.simple.tasklet.EndTasklet">
   <bean:property name="message" value="bye spring batch" />
</bean:bean>

    3、实现类

    

public class FirstTasklet implements Tasklet {

    private String message;

    public void setMessage(String message) {
        this.message = message;
    }

    @Override
    public RepeatStatus execute(StepContribution arg0, ChunkContext arg1)
            throws Exception {
        System.out.println(message + ",first tasklet");
        return RepeatStatus.FINISHED;
    }
}
public class EndTasklet implements Tasklet {

    private String message;

    public void setMessage(String message) {
        this.message = message;
    }

    @Override
    public RepeatStatus execute(StepContribution arg0, ChunkContext arg1)
            throws Exception {
        System.out.println(message + ",end tasklet");
        return RepeatStatus.FINISHED;
    }
}

    4、启动job

public class HelloJobLaunch {
    public static void main(String[] args) {
        ApplicationContext context = new ClassPathXmlApplicationContext("spring-batch-simple.xml");
        JobLauncher launcher = (JobLauncher) context.getBean("jobLauncher");
        Job job = (Job) context.getBean("helloJob");
        try {
            // 运行Job
            JobExecution result = launcher.run(job, new JobParametersBuilder()
                    .toJobParameters());
            // 处理结束
            System.out.println(result.getExitStatus().toString());
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

}

    其中Tasklet是一种特殊的step,区别于reader、processor、writer所组成的step

© 著作权归作者所有

halbert918
粉丝 2
博文 18
码字总数 14700
作品 0
九龙坡
程序员
私信 提问

暂无文章

OSChina 周四乱弹 —— 浙江台的电话号码倒是记得挺牢

Osc乱弹歌单(2019)请戳(这里) 【今日歌曲】 @巴拉迪维 :《Out On The Streets》 一直不理解北欧人对重金属和死亡摇滚的热情,听完这首歌好像理解了。#今日歌曲推荐# 《Out On The Stre...

小小编辑
今天
5
0
Leetcode PHP题解--D121 21. Merge Two Sorted Lists

D121 21. Merge Two Sorted Lists 题目链接 21. Merge Two Sorted Lists 题目分析 合并两个有序链表。 思路 逐个遍历两个链表,把小的数字塞入数组里。之后再拼起来。 最终代码 <?php/** *...

skys215
今天
5
0
mars-config 动态配置管理

mars-config 码云地址:https://gitee.com/fashionbrot/mars-config 介绍 spring mvc 、springboot 动态配置系统。http 轮训方式 更新 动态配置 软件架构 软件架构说明 后端使用技术 :sprin...

fashionbrot
今天
14
0
女朋友玩吃鸡手游被开挂老哥骗炮,我见义勇为将骗子绳之以法

大家好,我是乔哥。 晚上10点以后下班后我回到自如出租房里面,开始处理公众号粉丝发来的消息,一条一条处理,突然看到了这么几条消息,吸引了我的眼球: 然后我就和这位女粉丝小红(化名)聊...

gzc426
今天
9
0
两款软件

fadetop保护眼睛软件 Snipaste截图软件

伟大源于勇敢的开始
今天
7
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部