一、目录结构
勾选部分为相比上一章新增部分。
二、导入 Pom 依赖
三、改造各层代码
新增了两个方法，一个查询 code 表中的用户数量（用于测试），一个修改用户数量。
四、新增 Job
ps：新增 Job 类继承 QuartzJobBean，并重写 QuartzJobBean 的 executeInternal 方法。注意此处的 jobExecutionContext 参数，在 Detail 绑定该 Job 之后，可以传参数过来，通过该参数可以在 Job 中获取传过来的参数。获取方式如上图。该 Job 用来修改用户数量。
五、新增 quartz 配置类（编写 Trigger 和 Detail）
@Configurationpublic class QuartzConfiguration { @Bean public JobDetail MyJob1JobDetail(){ return JobBuilder.newJob(MyJob1.class)//PrintTimeJob我们的业务类 .withIdentity("MyJob1")//可以给该JobDetail起一个id //每个JobDetail内都有一个Map，包含了关联到这个Job的数据，在Job类中可以通过context获取 .usingJobData("MyJob1", "Hello Quartz")//关联键值对 .storeDurably()//即使没有Trigger关联时，也不需要删除该JobDetail .build(); } @Bean public Trigger MyJob1JobTrigger() { CronScheduleBuilder cronScheduleBuilder = CronScheduleBuilder.cronSchedule("0/30 * * * * ? *");//每30秒执行 return TriggerBuilder.newTrigger() .forJob(MyJob1JobDetail())//关联上述的JobDetail .withIdentity("MyJob1JobTrigger")//给Trigger起个名字 .withSchedule(cronScheduleBuilder) .build(); } @Bean public JobDetail MyJob2JobDetail(){ return JobBuilder.newJob(MyJob2.class)//PrintTimeJob我们的业务类 .withIdentity("MyJob2")//可以给该JobDetail起一个id //每个JobDetail内都有一个Map，包含了关联到这个Job的数据，在Job类中可以通过context获取 .usingJobData("MyJob2", "Hello Quartz")//关联键值对 .storeDurably()//即使没有Trigger关联时，也不需要删除该JobDetail .build(); } @Bean public Trigger MyJob2JobTrigger() { CronScheduleBuilder cronScheduleBuilder = CronScheduleBuilder.cronSchedule("0/30 * * * * ? *");//每30秒执行 return TriggerBuilder.newTrigger() .forJob(MyJob2JobDetail())//关联上述的JobDetail .withIdentity("MyJob2JobTrigger")//给Trigger起个名字 .withSchedule(cronScheduleBuilder) .build(); } }
复制代码
ps:不要忘记 Configuration 注解。下面解释 Detail 和 Trigger 的编写。
newJob 是设置需要绑定的 Job 的类型，withIdentity 是给该 detail 取个名字，usingJobData 是给该 detail 存储数据，可以在绑定的 Job 中通过 Context 获取此处绑定的值通过 key-value 方式获取。
新建一个 CronScheduleBuilder 用来维护定时任务环境，并让触发器生效，可以设置 cron 表达式，forJob 设置需要启用的 Detail 的类，withIdentity 是给该 Trigger 取名，withSchedule 是绑定 Schedule。
六、演示
操作：启动项目，请求查询用户数量接口，等待 30 秒再次查询。
等待 30 秒。
控制台打印：
可以看到在 Job 中获取 Detail 传过来的值，获取成功。
兄弟们羊么。
评论