Java之定时任务全家桶

@Componentpublic class ScheduleTask {    private Logger logger = LoggerFactory.getLogger(ScheduleTask.class);    @Scheduled(cron = "0/1 * * * * ? ")    public void one() {        logger.info("one:" + new Date());    }    @Scheduled(cron = "0/1 * * * * ? ")    public void two() {        logger.info("two:" + new Date());    }    @Scheduled(cron = "0/1 * * * * ? ")    public void three() {        logger.info("three:" + new Date());    }}

@PropertySource(value = {        "classpath:task.properties",}, encoding = "utf-8")@Component("scheduleTask")public class ScheduleTask implements SchedulingConfigurer {    @Value("${TEST_JOB_TASK_CRON}")    private String cron;    @Override    public void configureTasks(ScheduledTaskRegistrar scheduledTaskRegistrar) {        scheduledTaskRegistrar.addTriggerTask(new Runnable() {            @Override            public void run() {                System.out.println("执行任务:" + DateUtil.date());            }        }, new Trigger() {            @Override            public Date nextExecutionTime(TriggerContext triggerContext) {                return new CronTrigger(cron).nextExecutionTime(triggerContext);            }        });    }    public void setCron(String cron) {        this.cron = cron;    }}

@Configurationpublic class ScheduleConfig implements SchedulingConfigurer {    public void configureTasks(ScheduledTaskRegistrar scheduledTaskRegistrar) {        scheduledTaskRegistrar.setScheduler(Executors.newScheduledThreadPool(5));    }}

@Component@EnableAsyncpublic class ScheduleAsyncTask {    private Logger logger = LoggerFactory.getLogger(ScheduleAsyncTask.class);    @Scheduled(cron = "0/1 * * * * ? ")    @Async    public void one() {        logger.info("one Async:" + new Date());    }    @Scheduled(cron = "0/1 * * * * ? ")    @Async    public void two() {        logger.info("two Async:" + new Date());    }    @Scheduled(cron = "0/1 * * * * ? ")    @Async    public void three() {        logger.info("three Async:" + new Date());    }}

@Configurationpublic class DynamicScheduleTask implements SchedulingConfigurer {    @Autowired    @SuppressWarnings("all")    CronMapper cronMapper;    @Mapper    public interface CronMapper {        @Select("select cron from cron limit 1")        public String getCron();    }    /**     * 执行定时任务.     */    public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {        taskRegistrar.addTriggerTask(                //1.添加任务内容(Runnable)                () -> System.out.println("执行动态定时任务: " + LocalDateTime.now().toLocalTime()),                //2.设置执行周期(Trigger)                triggerContext -> {                    //2.1 从数据库获取执行周期                    String cron = cronMapper.getCron();                    //2.2 合法性校验.                    if (StringUtils.isEmpty(cron)) {                        // Omitted Code ..                    }                    //2.3 返回执行周期(Date)                    return new CronTrigger(cron).nextExecutionTime(triggerContext);                }        );    }}

spring:  datasource:    url: jdbc:mysql://127.0.0.1:3306/test    username: root    password: 1234

DROP DATABASE IF EXISTS `test`;CREATE DATABASE `test`;USE `test`;DROP TABLE IF EXISTS `cron`;CREATE TABLE `cron`  (  `cron_id` varchar(30) NOT NULL PRIMARY KEY,  `cron` varchar(30) NOT NULL  );INSERT INTO `cron` VALUES ('1', '0/5 * * * * ?');

<!--引入quartz定时框架--><dependency>    <groupId>org.springframework.boot</groupId>    <artifactId>spring-boot-starter-quartz</artifactId></dependency>

spring:  quartz:    #相关属性配置    properties:      org:        quartz:          scheduler:            instanceName: clusteredScheduler            instanceId: AUTO          jobStore:            class: org.quartz.impl.jdbcjobstore.JobStoreTX            driverDelegateClass: org.quartz.impl.jdbcjobstore.StdJDBCDelegate            tablePrefix: QRTZ_            isClustered: true            clusterCheckinInterval: 10000            useProperties: false          threadPool:            class: org.quartz.simpl.SimpleThreadPool            threadCount: 10            threadPriority: 5            threadsInheritContextClassLoaderOfInitializingThread: true    #数据库方式    job-store-type: jdbc    #初始化表结构    jdbc:      initialize-schema: always  datasource:    url: jdbc:mysql://127.0.0.1:3306/test    username: root    password: 1234

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

@Configurationpublic class QuartzConfiguration {    // 使用jobDetail包装job    @Bean    public JobDetail myCronJobDetail() {        return JobBuilder.newJob(CouponTimeOutJob.class).withIdentity("couponTimeOutJob").storeDurably().build();    }    // 把jobDetail注册到Cron表达式的trigger上去    @Bean    public Trigger CronJobTrigger() {        CronScheduleBuilder cronScheduleBuilder = CronScheduleBuilder.cronSchedule("0/1 * * * * ?");        return TriggerBuilder.newTrigger()                .forJob(myCronJobDetail())                .withIdentity("CouponTimeOutJobTrigger")                .withSchedule(cronScheduleBuilder)                .build();    }}

public class CouponTimeOutJob extends QuartzJobBean {    @Override    protected void executeInternal(JobExecutionContext jobExecutionContext) throws JobExecutionException {        System.out.println("定时任务执行");    }}

<dependency>    <groupId>com.xuxueli</groupId>    <artifactId>xxl-job-core</artifactId>    <version>2.2.0</version></dependency>

@Configurationpublic class XxlJobConfig {    private Logger logger = LoggerFactory.getLogger(XxlJobConfig.class);    @Value("${xxl.job.admin.addresses}")    private String adminAddresses;    @Value("${xxl.job.executor.appname}")    private String appName;    @Value("${xxl.job.executor.ip}")    private String ip;    @Value("${xxl.job.executor.port}")    private int port;    @Value("${xxl.job.accessToken}")    private String accessToken;    @Value("${xxl.job.executor.logpath}")    private String logPath;    @Value("${xxl.job.executor.logretentiondays}")    private int logRetentionDays;    @Bean(initMethod = "start", destroyMethod = "destroy")    public XxlJobSpringExecutor xxlJobExecutor() {        logger.info(">>>>>>>>>>> xxl-job config init.");        XxlJobSpringExecutor xxlJobSpringExecutor = new XxlJobSpringExecutor();        xxlJobSpringExecutor.setAdminAddresses(adminAddresses);        xxlJobSpringExecutor.setAppname(appName);        xxlJobSpringExecutor.setIp(ip);        xxlJobSpringExecutor.setPort(port);        xxlJobSpringExecutor.setAccessToken(accessToken);        xxlJobSpringExecutor.setLogPath(logPath);        xxlJobSpringExecutor.setLogRetentionDays(logRetentionDays);        return xxlJobSpringExecutor;    }}

# web portserver.port=8081# no web#spring.main.web-environment=false### xxl-job admin address list, such as "http://address" or "http://address01,http://address02"xxl.job.admin.addresses=http://127.0.0.1:8080/xxl-job-admin### xxl-job, access tokenxxl.job.accessToken=### xxl-job executor appnamexxl.job.executor.appname=blog-job-xxl-job### xxl-job executor registry-address: default use address to registry , otherwise use ip:port if address is nullxxl.job.executor.address=### xxl-job executor server-infoxxl.job.executor.ip=xxl.job.executor.port=8888### xxl-job executor log-pathxxl.job.executor.logpath=/data/applogs/xxl-job/jobhandler### xxl-job executor log-retention-daysxxl.job.executor.logretentiondays=30

@Componentpublic class XxlJobTaskExample {    @XxlJob("blogJobHandler")    public ReturnT<String> blogJobHandler(String param) throws Exception {        System.out.println("执行");        XxlJobLogger.log("XXL-JOB, Hello World.");        for (int i = 0; i < 5; i++) {            XxlJobLogger.log("beat at:" + i);            TimeUnit.SECONDS.sleep(2);        }        return ReturnT.SUCCESS;    }}

<!-- 分布式定时任务锁 -->   <!-- https://mvnrepository.com/artifact/net.javacrumbs.shedlock/shedlock-spring -->   <dependency>       <groupId>net.javacrumbs.shedlock</groupId>       <artifactId>shedlock-spring</artifactId>       <version>4.0.4</version>   </dependency>   <!-- 使用redis做分布式任务 -->   <dependency>       <groupId>net.javacrumbs.shedlock</groupId>       <artifactId>shedlock-provider-redis-spring</artifactId>       <version>2.5.0</version>   </dependency>   <!-- redis组件 -->   <dependency>       <groupId>org.springframework.boot</groupId>       <artifactId>spring-boot-starter-data-redis</artifactId>   </dependency>

@Configuration@EnableSchedulerLock(defaultLockAtMostFor = "PT30M")public class ShedLockConfig {    @Bean    public LockProvider lockProvider(RedisTemplate redisTemplate) {        return new RedisLockProvider(redisTemplate.getConnectionFactory());    }}

@Componentpublic class TaskSchedule {    /**     * 每分钟执行一次     * [秒] [分] [小时] [日] [月] [周] [年]     */    @Scheduled(cron = "1 * * * * ?")    @SchedulerLock(name = "synchronousSchedule")    public void SynchronousSchedule() {        System.out.println("Start run schedule to synchronous data:" + new Date());    }}

@SpringBootApplication@EnableSchedulingpublic class ShedLockRedisApplication {    public static void main(String[] args) {        SpringApplication.run(ShedLockRedisApplication.class);    }}

server:  tomcat:    uri-encoding: UTF-8    max-threads: 1000    min-spare-threads: 30  port: 8083spring:  redis:    database: 0    host: localhost    port: 6379    password:      # 密码（默认为空）    timeout: 6000ms  # 连接超时时长（毫秒）    jedis:      pool:        max-active: 1000  # 连接池最大连接数（使用负值表示没有限制）        max-wait: -1ms      # 连接池最大阻塞等待时间（使用负值表示没有限制）        max-idle: 10      # 连接池中的最大空闲连接        min-idle: 5       # 连接池中的最小空闲连接

https://github.com/developers-youcong/blog-job

source: https://developers-youcong.github.io/2020/11/21/Java之定时任务全家桶/