Java定时任务——数据库方式管理 (java定时任务数据库方式)
近年来，随着互联网技术的不断发展，大量的计算机软件需要进行定时任务的管理，来判断是否有数据需要自动提交处理等等。因此，定时任务已经成为了Java程序员的必备技能。然而，随着任务数量的增长，相应的管理也变得越来越繁琐，力求提高其效率和控制力的需求也变得日益迫切。因此，数据库方式管理成为了一个很好的解决方案。本文旨在介绍Java定时任务的管理方式，着眼于数据库方式管理的具体实践。
一、Java定时任务的常见管理方式
1.使用Schedule类来管理任务：Java官方提供了一个Schedule类，可以用于对任务的调度，该类提供了多个接口来实现任务的定时执行，详见https://docs.oracle.com/javase/8/docs/api/java/util/concurrent/ScheduledExecutorService.html。
2.使用Quartz框架管理任务：Quartz是一个Java的任务调度框架，提供了强大的任务调度功能，支持集群、多线程调度。
3.使用Spring框架管理任务：Spring框架是一个Java的应用程序开发框架，用于简化企业级应用程序开发，包括任务调度、面向切面编程等等。
二、为什么要采用数据库方式管理Java定时任务？
上述三种方式无论哪种，都有其自身的特点和优劣势，但是这些方式均需要程序员进行代码实现和管理，一旦任务数量较多可能导致管理繁琐，效率低下的问题。同时，Java应用程序一旦停止运行，所有的任务也会随之中断，需要重新开始执行，这样很容易导致数据丢失，因此需要一个更为稳定可靠的解决方案。次之，如果使用了第三方框架，需要对框架进行熟悉，且场景过于简单的使用方式不一定能够满足复杂的使用场景。在此情况下，我们可以使用数据库方式管理Java定时任务。
三、如何采用数据库方式管理Java定时任务？
数据库方式管理Java定时任务，需要提前创建好Table，这个Table中需要包括以下几个字段：ID，TASK_NAME，TASK_TYPE，TASK_PARAM，CRON_EXPRESSION，START_TIME，END_TIME，STATE。然后再将Table映射成Java对象。如下图所示：
任务定义表结构
1.定时任务的核心代码：
“`java
@Service
public class TaskSchedulerServiceImpl implements TaskSchedulerService {
@Autowired
private TaskSchedulerDao taskSchedulerDao;
@Override
public void schedule(String taskName, String taskType, String taskParam, String cronExpression) {
TaskSchedulerEntity taskSchedulerEntity = new TaskSchedulerEntity();
taskSchedulerEntity.setTaskName(taskName);
taskSchedulerEntity.setTaskType(taskType);
taskSchedulerEntity.setTaskParam(taskParam);
taskSchedulerEntity.setCronExpression(cronExpression);
taskSchedulerDao.insert(taskSchedulerEntity);
}
@Override
public void start(Long taskId) {
TaskSchedulerEntity taskSchedulerEntity = taskSchedulerDao.selectById(taskId);
if (taskSchedulerEntity == null) {
throw new RuntimeException();
}
// 创建 JobDetl 实例，并与 HelloJob 类绑定
JobDetl jobDetl = JobBuilder.newJob(DynamicJob.class)
.withIdentity(taskSchedulerEntity.getTaskName(), taskSchedulerEntity.getTaskType()).build();
jobDetl.getJobDataMap().put(“jobParam”, taskSchedulerEntity.getTaskParam());
// 创建 CronTrigger 对象，指定任务触发的时间规则
CronScheduleBuilder cronScheduleBuilder = CronScheduleBuilder.cronSchedule(taskSchedulerEntity.getCronExpression());
CronTrigger cronTrigger = TriggerBuilder.newTrigger().withIdentity(taskSchedulerEntity.getTaskName(), taskSchedulerEntity.getTaskType())
.withSchedule(cronScheduleBuilder).build();
// 创建 SchedulerFactory 对象
SchedulerFactory schedulerFactory = new StdSchedulerFactory();
// 获取 Scheduler 对象
try {
Scheduler scheduler = schedulerFactory.getScheduler();
// 设置 JobDetl 和 Trigger
scheduler.scheduleJob(jobDetl, cronTrigger);
// 启动调度器
scheduler.start();
// 修改任务状态为正常
taskSchedulerEntity.setState(TaskStateEnum.START.getCode());
taskSchedulerDao.updateById(taskSchedulerEntity);
} catch (Exception e) {
// 修改任务状态为异常
taskSchedulerEntity.setState(TaskStateEnum.ERROR.getCode());
taskSchedulerDao.updateById(taskSchedulerEntity);
throw new RuntimeException();
}
}
@Override
public void stop(Long taskId) {
TaskSchedulerEntity taskSchedulerEntity = taskSchedulerDao.selectById(taskId);
if (taskSchedulerEntity == null) {
throw new RuntimeException();
}
// 创建 SchedulerFactory 对象
SchedulerFactory schedulerFactory = new StdSchedulerFactory();
try {
Scheduler scheduler = schedulerFactory.getScheduler();
JobKey jobKey = new JobKey(taskSchedulerEntity.getTaskName(), taskSchedulerEntity.getTaskType());
scheduler.deleteJob(jobKey);
// 修改任务状态为停止
taskSchedulerEntity.setState(TaskStateEnum.STOP.getCode());
taskSchedulerDao.updateById(taskSchedulerEntity);
} catch (SchedulerException e) {
// 修改任务状态为异常
taskSchedulerEntity.setState(TaskStateEnum.ERROR.getCode());
taskSchedulerDao.updateById(taskSchedulerEntity);
throw new RuntimeException();
}
}
}
“`
2.任务执行类的核心代码：
“`java
public class DynamicJob implements Job {
@Override
public void execute(JobExecutionContext context) throws JobExecutionException {
JobDataMap dataMap = context.getJobDetl().getJobDataMap();
String jobParam = (String) dataMap.get(“jobParam”);
// 正常的业务处理
System.out.println(“执行动态定时任务，任务参数：” + jobParam);
}
}
“`
四、
Java定时任务的管理方式多种多样，但频繁的维护、调整和控制任务数量等问题仍然存在。数据库方式管理Java定时任务能够有效地解决这些问题，并且可以更好地满足业务的需求。显然，在生产环境中使用这种方式管理任务可以更大程度实现任务优化，也可以根据自己需求定制更适合自己业务的方式。但是，开发人员在使用此方式管理定时任务时，需要仔细考虑任务的相关需求，进行代码的拆分和调整，才能更好地实现任务的功能，提高定时任务管理的效率。
