定时调度
时间:2019-02-11
本文章向大家介绍定时调度,主要包括定时调度使用实例、应用技巧、基本知识点总结和需要注意事项,具有一定的参考价值,需要的朋友可以参考一下。
https://www.cnblogs.com/dawnheaven/p/5301482.html
https://www.jianshu.com/p/d732707ff194
解释:在规定的时间执行相关的程序,比如在距离活动结束前10分钟发送一个短信,定时调度就是在这个时间点调度发送短信的任务。
例子:
controller:
(可以写在service中,我写在controller了)
@Autowired
private Scheduler scheduler;
/**
* 测试定时调度
* @param req
* @return
*/
@RequestMapping(value = "/test",method = RequestMethod.POST)
public ResponseBase test(@Valid @RequestBody PushReq req){
System.out.println("---"+req.getEndTime());
try {
if(req.getEndTime()!=null){
PushTask testTask = new PushTask(PushTaskName.PUSH_TASK_NAME.name(),req.getOrderNo());
Trigger trigger = scheduler.getTrigger(testTask.getTriggerKey());
if (trigger != null) {
scheduler.deleteJob(trigger.getJobKey());
}
pushService.testJob(scheduler,testTask,req.getEndTime());
}
return ResponseBase.succeeded();
} catch (Exception e) {
e.printStackTrace();
return ResponseBase.failed(ApiCode.INTERNAL_SERVER_ERROR, e.getMessage());
}
}
basetask: (是一个基础的,方便其他task的实现)
public class BaseTask {
String group;
String jobName;
String triggerName;
private JobKey jobKey;
private TriggerKey triggerKey;
public BaseTask(){
}
public BaseTask(String group, String taskName, String id) {
this.group = group;
this.jobName = taskName + "_JOB_" + id;
this.triggerName = taskName + "_TRIGGER_" + id;
this.jobKey = new JobKey(jobName, group);
this.triggerKey = new TriggerKey(triggerName, group);
}
public String getGroup() {
return group;
}
public String getJobName() {
return jobName;
}
public void setJobName(String jobName) {
this.jobName = jobName;
}
public void setGroup(String group) {
this.group = group;
}
public String getTriggerName() {
return triggerName;
}
public void setTriggerName(String triggerName) {
this.triggerName = triggerName;
}
public JobKey getJobKey() {
return jobKey;
}
public void setJobKey(JobKey jobKey) {
this.jobKey = jobKey;
}
public TriggerKey getTriggerKey() {
return triggerKey;
}
public void setTriggerKey(TriggerKey triggerKey) {
this.triggerKey = triggerKey;
}
}
实现basetask的task
public class PushTask extends BaseTask{
@NotBlank
private String pushId;
@NotBlank
private Long orderno;
public PushTask(String taskName, String id){
super(PushGroup.PUSH_GROUP.name(),taskName,id);
this.pushId = id;
}
public String getPushId() {
return pushId;
}
public void setPushId(String pushId) {
this.pushId = pushId;
}
public Long getOrderno() {
return orderno;
}
public void setOrderno(Long orderno) {
this.orderno = orderno;
}
}
service:
@Override
public void testJob(Scheduler scheduler, PushTask testTask, Date time) throws Exception {
//用于如何开始和关闭一个定时任务以及如何运行一个运行任务
/**
* 1. 获取scheduler对象,此处是由参数传入
* 2. 获取时间,此处由参数传入
* 3. 定义一个job对象,绑定job类,即本次的TestJob[真正执行的任务并不是Job接口的实例,而是用反射的方式实例化的一个JobDetail实例 ]
* 4. 定义一个触发器,startAt方法定义了任务应当开始的时间
* 5. 将任务和tigger放入scheduler
*/
logger.info("[TEAM] close team" + testTask);
//3. job对象绑定job类
JobDetail jobDetail = JobBuilder
.newJob(TestJob.class)
.withIdentity(testTask.getJobKey())
.build();
JobDataMap jobDataMap = jobDetail.getJobDataMap();
jobDataMap.put("pintuanid_job", testTask.getOrderno());
//4. 触发器
Trigger trigger = TriggerBuilder
.newTrigger()
.withIdentity(testTask.getTriggerKey())
.withSchedule(SimpleScheduleBuilder.simpleSchedule().withIntervalInSeconds(2))
.startAt(time)
.build();
//5. 将任务和tigger放入scheduler
scheduler.scheduleJob(jobDetail,trigger);
System.out.println("任务调度已经启动---"+time);
}
job:
package com.eyee.scheduler.job;
import org.quartz.Job;
import org.quartz.JobDataMap;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import java.util.Date;
public class TestJob implements Job {
@Override
public void execute(JobExecutionContext context) throws JobExecutionException {
JobDataMap jobDataMap = context.getJobDetail().getJobDataMap();
String result = (String)jobDataMap.get("pintuanid_job");
System.out.println("===="+result);
System.out.println("hello word-"+new Date());
}
}
- Golang语言--包的概念、导入与可见性
- MySQL中的change,modify和自增列的关系(r12笔记第70天)
- Golang 值得注意的地方
- MySQL数值类型在binlog中需要注意的细节(r12笔记第69天)
- WordPress评论滑动/拉链解锁myQaptcha修改为自动提交的方法
- MySQL root用户登录的几个小问题(r12笔记第67天)
- Java实现生产者消费者的两种方式(r12笔记第66天)
- Golang语言的函数调用信息
- mysqldump的一点使用总结(r12笔记第81天)
- 转-Golang语言Interface漫谈
- WordPress导航菜单图标字体插件font awesome 4 menus纯代码版
- Oracle 12c远程克隆PDB的问题及修复(r12笔记第78天)
- Oracle表中含有255列以上时需要注意的(r12笔记第77天)
- Golang语言--资源自动回收技术
- JavaScript 教程
- JavaScript 编辑工具
- JavaScript 与HTML
- JavaScript 与Java
- JavaScript 数据结构
- JavaScript 基本数据类型
- JavaScript 特殊数据类型
- JavaScript 运算符
- JavaScript typeof 运算符
- JavaScript 表达式
- JavaScript 类型转换
- JavaScript 基本语法
- JavaScript 注释
- Javascript 基本处理流程
- Javascript 选择结构
- Javascript if 语句
- Javascript if 语句的嵌套
- Javascript switch 语句
- Javascript 循环结构
- Javascript 循环结构实例
- Javascript 跳转语句
- Javascript 控制语句总结
- Javascript 函数介绍
- Javascript 函数的定义
- Javascript 函数调用
- Javascript 几种特殊的函数
- JavaScript 内置函数简介
- Javascript eval() 函数
- Javascript isFinite() 函数
- Javascript isNaN() 函数
- parseInt() 与 parseFloat()
- escape() 与 unescape()
- Javascript 字符串介绍
- Javascript length属性
- javascript 字符串函数
- Javascript 日期对象简介
- Javascript 日期对象用途
- Date 对象属性和方法
- Javascript 数组是什么
- Javascript 创建数组
- Javascript 数组赋值与取值
- Javascript 数组属性和方法
- Kubernetes K8S之资源控制器Daemonset详解
- Kubernetes K8S之资源控制器Job和CronJob详解
- Kubernetes K8S在IPVS代理模式下Service服务的ClusterIP类型访问失败处理
- Kubernetes K8S之Pod跨namespace名称空间访问Service服务
- Kubernetes K8S之Service服务详解与示例
- Kubernetes K8S之Ingress详解与示例
- Kubernetes K8S之存储Secret详解
- 在K8s上轻松部署Tungsten Fabric的两种方式
- Linux系统如何在离线环境或内网环境安装部署Docker服务和其他服务
- Servlet执行流程
- 最新的spring boot技术实现登录、列表、分页、上传等功能
- 谈谈我对Vue钩子函数、生命周期的理解
- 浅谈Apache Shiro权限模块及数据库设计
- 企图变秃变强的第一天
- 企图变秃变强的第二天