定时任务—写的不好，不要看-创新互联

计划任务什么是计划任务（Crond）

计划任务—我们平时生活中的闹钟，定点执行

发展壮大离不开广大客户长期以来的信赖与支持，我们将始终秉承“诚信为本、服务至上”的服务理念，坚持“二合一”的优良服务模式，真诚服务每家企业，认真做好每个细节，不断完善自我，成就企业，实现共赢。行业涉及成都塔吊租赁等，在成都网站建设、成都营销网站建设、WAP手机网站、VI设计、软件开发等项目上具有丰富的设计经验。为什么要有计划任务

计划任务—主要是做一些周期性的任务，比如: 凌晨3点定时备份数据，订单超过三十分钟，取消订单。每十分钟抓取别的网站数据收为己用等等。

计划任务主要分两种

一、系统级别的定时任务：临时文件清理、系统信息采集、日志文件切割。二、用户级别的定时任务：定时备份系统配置文件、定时备份数据库的数据。

计划任务时间管理

root@Hyman[15:23:15]~# vim /etc/crontab
SHELL=/bin/bash                     #执行命令的解释器
PATH=/sbin:/bin:/usr/sbin:/usr/bin  #环境变量
MAILTO=root                         #邮件发给谁
# Example of job definition:
# .---------------- minute (0 - 59) #分钟
# |  .------------- hour (0 - 23)   #小时
# |  |  .---------- day of month (1 - 31)   #日期
# |  |  |  .------- month (1 - 12) OR jan,feb,mar,apr #月份
# |  |  |  |  .---- day of week (0 - 6) (Sunday=0 or 7) OR sun,mon,tue,wed,thu,fri,sat  #星期
# |  |  |  |  |
# *  *  *  *  *   command to be executed

# *  表示任意的(分、时、日、月、周)时间都执行
# -  表示一个时间范围段, 如5-7点
# ,  表示分隔时段, 如6,0,4表示周六、日、四
# /1 表示每隔n单位时间, 如*/10 每10分钟


00 02 * * * ls           #每天的凌晨2点整执行
*/10  02 * * * ls        #每天凌晨2点，每隔10分钟执行一次
45 4 1-10 * * ls         #每月1到10日的4:45执行
45 4 1,10,22 * * ls      #每月1、10、22日的4:45执行

SpringBoot基于SchedulingConfigurer接口实现动态定时任务

步骤：编写实体类-》定时执行的业务方法接口-》定时执行的业务方法接口实现-》实现SchedulingConfigurer接口，重写configureTasks()方法

@Entity
@Table(name = "SYS_TIMED_TASK")
public class TimedTaskEntity extends BaseEntity {private static final long serialVersionUID = 1L;
    public static String STATUS_START = "START";
    public static String STATUS_STOP = "STOP";
    @Column(name = "task_name", nullable = true)
    private String taskName;//定时任务名
    @Column(name = "status", nullable = true)//状态
    private String status = STATUS_STOP;
    @Column(name = "init_status")//初始状态
    private String initStatus = STATUS_START;
    @Column(name = "task_cron", nullable = true)
    private String cron;//定时任务时间管理
    @Column(name = "service_name", nullable = true, length = 255)
    private String serviceName;//调用的服务名
    @Column(name = "exe_method", nullable = true, length = 255)
    private String exeMethod;//调用的服务名中具体方法
    @Column(name = "task_desc", nullable = true, length = 255)
    private String description;//定时任务描述
    
    @Transient
    ScheduledTask scheduledTask;//计划任务
    @Transient
    Boolean scheduledTaskEnabled = false;
}

业务方法接口实现

//假设刚添加的定时任务数据已经保存到数据库中-》接下来就是开始定时任务了
    @RequestMapping({"/start"})
	@ControllerLogExeTime(description="开启定时任务")
	public void start(String id ) {dynamicScheduledTaskServiceImpl.start(id);
	}

实现SchedulingConfigurer接口，重写configureTasks()方法

@Component(value = "dynamicScheduledTaskService")
public class DynamicScheduledTaskServiceImpl implements SchedulingConfigurer, ApplicationContextAware, DynamicScheduledTaskService {private MaptaskMap = new ConcurrentHashMap();
    //开始定时任务
    synchronized public void start(String id) {//查询taskMap 是否含有该定时任务
        TimedTaskEntity transientTimedTaskEntity = this.taskMap.get(id);
        TimedTaskEntity timedTaskEntity = null;
        //没有该定时任务
        if (transientTimedTaskEntity == null) {timedTaskEntity = timedTaskService.get(id);
            if (timedTaskEntity != null) {   //开启定时任务
               scheduleTriggerTask(transientTimedTaskEntity);
               //修改实体类中的开始状态信息               
               transientTimedTaskEntity.setStatus(TimedTaskEntity.STATUS_START);
            }
        }
    }
    
    //开启定时任务
    private void scheduleTriggerTask(TimedTaskEntity timedTaskEntity) {//检查该定时任务信息是否符合你们的要求
        check(timedTaskEntity);
        //将该定时任务添加到taskMap中
        this.taskMap.put(timedTaskEntity.getId(), timedTaskEntity);
        //触发器
        TriggerTask triggerTask = new TriggerTask(new Runnable() {@Override
            public void run() {Object serviceObject = applicationContext
                        .getBean(timedTaskEntity.getServiceName());
                try {Method method = serviceObject.getClass()
                            .getMethod(timedTaskEntity.getExeMethod());
                    try {method.invoke(serviceObject);
                    } catch (Throwable e) {logger.error("invode service method  error", e);
                    }
                } catch (Throwable e) {logger.error("get service method  error", e);
                }
            }
        }, new Trigger() {@Override
            public Date nextExecutionTime(TriggerContext triggerContext) {TimedTaskEntity entity = taskMap.get(timedTaskEntity.getId());
                CronTrigger trigger = new CronTrigger(entity.getCron());
                Date nextExecDate = trigger.nextExecutionTime(triggerContext);
                return nextExecDate;
            }
        });
        //计划任务的表示形式
        ScheduledTask scheduledTask = null;
        try {//调度指定的触发器任务
            scheduledTask = taskRegistrar.scheduleTriggerTask(triggerTask);
        } catch (Throwable e) {logger.error("schedule trigger task error", e);
            if(scheduledTask != null){this.taskMap.remove(timedTaskEntity.getId());
                scheduledTask.cancel();
            }
        }
        if(scheduledTask != null){timedTaskEntity.setScheduledTask(scheduledTask);
            TimedTaskEntity entity = timedTaskRepository.get(timedTaskEntity.getId());
            entity.setStatus(TimedTaskEntity.STATUS_START);
            this.timedTaskRepository.save(entity);
        }
    }



    public void check(TimedTaskEntity timedTaskEntity) {String serviceName = timedTaskEntity.getServiceName();
        Object serviceObject = null;
        try {serviceObject = applicationContext.getBean(serviceName);
        } catch (Throwable e) {logger.error("can't find  service  " + serviceName);
            Assert.throwException("sys.timedTask.notFindService", serviceName);
        }
        serviceObject.getClass();
        String methodName = timedTaskEntity.getExeMethod();
        try {serviceObject.getClass().getMethod(methodName);
        } catch (Exception e) {logger.error("can't find  method " + methodName);
            Assert.throwException("sys.timedTask.notFindMethod", methodName);
        }
        String cron = timedTaskEntity.getCron();
        boolean flag = false;
        try {flag = CronSequenceGenerator.isValidExpression(cron);
        } catch (Exception e) {logger.error("cron is error " + cron);
            Assert.throwException("sys.timedTask.cronError", cron);
        }
        if (!flag) {Assert.throwException("sys.timedTask.cronError", cron);
        }
    }
}

你是否还在寻找稳定的海外服务器提供商？创新互联www.cdcxhl.cn海外机房具备T级流量清洗系统配攻击溯源，准确流量调度确保服务器高可用性，企业级服务器适合批量采购，新人活动首月15元起，快前往官网查看详情吧

网站标题：定时任务—写的不好，不要看-创新互联
新闻来源：http://cxhlcq.com/article/eehps.html

定时任务—写的不好，不要看-创新互联

其他资讯

网站制作

企业服务

网站建设

服务器托管