[Java知识库] Java定时任务与分布式定时任务

开发: C++知识库 Java知识库 JavaScript Python PHP知识库人工智能区块链大数据移动开发嵌入式开发工具数据结构与算法开发测试游戏开发网络协议系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑笔记本显卡显示器固态硬盘硬盘耳机手机 iphone vivo oppo 小米华为单反装机图拉丁

-> Java知识库 -> Java定时任务与分布式定时任务 -> 正文阅读

[Java知识库]Java定时任务与分布式定时任务

Java定时任务与分布式定时任务

文章目录

- Java定时任务与分布式定时任务

业务场景：

订单下单之后15分钟后，用户未付款，系统需要自动取消订单。
红包24小时未被查收，需要延迟执退还业务；
超过7天，自动收货

1. JDK原生

使用JUC 提供的newScheduledThreadPool来执行定时任务

public class ScheduledExecutor {
    public static void main(String[] args) {
        // 创建任务队列，起10个线程
        ScheduledExecutorService scheduledExecutorService = Executors.newScheduledThreadPool(10);
        // 执行任务：1秒 后开始执行，每5秒执行一次
        scheduledExecutorService.scheduleAtFixedRate(new Runnable() {
            @Override
            public void run() {
                System.out.println("执行任务: "+new Date());
            }
        },1,5, TimeUnit.SECONDS);
    }
}

2. Spring

使用Spring提供的@Scheduled 配置任务类，在启动类上添加@EnableScheduling

@Component
public  class ScheduleWork {
    @Scheduled(cron = "5/3 * * * * ? ")
    public void doJob() {
        System.out.println("spring 定时器 ："+ new Date());
    }
}
// 启动类加上注解，表示启用定时任务
@EnableScheduling
@SpringBootApplication
public class Application {
    public static void main(String[] args) {
        SpringApplication.run(Application.class, args);
    }
}

或者使用@Configuration定义配置类注解，在任务类上同时使用@EnableScheduling 和@Scheduled

@Configuration
@EnableScheduling
public class SomeJob {
    @Scheduled(cron = "5/3 * * * * ? ")
    public void someTask() {
        System.out.println("更改注解位置的方式  ");
    }
}

这种方式有个缺点，那就是执行周期写死在代码里了，没有办法动态改变，要想改变只能修改代码在重新部署启动微服务.

3.Spring + 数据库

启动类

@EnableScheduling
@SpringBootApplication
public class Application {
    public static void main(String[] args) {
        SpringApplication.run(Application.class, args);
    }
}

配置类

@Configuration
public class ScheduleConfig implements SchedulingConfigurer {
    @Autowired
    private ApplicationContext context;

    @Autowired
    private SpringScheduleService scheduleService;

    @Override
    public void configureTasks(ScheduledTaskRegistrar scheduledTaskRegistrar) {
        // 查询出所有的任务列表,这里使用的是mybatis，查询的MySQL数据库、
        List<SpringScheduledCron> workList = scheduleService.findAllWorkList();
        for (SpringScheduledCron scheduledCron : workList) {
            Class<?> clazz;
            Object task;

            try {
                // 使用反射获取Class类对象
                clazz = Class.forName(scheduledCron.getCronKey());
                // 获取spring容器中初始化的bean对象
                task  = context.getBean(clazz);
            } catch (ClassNotFoundException e) {
                throw new IllegalArgumentException("该class有误："+scheduledCron.getCronKey() + "----",e);
            }
         
            // 所有定时任务类在微服务启动的时候，就会被自动注册到Spring的定时任务里
             // 动态改变执行周期
            scheduledTaskRegistrar.addTriggerTask((Runnable) task,triggerContext -> {
                // 获取定时任务表达式,执行时间
                String cronExpression = scheduleService.findByCronKey(scheduledCron.getCronKey()).getCronExpression();
                return new CronTrigger(cronExpression).nextExecutionTime(triggerContext);
            });
        }

    }

    // 开启线程池，去处理多个定时任务
    @Bean
    public Executor taskExecutor() {
        return Executors.newScheduledThreadPool(10);
    }
}

任务类

@Component
public class DynamicTask implements Runnable {
    private Logger logger =  LoggerFactory.getLogger(getClass());
    private int i;

    @Override
    public void run() {
        logger.info("Task---线程 id :{}, 任务执行 ：{}",Thread.currentThread().getId(),++i);
    }
}