定时任务的五种创建方式，你都会么？

客官°小女子只卖身不卖艺 2022-10-05 07:50 167阅读 0赞

![0D5F937FE12312312D81F17F.jpg][]

程序员的成长之路

互联网/程序员/技术/资料共享

[关注][Link 1]

阅读本文大概需要 6 分钟。

来自：blog.csdn.net/qq\_41463655/article/details/100839629

Quartz表达式生成地址：http://cron.qqe2.com/

支持生成定时任务表达式和反解析，使用Quartz表达式的定时任务如下

*  xxl-job
 *  springboot 的 @Scheduled
 *  Quartz 框架

## ** ** ##

## **一、job 定时任务的五种创建方式** ##

1、使用线程创建 job 定时任务

/**
      * TODO  使用线程创建 job 定时任务
      * @author 王松
      */
    public class JobThread {
    
        public static class Demo01 {
            static long count = 0;
    
            public static void main(String[] args) {
                Runnable runnable = new Runnable() {
                    @Override
                    public void run() {
                        while (true) {
                            try {
                                Thread.sleep(1000);
                                count++;
                                System.out.println(count);
                            } catch (Exception e) {
                                // TODO: handle exception
                            }
                        }
                    }
                };
                Thread thread = new Thread(runnable);
                thread.start();
            }
        }
    }

2、使用 TimerTask 创建job定时任务

/**
     * TODO  使用 TimerTask 创建job定时任务
     * @author 王松
     */
    public class JobTimerTask {
    
        static long count = 0;
        public static void main(String[] args) {
            TimerTask timerTask = new TimerTask() {
                @Override
                public void run() {
                    count++;
                    System.out.println(count);
                }
            };
            //创建timer对象设置间隔时间
            Timer timer = new Timer();
            // 间隔天数
            long delay = 0;
            // 间隔毫秒数
            long period = 1000;
            timer.scheduleAtFixedRate(timerTask, delay, period);
        }
    }

3、使用线程池创建 job定时任务

/**
      * TODO  使用线程池创建 job定时任务
      * @author 王松
      */
    public class JobScheduledExecutorService {
            public static void main(String[] args) {
                Runnable runnable = new Runnable() {
                    @Override
                    public void run() {
                        // task to run goes here
                        System.out.println("Hello !!");
                    }
                };
                ScheduledExecutorService service = Executors.newSingleThreadScheduledExecutor();
                // 第二个参数为首次执行的延时时间，第三个参数为定时执行的间隔时间
                service.scheduleAtFixedRate(runnable, 1, 1, TimeUnit.SECONDS);
            }
    }

4.Quartz 框架

1.引入maven依赖

<dependencies>
     
     <dependency>
      <groupId>org.quartz-scheduler</groupId>
      <artifactId>quartz</artifactId>
      <version>2.2.1</version>
     </dependency>
     <dependency>
      <groupId>org.quartz-scheduler</groupId>
      <artifactId>quartz-jobs</artifactId>
      <version>2.2.1</version>
     </dependency>
    </dependencies>

2.任务调度类

public class MyJob implements Job {
    
        @Override
        public void execute(JobExecutionContext context) throws JobExecutionException {
            System.out.println("quartz MyJob date:" + System.currentTimeMillis());
        }
    }

3.启动类

public class JobQuartz {
    
        public static void main(String[] args) throws SchedulerException {
            //1.创建Scheduler的工厂
            SchedulerFactory sf = new StdSchedulerFactory();
            //2.从工厂中获取调度器实例
            Scheduler scheduler = sf.getScheduler();
            //3.创建JobDetail，
            JobDetail jb = JobBuilder.newJob(MyJob.class)
                    //job的描述
                    .withDescription("this is a ram job")
                    //job 的name和group
                    .withIdentity("ramJob", "ramGroup")
                    .build();
            //任务运行的时间，SimpleSchedle类型触发器有效，3秒后启动任务
            long time=  System.currentTimeMillis() + 3*1000L;
            Date statTime = new Date(time);
            //4.创建Trigger
            //使用SimpleScheduleBuilder或者CronScheduleBuilder
            Trigger t = TriggerBuilder.newTrigger()
                    .withDescription("")
                    .withIdentity("ramTrigger", "ramTriggerGroup")
                    //.withSchedule(SimpleScheduleBuilder.simpleSchedule())
                    //默认当前时间启动
                    .startAt(statTime)
                    //两秒执行一次，Quartz表达式，支持各种牛逼表达式
                    .withSchedule(CronScheduleBuilder.cronSchedule("0/2 * * * * ?"))
                    .build();
            //5.注册任务和定时器
            scheduler.scheduleJob(jb, t);
            //6.启动 调度器
            scheduler.start();
        }

5. springboot 的 @Scheduled 注解

@Component
    @Configuration      //1.主要用于标记配置类，兼备Component的效果。
    @EnableScheduling   // 2.开启定时任务
    public class SaticScheduleTask {
    
        @Scheduled(cron = "0/5 * * * * ?")  //3.添加定时任务
        //@Scheduled(fixedRate=5000)        //或直接指定时间间隔，例如：5秒
        private void configureTasks() {
            System.err.println("执行静态定时任务时间: " + LocalDateTime.now());
        }
    }

## ** ** ##

## **二、xxl-job 任务调度后台 Admin** ##

xxl-job 有什么用？

*  分布式集群的情况下，保证定时任务不被重复执行。
 *  执行原理同Nginx 类型，所有定时任务通过任务调度平台分发，也可配置负载均衡等等
 *  首先让我们能够使用起来，搭建一个自己的任务

第一步: github下载源码导入

下载地址：https://github.com/xuxueli/xxl-job/

当前版本目录结构 2.1.1

![32b299e584a47827ec6c69a890869882.png][]

图片

第二步: 执行sql

文件地址：xxl-job/doc/db/tables\_xxl\_job.sql

当前2.1.1版本sql

![4a320a6adf83fa361ff8441d2657dad5.png][]

图片

第三步: 修改xxl-job-admin项目配置

配置文件：application.properties

修改数据库连接

![aa886050bdba7eccd2079ee1c7004043.png][]

图片

第四步: 启动admin项目

springboot 方式启动项目，

![6633623e34e400961709f13d13b45222.png][]

图片

访问 http://localhost:8080/xxl-job-admin/

账号密码：admin / 123456

![568a69e823548750e6598f23bd2ff54e.png][]

图片

任务调度中心就搭建好了

接下来需要创建一个服务器连接任务调度中心

## ** ** ##

## **三、自创建boot项目的任务xxl-job 示例demo** ##

创建一个 boot 项目

我的目录结构

![72b7d7f73a62eca832de36e1c6dea8bf.png][]

图片

pom.xml

web核心及 xxl-job-core

<dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-test</artifactId>
        <scope>test</scope>
    </dependency>
    
    
    <dependency>
        <groupId>com.xuxueli</groupId>
        <artifactId>xxl-job-core</artifactId>
        <version>2.1.1-SNAPSHOT</version>
    </dependency>

logback.xml

日志配置直接拷贝

<?xml version="1.0" encoding="UTF-8"?>
    <configuration debug="false" scan="true" scanPeriod="1 seconds">
    
        <contextName>logback</contextName>
        <property name="log.path" value="/data/applogs/xxl-job/xxl-job-executor-sample-springboot.log"/>
    
        <appender name="console" class="ch.qos.logback.core.ConsoleAppender">
            <encoder>
                <pattern>%d{HH:mm:ss.SSS} %contextName [%thread] %-5level %logger{36} - %msg%n</pattern>
            </encoder>
        </appender>
    
        <appender name="file" class="ch.qos.logback.core.rolling.RollingFileAppender">
            <file>${log.path}</file>
            <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
                <fileNamePattern>${log.path}.%d{yyyy-MM-dd}.zip</fileNamePattern>
            </rollingPolicy>
            <encoder>
                <pattern>%date %level [%thread] %logger{36} [%file : %line] %msg%n
                </pattern>
            </encoder>
        </appender>
    
        <root level="info">
            <appender-ref ref="console"/>
            <appender-ref ref="file"/>
        </root>
    
    </configuration>

application.properties 加入配置

需修改或自定义

*  xxl-job admin 地址
 *  xxl.job.executor.appname 自定义名称，后台配置必须对应
 *  xxl.job.executor.ip 当前电脑Ip，或部署项目的电脑Ip
 *  xxl.job.executor.port 端口

# 端口号
    server.port=8081
    # 日志
    logging.config=classpath:logback.xml
    
    ## xxl-job admin 地址，多个逗号分隔"
    xxl.job.admin.addresses=http://127.0.0.1:8080/xxl-job-admin
    
    ## xxl-job名称 || socket ip 当前项目部署的ip地址/本机ip || socket 端口号
    xxl.job.executor.appname=xxl-job-executor-sample
    xxl.job.executor.ip=192.168.43.153
    xxl.job.executor.port=9999
    
    ## xxl-job, access token
    xxl.job.accessToken=
    ## xxl-job log path
    xxl.job.executor.logpath=/data/applogs/xxl-job/jobhandler
    ## xxl-job log retention days
    xxl.job.executor.logretentiondays=-1

添加boot配置类 XxlJobConfig

package xxljob.config;
    import com.xxl.job.core.executor.impl.XxlJobSpringExecutor;
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    import org.springframework.beans.factory.annotation.Value;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    
    /**
     * xxl-job xxljob.config
     */
    @SuppressWarnings("ALL")
    @Configuration
    public 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 xxljob.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);
            System.err.println(ip+":"+port);
            return xxlJobSpringExecutor;
        }
    
        /**
         * 针对多网卡、容器内部署等情况，可借助 "spring-cloud-commons" 提供的 "InetUtils" 组件灵活定制注册IP；
         *
         *      1、引入依赖：
         *          <dependency>
         *             <groupId>org.springframework.cloud</groupId>
         *             <artifactId>spring-cloud-commons</artifactId>
         *             <version>${version}</version>
         *         </dependency>
         *
         *      2、配置文件，或者容器启动变量
         *          spring.cloud.inetutils.preferred-networks: 'xxx.xxx.xxx.'
         *
         *      3、获取IP
         *          String ip_ = inetUtils.findFirstNonLoopbackHostInfo().getIpAddress();
         */
    }

任务job

@JobHandler(value="demoJobHandler")
    @Component
    public class DemoJobHandler extends IJobHandler {
    
         static int count;
        @Override
        public ReturnT<String> execute(String param) throws Exception {
            System.out.println("执行job任务"+count++);
            return SUCCESS;
        }
    }

admin 后台配置

执行管理器下

![bc4b0ccb5ea59ed10bacd4ce6d62f260.png][]

图片

任务管理下编辑任务

定时规则生成：http://cron.qqe2.com/

job任务名：@JobHandler注解值 >> 如:`@JobHandler(value=“demoJobHandler”)`

![0be1ed5e90fdca35684394a2b47d16e2.png][]

图片

启动

![56b57e2ec9a443be0fc98f4d220b1ca5.png][]

图片

这样就配置完成了

![dc1b8234d01a9b3a59543882f8e20b11.png][]

图片

完成。

<END>

**推荐阅读：**

[这是你想要的工作吗？灵隐寺招聘：没有KPI，佛系上班……][KPI]

[强烈不建议你用 a.equals(b) 判断对象相等！][a.equals_b_]

最近面试BAT，整理一份面试资料《Java面试BATJ通关手册》，覆盖了Java核心技术、JVM、Java并发、SSM、微服务、数据库、数据结构等等。

**获取方式：点个「****在看****」，点击上方小卡片，进入公众号后回复「****面试题****」领取，更多内容陆续奉上。**

朕已阅 ![177db3c5fa4c61685205f0fe269e4e5d.gif][]

[0D5F937FE12312312D81F17F.jpg]: /images/20221005/5bc0594f6fe84ea1a0640de640a21536.png
[Link 1]: https://mp.weixin.qq.com/s?__biz=MzUyNDkzNzczNQ%3D%3D&chksm=fa24f0bacd5379ac93d74ffebac826d2401fd494f82e900e5102a8bf968f108e4ec72a4ad548&idx=3&lang=zh_CN&mid=2247487442&scene=21&sn=61e758d4bf9f15a3419fd028146469a3&token=1854383306#wechat_redirect
[32b299e584a47827ec6c69a890869882.png]: /images/20221005/b10ce0a941f642b4ba4180f34e89ae65.png
[4a320a6adf83fa361ff8441d2657dad5.png]: /images/20221005/6a2a774c82cb498190bdf036bc51efa5.png
[aa886050bdba7eccd2079ee1c7004043.png]: /images/20221005/3a1cb0e3737e454ab44f2bb70db20811.png
[6633623e34e400961709f13d13b45222.png]: /images/20221005/7326a8cc55034eb898a1368abdd83668.png
[568a69e823548750e6598f23bd2ff54e.png]: /images/20221005/4bcd434d89364694b38b045937987ea6.png
[72b7d7f73a62eca832de36e1c6dea8bf.png]: /images/20221005/15eb3bb46fa840f88b4e8401704de440.png
[bc4b0ccb5ea59ed10bacd4ce6d62f260.png]: /images/20221005/1da93b255562468d83e91592830fc0e3.png
[0be1ed5e90fdca35684394a2b47d16e2.png]: /images/20221005/ce6d5ffac5f74effa4a8b7f73f8d924f.png
[56b57e2ec9a443be0fc98f4d220b1ca5.png]: /images/20221005/3c82c7a581254066aa543bdbf2355c37.png
[dc1b8234d01a9b3a59543882f8e20b11.png]: /images/20221005/73bdd7a56a82465ebdd5c5bdc644ad91.png
[KPI]: http://mp.weixin.qq.com/s?__biz=MzUyNDkzNzczNQ%3D%3D&chksm=fa275f49cd50d65f8acb68ab760cedf2783057a8e97fe0229c66617ef030ad19ecdb48bca91a&idx=1&mid=2247508001&scene=21&sn=6067140b9446986194b35acd2baf1d0e#wechat_redirect
[a.equals_b_]: http://mp.weixin.qq.com/s?__biz=MzUyNDkzNzczNQ%3D%3D&chksm=fa275f49cd50d65f0989e9d7b948392c3275b76dcd6d9769b5e520806d32c03e2722bc777f6b&idx=2&mid=2247508001&scene=21&sn=3375161f5d689373259a878d9b52a404#wechat_redirect
[177db3c5fa4c61685205f0fe269e4e5d.gif]: /images/20221005/71fb08bec18744fc99cb381d46b8478b.png