Go语言视频零基础入门到精通

admin

quartz负责定时，spring batch负责批量，MyBatis负责持久化数据库，具体每个框架的介绍请参考其它文章，本节主要做spring boot + quartz + spring batch + mybatis的整合。
案例：指定距当前时间5s后，每隔3s时间执行一次批处理任务，批处理任务是读取数据库表记录并打印出来。
数据库采用DB2数据库，库表为users，记录为：

一、建立一个spring boot工程，并在pom.xml中引入依赖jar包

1. [code]<?xml version="1.0" encoding="UTF-8"?>
2. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
3.     <modelVersion>4.0.0</modelVersion>
5.     <groupId>com.lzj</groupId>
6.     <artifactId>demo</artifactId>
7.     <version>0.0.1-SNAPSHOT</version>
8.     <packaging>jar</packaging>
10.     <name>demo</name>
11.     <description>Demo project for Spring Boot</description>
13.     <parent>
14.         <groupId>org.springframework.boot</groupId>
15.         <artifactId>spring-boot-starter-parent</artifactId>
16.         <version>1.5.10.RELEASE</version>
17.         <relativePath /> <!-- lookup parent from repository -->
18.     </parent>
20.     <properties>
21.         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
22.         <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
23.         <java.version>1.8</java.version>
24.     </properties>
26.     <dependencies>
27.         <dependency>
28.             <groupId>org.springframework</groupId>
29.             <artifactId>spring-context-support</artifactId>
30.         </dependency>
31.         <dependency>
32.             <groupId>org.springframework.boot</groupId>
33.             <artifactId>spring-boot-starter-batch</artifactId>
34.         </dependency>
35.         <dependency>
36.             <groupId>org.springframework</groupId>
37.             <artifactId>spring-oxm</artifactId>
38.         </dependency>
39.         <dependency>
40.             <groupId>org.projectlombok</groupId>
41.             <artifactId>lombok</artifactId>
42.         </dependency>
43.         <!-- <dependency> <groupId>com.h2database</groupId> <artifactId>h2</artifactId> <scope>runtime</scope> </dependency> -->
44.         <dependency>
45.             <groupId>mysql</groupId>
46.             <artifactId>mysql-connector-java</artifactId>
47.             <scope>runtime</scope>
48.         </dependency>
49.         <dependency>
50.             <groupId>org.springframework.boot</groupId>
51.             <artifactId>spring-boot-starter-test</artifactId>
52.             <scope>test</scope>
53.         </dependency>
54.         <dependency>
55.             <groupId>org.springframework.batch</groupId>
56.             <artifactId>spring-batch-test</artifactId>
57.             <scope>test</scope>
58.         </dependency>
59.         <dependency>
60.             <groupId>org.projectlombok</groupId>
61.             <artifactId>lombok</artifactId>
62.         </dependency>
63.         <dependency>
64.             <groupId>org.quartz-scheduler</groupId>
65.             <artifactId>quartz</artifactId>
66.             <version>2.3.0</version>
67.         </dependency>
68.         <dependency>
69.             <groupId>com.h2database</groupId>
70.             <artifactId>h2</artifactId>
71.             <scope>runtime</scope>
72.         </dependency>
73.         <dependency>
74.             <groupId>org.mybatis</groupId>
75.             <artifactId>mybatis</artifactId>
76.             <version>3.4.6</version>
77.         </dependency>
78.         <dependency>
79.             <groupId>org.mybatis</groupId>
80.             <artifactId>mybatis-spring</artifactId>
81.             <version>1.3.2</version>
82.         </dependency>
83.         <dependency>
84.             <groupId>com.alibaba</groupId>
85.             <artifactId>druid</artifactId>
86.             <version>1.1.9</version>
87.         </dependency>
88.     </dependencies>
90.     <build>
91.         <plugins>
92.             <plugin>
93.                 <groupId>org.springframework.boot</groupId>
94.                 <artifactId>spring-boot-maven-plugin</artifactId>
95.             </plugin>
96.         </plugins>
97.     </build>
99. </project>

复制代码

[/code]
二、配置定时
spring-context-support的jar包作了quartz和spring batch的整合。QuartzJobBean类起连接quartz和spring batch的作用。quartz定时执行QuartzJobBean的继承类，在继承类中去执行启动批量任务，达到定时启动批量的作用。
1、创建QuartzJobBean的继承类

1. [code]package com.lzj.quartz;
2. import java.text.SimpleDateFormat;
3. import java.util.Date;
4. import org.h2.util.New;
5. import org.quartz.JobDataMap;
6. import org.quartz.JobDetail;
7. import org.quartz.JobExecutionContext;
8. import org.quartz.JobExecutionException;
9. import org.quartz.JobKey;
10. import org.springframework.batch.core.Job;
11. import org.springframework.batch.core.JobExecution;
12. import org.springframework.batch.core.JobParameters;
13. import org.springframework.batch.core.JobParametersBuilder;
14. import org.springframework.batch.core.configuration.JobLocator;
15. import org.springframework.batch.core.launch.JobLauncher;
16. import org.springframework.scheduling.quartz.QuartzJobBean;
18. public class QuartzJobLauncher extends QuartzJobBean {
19. /*-------------方式一：获取jobName、jobLauncher和jobLocator*/
20. //  private String jobName;
21. //  private JobLauncher jobLauncher;
22. //  private JobLocator jobLocator;
23. //
24. //  public String getJobName() {
25. //      return jobName;
26. //  }
27. //
28. //  public void setJobName(String jobName) {
29. //      this.jobName = jobName;
30. //  }
31. //
32. //  public JobLauncher getJobLauncher() {
33. //      return jobLauncher;
34. //  }
35. //
36. //  public void setJobLauncher(JobLauncher jobLauncher) {
37. //      this.jobLauncher = jobLauncher;
38. //  }
39. //
40. //  public JobLocator getJobLocator() {
41. //      return jobLocator;
42. //  }
43. //
44. //  public void setJobLocator(JobLocator jobLocator) {
45. //      this.jobLocator = jobLocator;
46. //  }
47. /*------------------------方式一获取结束------------------------------*/
49.     @Override
50.     protected void executeInternal(JobExecutionContext context) throws JobExecutionException {
51. /*-------------方式二：获取jobName、jobLauncher和jobLocator-------------------*/
52.         JobDetail jobDetail = context.getJobDetail();
53.         JobDataMap jobDataMap = jobDetail.getJobDataMap();
54.         String jobName = jobDataMap.getString("jobName");
55.         JobLauncher jobLauncher = (JobLauncher) jobDataMap.get("jobLauncher");
56.         JobLocator jobLocator = (JobLocator) jobDataMap.get("jobLocator");
57.         System.out.println("jobName : " + jobName);
58.         System.out.println("jobLauncher : " + jobLauncher);
59.         System.out.println("jobLocator : " + jobLocator);
60. /*-----------------------------方式二获取结束---------------------------------*/
61.         SimpleDateFormat sf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
62.         String date = sf.format(new Date());
63.         System.out.println("Current Time : " + date);
65.         try {
66.             Job job = jobLocator.getJob(jobName);
67.             /*启动spring batch的批处理作业*/
68.             JobExecution jobExecution = jobLauncher.run(job, new JobParametersBuilder().addDate("date", new Date()).toJobParameters());
69.         } catch (Exception e) {
70.             e.printStackTrace();
71.         }
73.     }
75. }

复制代码

[/code]
2、配置定时任务

1. [code]<?xml version="1.0" encoding="UTF-8"?>
2. <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd">
4.     <bean id="quartzJob" class="com.lzj.quartz.QuartzJobLauncher"></bean>
5.     <!-- 注册job -->
6.     <bean id="jobRegistry" class="org.springframework.batch.core.configuration.support.MapJobRegistry"></bean>
8.     <bean class="org.springframework.batch.core.configuration.support.JobRegistryBeanPostProcessor">
9.         <property name="jobRegistry" ref="jobRegistry"></property>
10.     </bean>
12.     <!-- jobLauncher在batch-config.xml文件中定义了 -->
13.     <bean id="jobDetail" class="org.springframework.scheduling.quartz.JobDetailFactoryBean">
14.         <property name="jobClass" value="com.lzj.quartz.QuartzJobLauncher"></property>
15.         <property name="jobDataMap">
16.             <map>
17.                 <entry key="jobName" value="myJob"></entry>
18.                 <entry key="jobLauncher" value-ref="jobLauncher"></entry>
19.                 <entry key="jobLocator" value-ref="jobRegistry"></entry>
20.             </map>
21.         </property>
22.     </bean>
24.     <bean id="cronTrigger" class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
25.         <property name="jobDetail" ref="jobDetail"></property>
26.         <property name="cronExpression" value="0/3 * * * * ?"></property>
27.         <property name="startDelay" value="3000"></property>
28.     </bean>
30.     <bean id="scheduler" class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
31.         <property name="triggers" ref="cronTrigger"></property>
32.     </bean>
34. </beans>

复制代码

[/code]
三、配置spring batch的job作业
1、首先创建batch的作业类，实现Tasklet接口即可
程序中用到的UserDao 与数据库打交道的接口在后面通过mybatis进行定义。

1. [code]package com.lzj.springbatch.tasklet;
2. import java.util.List;
3. import org.springframework.batch.core.StepContribution;
4. import org.springframework.batch.core.scope.context.ChunkContext;
5. import org.springframework.batch.core.step.tasklet.Tasklet;
6. import org.springframework.batch.repeat.RepeatStatus;
7. import com.lzj.mybatis.dao.UserDao;
8. import com.lzj.springbatch.model.User;
10. public class MyTasklet implements Tasklet {
11.     /*在配置文件batch-confi.xml中定义MyTasklet的bean时，传入UserDao 的属性*/
12.     private UserDao userDao;
14.     public UserDao getUserDao() {
15.         return userDao;
16.     }
18.     public void setUserDao(UserDao userDao) {
19.         this.userDao = userDao;
20.     }
22.     @Override
23.     public RepeatStatus execute(StepContribution contribution, ChunkContext chunkContext) throws Exception {
24.         User user = new User();
25.         user.setId(1);
26.         List<User> users = userDao.select(user);
27.         for(User user1 : users){
28.             System.out.println(user1);
29.         }
30.         return RepeatStatus.FINISHED;
31.     }
32. }

复制代码

[/code]
2、配置job作业

1. [code]<?xml version="1.0" encoding="UTF-8"?>
2. <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:batch="http://www.springframework.org/schema/batch" xmlns:jdbc="http://www.springframework.org/schema/jdbc" xmlns:context="http://www.springframework.org/schema/context" xsi:schemaLocation="http://www.springframework.org/schema/batch http://www.springframework.org/schema/batch/spring-batch.xsd http://www.springframework.org/schema/jdbc http://www.springframework.org/schema/jdbc/spring-jdbc-4.3.xsd http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.3.xsd">
4. <!-- <context:property-placeholder location="classpath:db.properties"/> -->
6.     <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
7.         <property name="dataSource" ref="dataSource"></property>
8.     </bean>
10.     <bean id="jobRepository" class="org.springframework.batch.core.repository.support.JobRepositoryFactoryBean">
11.         <property name="dataSource" ref="dataSource"></property>
12.         <property name="transactionManager" ref="transactionManager"></property>
13.     </bean>
15.     <bean id="jobLauncher" class="org.springframework.batch.core.launch.support.SimpleJobLauncher">
16.         <property name="jobRepository" ref="jobRepository"></property>
17.     </bean>
19.     <batch:job id="myJob" restartable="true">
20.         <batch:step id="myStep" allow-start-if-complete="true">
21.             <batch:tasklet ref="myTasklet">
22.             </batch:tasklet>
23.         </batch:step>
24.     </batch:job>
26.     <bean id="myTasklet" class="com.lzj.springbatch.tasklet.MyTasklet">
27. <!-- <property name="dataSource" ref="dataSource"></property> -->
28.         <property name="userDao" ref="userDao"></property>
29.     </bean>
31. </beans>

复制代码

[/code]
四、配置mybatis的持久化层
1、在spring boot中整合mybatis的配置

1. [code]<?xml version="1.0" encoding="UTF-8"?>
2. <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context" xmlns:tx="http://www.springframework.org/schema/tx" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.2.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.0.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-4.2.xsd">
4.     <bean id="propertyConfigure" class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
5.         <property name="locations">
6.             <list>
7.                 <value>classpath:db.properties</value>
8.             </list>
9.         </property>
10.     </bean>
12.     <!--spring batch和mybatis共用一个数据源-->
13.     <bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource">
14.         <property name="url" value="${jdbc.jdbcUrl}" />
15.         <property name="username" value="${jdbc.user}" />
16.         <property name="password" value="${jdbc.password}" />
17.         <property name="driverClassName" value="${jdbc.driverClass}" />
18.         <property name="initialSize" value="3" />
19.         <property name="minIdle" value="3" />
20.         <property name="maxActive" value="3" />
21.         <!-- 配置获取连接等待超时的时间 -->
22.         <property name="maxWait" value="60000" />
23.         <!-- 配置间隔多久才进行一次检测，检测需要关闭的空闲连接，单位是毫秒 -->
24.         <property name="timeBetweenEvictionRunsMillis" value="60000" />
25.         <!-- 配置一个连接在池中最小生存的时间，单位是毫秒 -->
26.         <property name="minEvictableIdleTimeMillis" value="300000" />
27.         <property name="testWhileIdle" value="true" />
28.         <property name="testOnBorrow" value="false" />
29.         <property name="testOnReturn" value="false" />
30.     </bean>
33.     <!-- 申明式事务 -->
34.     <tx:annotation-driven transaction-manager="transactionManager" />
36.     <!--mybatis-config.xml为mybatis的一些属性配置，如无必须要求，可不配置-->
37.     <bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
38.         <property name="dataSource" ref="dataSource" />
39.         <property name="configLocation" value="classpath:mybatis-config.xml" />
40.         <!-- <property name="typeAliasesPackage" value="domain.bean" /> -->
41.         <property name="mapperLocations">
42.             <array>
43.                 <value>classpath:mapper/*.xml</value>
44.             </array>
45.         </property>
46.     </bean>
48.     <!-- 配置加载Dao -->
49.     <bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">
50.         <property name="basePackage" value="com.lzj.mybatis.dao"></property>
51.         <property name="sqlSessionFactoryBeanName" value="sqlSessionFactory"></property>
52.     </bean>
54. </beans>

复制代码

[/code]
mybatis-config.xml中只配置了开启mybatis的二级缓存功能

1. [code]<?xml version="1.0" encoding="UTF-8" ?>
2. <!DOCTYPE configuration PUBLIC "-//mybatis.org//DTD Config 3.0//EN" "http://mybatis.org/dtd/mybatis-3-config.dtd">
4. <configuration>
5.     <settings>
6.         <setting name="cacheEnabled" value="true" />
7.     </settings>
8. </configuration>

复制代码

[/code]
数据库的properties文件db.properties为：

1. [code]jdbc.user=my_name
2. jdbc.password=my_password
3. jdbc.driverClass=com.ibm.db2.jcc.DB2Driver
4. jdbc.jdbcUrl=jdbc:db2:xx.xxx.xx.xxx:50000/database_name

复制代码

[/code]
2、创建mybatis的接口，程序通过接口来操作mybatis与数据库交互

1. [code]package com.lzj.mybatis.dao;
2. import java.util.List;
3. import com.lzj.springbatch.model.User;
4. public interface UserDao {
5.     public List<User> select(User user);
6. }

复制代码

[/code]
3、编写mybatis的mapper文件，接口操作mapper文件，

1. [code]mapper文件与数据库交互
2. <?xml version="1.0" encoding="UTF-8"?>
3. <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
4. <mapper namespace="com.lzj.mybatis.dao.UserDao">
5.     <resultMap type="com.lzj.springbatch.model.User" id="ResultMap">
6.         <result column="ID" property="id"/>
7.         <result column="NAME" property="name"/>
8.         <result column="AGE" property="age"/>
9.     </resultMap>
11.     <select id="select" resultMap="ResultMap">
12.         select * from SQLJ.users
13.         <where>
14.             <if test="id != null">ID > #{id}</if>
15.         </where>
16.     </select>
17. </mapper>

复制代码

[/code]
五、run
测试方法如下：

1. [code]@SpringBootApplication
2. public class DemoApplication {
4.     public static void main(String[] args) throws JobExecutionAlreadyRunningException, JobRestartException, JobInstanceAlreadyCompleteException, JobParametersInvalidException {
6.         Set<Object> set = new HashSet<>();
7.         set.add("classpath:batch-config.xml");
8.         set.add("classpath:quartz-config.xml");
9.         set.add("applicationContext.xml");
10.         SpringApplication app = new SpringApplication(DemoApplication.class);
11.         app.setSources(set);
12.         ApplicationContext context = app.run(args);
13.     }
14. }

复制代码

[/code]
启动测试方法，输出日志如下：

1. [code]……
2. jobName : myJob
3. jobLauncher : org.springframework.batch.core.launch.support.SimpleJobLauncher@4ba309ec
4. jobLocator : org.springframework.batch.core.configuration.support.MapJobRegistry@4564eee8
5. Current Time : 2018-04-13 19:48:00
6. 2018-04-13 19:48:00.032  INFO 4788 --- [eduler_Worker-2] o.s.b.c.l.support.SimpleJobLauncher      : Job: [FlowJob: [name=myJob]] launched with the following parameters: [{date=1523620080009}]
7. 2018-04-13 19:48:00.090  INFO 4788 --- [eduler_Worker-2] o.s.batch.core.job.SimpleStepHandler     : Executing step: [myStep]
8. User [id=2, name=huwei, age=28]
9. User [id=3, name=lijie, age=26]
10. 2018-04-13 19:48:00.140  INFO 4788 --- [eduler_Worker-2] o.s.b.c.l.support.SimpleJobLauncher      : Job: [FlowJob: [name=myJob]] completed with the following parameters: [{date=1523620080009}] and the following status: [COMPLETED]
11. jobName : myJob
12. jobLauncher : org.springframework.batch.core.launch.support.SimpleJobLauncher@4ba309ec
13. jobLocator : org.springframework.batch.core.configuration.support.MapJobRegistry@4564eee8
14. Current Time : 2018-04-13 19:48:03
15. 2018-04-13 19:48:03.017  INFO 4788 --- [eduler_Worker-3] o.s.b.c.l.support.SimpleJobLauncher      : Job: [FlowJob: [name=myJob]] launched with the following parameters: [{date=1523620083000}]
16. 2018-04-13 19:48:03.057  INFO 4788 --- [eduler_Worker-3] o.s.batch.core.job.SimpleStepHandler     : Executing step: [myStep]
17. User [id=2, name=huwei, age=28]
18. User [id=3, name=lijie, age=26]
19. 2018-04-13 19:48:03.089  INFO 4788 --- [eduler_Worker-3] o.s.b.c.l.support.SimpleJobLauncher      : Job: [FlowJob: [name=myJob]] completed with the following parameters: [{date=1523620083000}] and the following status: [COMPLETED]
20. jobName : myJob
21. jobLauncher : org.springframework.batch.core.launch.support.SimpleJobLauncher@4ba309ec
22. jobLocator : org.springframework.batch.core.configuration.support.MapJobRegistry@4564eee8
23. Current Time : 2018-04-13 19:48:06
24. 2018-04-13 19:48:06.019  INFO 4788 --- [eduler_Worker-4] o.s.b.c.l.support.SimpleJobLauncher      : Job: [FlowJob: [name=myJob]] launched with the following parameters: [{date=1523620086001}]
25. 2018-04-13 19:48:06.058  INFO 4788 --- [eduler_Worker-4] o.s.batch.core.job.SimpleStepHandler     : Executing step: [myStep]
26. User [id=2, name=huwei, age=28]
27. User [id=3, name=lijie, age=26]
28. 2018-04-13 19:48:06.094  INFO 4788 --- [eduler_Worker-4] o.s.b.c.l.support.SimpleJobLauncher      : Job: [FlowJob: [name=myJob]] completed with the following parameters: [{date=1523620086001}] and the following status: [COMPLETED]
29. ……

复制代码

[/code]
通过日志可以看出，每3s执行一次job任务
工程目录为：