详解spring batch的使用和定时器Quart的使用

2023-09-26 23:40:06 133

springBatch是一个基于Spring的企业级批处理框架，它通过配合定时器Quartz来轻易实现大批量的数据读取或插入，并且全程自动化，无需人员管理。

在使用springbatch之前，得对springbatch的流程有一个基本了解

每个batch它都包含了一个job，而一个job中却有可能包含多个step，整个batch中干活的是step，batch主要是用来对数据的操作，所以step就有三个操作数据的东西，一个是ItemReader用来读取数据的，一个是ItemProcessor用来处理数据的，一个是ItemWriter用来写数据（可以是文件也可以是插入sql语句），JobLauncher用来启动Job，JobRepository是上述处理提供的一种持久化机制，它为JobLauncher，Job，和Step实例提供CRUD操作。

pom.xml 三个batch的jar包


org.springframework
spring-batch-core
2.1.8.RELEASE



org.springframework
spring-batch-infrastructure
2.1.8.RELEASE



org.springframework
spring-batch-test
2.1.8.RELEASE

batch.xml

读取数据 teacherInterviewMapper

packagecom.yc.batch;

importjava.sql.ResultSet;
importjava.sql.SQLException;
importorg.springframework.jdbc.core.RowMapper;
importorg.springframework.stereotype.Component;
importcom.yc.vo.TeacherInterviewdetail;
importcom.yc.vo.TeacherWorkdetail;
importcom.yc.vo.Workdetail;
@Component("teacherInterviewMapper")
publicclassTeacherInterviewMapperimplementsRowMapper{
@Override
publicObjectmapRow(ResultSetrs,introwNum)throwsSQLException{

TeacherInterviewdetailTId=newTeacherInterviewdetail();
TId.setTeacherName(rs.getString("teacherName"));
TId.setNum(rs.getInt("num"));
returnTId;
}
}

处理数据 teacherInterviewProcessor，这个处理数据方法，一般都是在这里在这里进行一些数据的加工，比如有些数据没有读到，你也可以在这个方法和后面那个写入数据的类里面写，所以就导致了这个类里面你可以什么都不敢，直接把数据抛到后面去，让后面的写数据类来处理；我这里就是处理数据的这个类什么都没写，但是最好还是按它的规则来！

packagecom.yc.batch;

importorg.hibernate.engine.transaction.jta.platform.internal.SynchronizationRegistryBasedSynchronizationStrategy;
importorg.springframework.batch.item.ItemProcessor;
importorg.springframework.stereotype.Component;
importorg.springframework.stereotype.Service;

importcom.yc.vo.TeacherInterviewdetail;
importcom.yc.vo.TeacherWorkdetail;
importcom.yc.vo.Workdetail;


//业务层
@Component("teacherInterviewProcessor")
publicclassTeacherInterviewProcessorimplementsItemProcessor{

@Override
publicTeacherInterviewdetailprocess(TeacherInterviewdetailteacherInterviewdetail)throwsException{

returnteacherInterviewdetail;
}
}

写数据teacherInterviewItemWriter这个类里面主要是把数据写进一个文件里，同时我这个类里面还有一些数据处理

packagecom.yc.batch;

importjava.io.InputStream;

importjava.text.NumberFormat;
importjava.util.ArrayList;
importjava.util.List;
importjava.util.Properties;
importjavax.annotation.Resource;
importorg.springframework.batch.item.ItemWriter;
importorg.springframework.stereotype.Component;
importorg.springframework.stereotype.Service;
importcom.yc.biz.ExamineeClassBiz;
importcom.yc.biz.WorkBiz;
importcom.yc.utils.CsvUtils;
importcom.yc.vo.TeacherInterviewdetail;
importcom.yc.vo.TeacherWorkdetail;
importcom.yc.vo.Workdetail;
importnet.sf.ehcache.util.PropertyUtil;
//写
@Component("teacherInterviewItemWriter")
publicclassTeacherInterviewItemWriterimplementsItemWriter{

@Override
publicvoidwrite(ListteacherInterviewdetails)throwsException{
Propertiesprops=newProperties();
InputStreamin=PropertyUtil.class.getClassLoader().getResourceAsStream("connectionConfig.properties");
props.load(in);
Stringtime=props.getProperty("detail_time");
CsvUtilscu=newCsvUtils();
List

详解spring batch的使用和定时器Quart的使用

热门推荐

随机推荐