1.加上注解 @EnableScheduling
@EnableCaching // 启用缓存功能
@EnableScheduling // 开启定时任务功能
@ComponentScan(basePackages = "org.javamaster.b2c")
@EnableTransactionManagement
@SpringBootApplication
public class ScheduledApplication {
private static Logger logger = LoggerFactory.getLogger(ScheduledApplication.class);
public static void main(String[] args) {
SpringApplication.run(ScheduledApplication.class, args);
logger.info("定时任务页面管理地址:{}", "http://localhost:8089/scheduled/task/taskList");
}
}定时任务类：
//定时任务类
//@Scheduled(cron ="*/15 * * * * ?")注解表明这是一个需要定时执行的方法,里面的cron属性接收的是一个cron表达式
//*/15 * * * * 的意思是每隔15秒执行一次方法
@Component
public class FixedPrintTask {
private Logger logger = LoggerFactory.getLogger(getClass());
private int i;
@Scheduled(cron = "*/15 * * * * ?")
public void execute() {
logger.info("thread id:{},FixedPrintTask execute times:{}", Thread.currentThread().getId(), ++i);
}
}缺点：执行周期写死在代码里了，没有办法动态改变，要想改变只能修改代码在重新部署启动微服务。
2.方式2
//创建定时任务类
drop table if exists `spring_scheduled_cron`;
create table `spring_scheduled_cron` (
`cron_id` int primary key auto_increment
comment '主键id',
`cron_key` varchar(128) not null unique
comment '定时任务完整类名',
`cron_expression` varchar(20) not null
comment 'cron表达式',
`task_explain` varchar(50) not null default ''
comment '任务描述',
`status` tinyint not null default 1
comment '状态,1:正常;2:停用',
unique index cron_key_unique_idx(`cron_key`)
)
ENGINE = InnoDB
DEFAULT CHARSET = utf8mb4
COMMENT = '定时任务表';
insert into `spring_scheduled_cron`
values (1, 'org.javamaster.b2c.scheduled.task.DynamicPrintTask', '*/5 * * * * ?', '定时任务描述', 1);
insert into `spring_scheduled_cron`
values (2, 'org.javamaster.b2c.scheduled.task.DynamicPrintTask1', '*/5 * * * * ?', '定时任务描述1', 1);
insert into `spring_scheduled_cron`
values (3, 'org.javamaster.b2c.scheduled.task.DynamicPrintTask2', '*/5 * * * * ?', '定时任务描述2', 1);//配置类
@Configuration
public class ScheduledConfig implements SchedulingConfigurer {
@Autowired
private ApplicationContext context;
@Autowired
private SpringScheduledCronRepository cronRepository;
@Override
public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
for (SpringScheduledCron springScheduledCron : cronRepository.findAll()) {
Class<?> clazz;
Object task;
try {
clazz = Class.forName(springScheduledCron.getCronKey());
task = context.getBean(clazz);
} catch (ClassNotFoundException e) {
throw new IllegalArgumentException("spring_scheduled_cron表数据" + springScheduledCron.getCronKey() + "有误", e);
} catch (BeansException e) {
throw new IllegalArgumentException(springScheduledCron.getCronKey() + "未纳入到spring管理", e);
}
Assert.isAssignable(ScheduledOfTask.class, task.getClass(), "定时任务类必须实现ScheduledOfTask接口");
// 可以通过改变数据库数据进而实现动态改变执行周期
taskRegistrar.addTriggerTask(((Runnable) task),
triggerContext -> {
String cronExpression = cronRepository.findByCronKey(springScheduledCron.getCronKey()).getCronExpression();
return new CronTrigger(cronExpression).nextExecutionTime(triggerContext);
}
);
}
}
@Bean
public Executor taskExecutor() {
return Executors.newScheduledThreadPool(10);
}
}//这里我为了做到可以灵活处理，自定义了一个接口ScheduledOfTask:
public interface ScheduledOfTask extends Runnable {
/**
* 定时任务方法
*/
void execute();
/**
* 实现控制定时任务启用或禁用的功能
*/
@Override
default void run() {
SpringScheduledCronRepository repository = SpringUtils.getBean(SpringScheduledCronRepository.class);
SpringScheduledCron scheduledCron = repository.findByCronKey(this.getClass().getName());
if (StatusEnum.DISABLED.getCode().equals(scheduledCron.getStatus())) {
// 任务是禁用状态
return;
}
execute();
}
}所有定时任务类只需要实现这个接口并相应的在数据库插入一条记录，那么在微服务启动的时候，就会被自动注册到Spring的定时任务里，也就是这行代码所起的作用：
// 可以通过改变数据库数据进而实现动态改变执行周期
taskRegistrar.addTriggerTask(((Runnable) task),
triggerContext -> {
String cronExpression = cronRepository.findByCronKey(springScheduledCron.getCronKey()).getCronExpression();
return new CronTrigger(cronExpression).nextExecutionTime(triggerContext);
}
);具体的定时任务类（一共有三个，这里我只列出一个）
@Component
public class DynamicPrintTask implements ScheduledOfTask {
private Logger logger = LoggerFactory.getLogger(getClass());
private int i;
@Override
public void execute() {
logger.info("thread id:{},DynamicPrintTask execute times:{}", Thread.currentThread().getId(), ++i);
}
}项目跑起来后，可以看到类被定时执行了.
提供一个Controller类供调用，动态更改数据库：
/**
* 管理定时任务(需要做权限控制)，具体的业务逻辑应
* 该写在Service里，良好的设计是Controller本身
* 只处理很少甚至不处理工作，业务逻辑均委托给
* Service进行处理，这里我偷一下懒，都写在Controller
*/
@Controller
@RequestMapping("/scheduled/task")
public class TaskController {
@Autowired
private ApplicationContext context;
@Autowired
private SpringScheduledCronRepository cronRepository;
/**
* 查看任务列表
*/
@RequestMapping("/taskList")
public String taskList(Model model) {
model.addAttribute("cronList", cronRepository.findAll());
return "task-list";
}
/**
* 编辑任务cron表达式
*/
@ResponseBody
@RequestMapping("/editTaskCron")
public Result<Void> editTaskCron(String cronKey, String newCron) {
if (!CronUtils.isValidExpression(newCron)) {
throw new IllegalArgumentException("失败,非法表达式:" + newCron);
}
cronRepository.updateCronExpressionByCronKey(newCron, cronKey);
return new Result<>(AppConsts.SUCCESS, "更新成功");
}
/**
* 执行定时任务
*/
@ResponseBody
@RequestMapping("/runTaskCron")
public Result<Void> runTaskCron(String cronKey) throws Exception {
((ScheduledOfTask) context.getBean(Class.forName(cronKey))).execute();
return new Result<>(AppConsts.SUCCESS, "执行成功");
}
/**
* 启用或禁用定时任务
*/
@ResponseBody
@RequestMapping("/changeStatusTaskCron")
public Result<Void> changeStatusTaskCron(Integer status, String cronKey) {
cronRepository.updateStatusByCronKey(status, cronKey);
return new Result<>(AppConsts.SUCCESS, "操作成功");
}
}
最后如果对定时任务有更多其它要求，可以考虑使用xxljob这个开源的分布式任务调度平台，有兴趣的同学可以去了解，这里我就不展开了。
源码github地址和gitee地址（代码同步）：
GitHub - jufeng98/java-master: Java高手之路
java-master: Java高手之路
