精华内容
下载资源
问答
  • spring定时任务详解(@Scheduled注解)

    万次阅读 多人点赞 2016-07-07 17:09:36
    在springMVC里使用spring的定时任务非常的简单,如下: (一)在xml里加入task的命名空间 xmlns:task="http://www.springframework.org/schema/task" ...

    在springMVC里使用spring的定时任务非常的简单,如下:

    (一)在xml里加入task的命名空间

    xmlns:task="http://www.springframework.org/schema/task" 
    http://www.springframework.org/schema/task http://www.springframework.org/schema/task/spring-task-4.1.xsd

    (二)启用注解驱动的定时任务

    <task:annotation-driven scheduler="myScheduler"/> 
    

    (三)配置定时任务的线程池

    推荐配置线程池,若不配置多任务下会有问题。后面会详细说明单线程的问题。

    <task:scheduler id="myScheduler" pool-size="5"/>

    (四)写我们的定时任务

    @Scheduled注解为定时任务,cron表达式里写执行的时机

    package com.mvc.task.impl;
    import java.text.DateFormat;
    import java.text.SimpleDateFormat;
    import java.util.concurrent.TimeUnit;
    import org.joda.time.DateTime;
    import org.springframework.scheduling.annotation.Scheduled;
    import org.springframework.stereotype.Component;
    import com.mvc.task.IATask;
    @Component
    public class ATask implements IATask{
           @Scheduled(cron="0/10 * *  * * ? ")   //每10秒执行一次    
           @Override    
           public void aTask(){    
                try {
                    TimeUnit.SECONDS.sleep(20);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                DateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");  
                System.out.println(sdf.format(DateTime.now().toDate())+"*********A任务每10秒执行一次进入测试");    
           }    
    }  
    package com.mvc.task.impl;
    import java.text.DateFormat;
    import java.text.SimpleDateFormat;
    import org.joda.time.DateTime;
    import org.springframework.scheduling.annotation.Scheduled;
    import org.springframework.stereotype.Component;
    import com.mvc.task.IBTask;
    @Component
    public class BTask implements IBTask{
    	   @Scheduled(cron="0/5 * *  * * ? ")   //每5秒执行一次    
    	   @Override 
    	   public void bTask(){   
    		     DateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");  
    	         System.out.println(sdf.format(DateTime.now().toDate())+"*********B任务每5秒执行一次进入测试");    
    	   }    
    }

    spring的定时任务默认是单线程多个任务执行起来时间会有问题(B任务会因为A任务执行起来需要20S而被延后20S执行),如下图所示:



    当我们配置了线程池后再来看结果(多线程下,B任务再也不会因为A任务执行起来要20S而被延后了):

    cron表达式详解:    

    一个cron表达式有至少6个(也可能7个)有空格分隔的时间元素。

           按顺序依次为
          1  秒(0~59)
          2  分钟(0~59)
          3 小时(0~23)
          4  天(0~31)
          5 月(0~11)
          6  星期(1~7 1=SUN 或 SUN,MON,TUE,WED,THU,FRI,SAT)
          7.年份(1970-2099)
          其中每个元素可以是一个值(如6),一个连续区间(9-12),一个间隔时间(8-18/4)(/表示每隔4小时),一个列表(1,3,5),通配符。由于"月份中的日期"和"星期中的日期"这两个元素互斥的,必须要对其中一个设置?.
           0 0 10,14,16 * * ? 每天上午10点,下午2点,4点
           0 0/30 9-17 * * ?   朝九晚五工作时间内每半小时
           0 0 12 ? * WED 表示每个星期三中午12点
           "0 0 12 * * ?" 每天中午12点触发
           "0 15 10 ? * *" 每天上午10:15触发
           "0 15 10 * * ?" 每天上午10:15触发
           "0 15 10 * * ? *" 每天上午10:15触发
           "0 15 10 * * ? 2005" 2005年的每天上午10:15触发
           "0 * 14 * * ?" 在每天下午2点到下午2:59期间的每1分钟触发
           "0 0/5 14 * * ?" 在每天下午2点到下午2:55期间的每5分钟触发
           "0 0/5 14,18 * * ?" 在每天下午2点到2:55期间和下午6点到6:55期间的每5分钟触发
           "0 0-5 14 * * ?" 在每天下午2点到下午2:05期间的每1分钟触发
           "0 10,44 14 ? 3 WED" 每年三月的星期三的下午2:10和2:44触发
           "0 15 10 ? * MON-FRI" 周一至周五的上午10:15触发
           "0 15 10 15 * ?" 每月15日上午10:15触发
           "0 15 10 L * ?" 每月最后一日的上午10:15触发
           "0 15 10 ? * 6L" 每月的最后一个星期五上午10:15触发
           "0 15 10 ? * 6L 2002-2005" 2002年至2005年的每月的最后一个星期五上午10:15触发
           "0 15 10 ? * 6#3" 每月的第三个星期五上午10:15触发
           有些子表达式能包含一些范围或列表
           例如:子表达式(天(星期))可以为 “MON-FRI”,“MON,WED,FRI”,“MON-WED,SAT”
           “*”字符代表所有可能的值
           “/”字符用来指定数值的增量
           例如:在子表达式(分钟)里的“0/15”表示从第0分钟开始,每15分钟
                    在子表达式(分钟)里的“3/20”表示从第3分钟开始,每20分钟(它和“3,23,43”)的含义一样
           “?”字符仅被用于天(月)和天(星期)两个子表达式,表示不指定值
           当2个子表达式其中之一被指定了值以后,为了避免冲突,需要将另一个子表达式的值设为“?”
           “L” 字符仅被用于天(月)和天(星期)两个子表达式,它是单词“last”的缩写
           如果在“L”前有具体的内容,它就具有其他的含义了。例如:“6L”表示这个月的倒数第6天
           注意:在使用“L”参数时,不要指定列表或范围,因为这会导致问题
           W 字符代表着平日(Mon-Fri),并且仅能用于日域中。它用来指定离指定日的最近的一个平日。大部分的商业处理都是基于工作周的,所以 W 字符可能是非常重要的。
           例如,日域中的 15W 意味着 "离该月15号的最近一个平日。" 假如15号是星期六,那么 trigger 会在14号(星期五)触发,因为星期四比星期一离15号更近。
           C:代表“Calendar”的意思。它的意思是计划所关联的日期,如果日期没有被关联,则相当于日历中所有日期。例如5C在日期字段中就相当于日历5日以后的第一天。1C在星期字段中相当于星期日后的第一天。
           字段   允许值   允许的特殊字符
           秒           0-59           , - * /
           分           0-59           , - * /
           小时           0-23           , - * /
           日期           1-31           , - * ? / L W C
           月份           1-12 或者 JAN-DEC           , - * /
           星期           1-7 或者 SUN-SAT           , - * ? / L C #
           年(可选)           留空, 1970-2099           , - * /

    展开全文
  • 【SpringBoot】十九、SpringBoot中实现启动任务

    万次阅读 多人点赞 2020-06-14 21:35:16
    我们在项目中会用到项目启动任务,即项目在启动的时候需要做的一些事,例如:数据初始化、获取第三方数据等等,那么如何在SpringBoot 中实现启动任务,一起来看看吧 SpringBoot 中提供了两种项目启动方案,...

    我们在项目中会用到项目启动任务,即项目在启动的时候需要做的一些事,例如:数据初始化、获取第三方数据等等,那么如何在SpringBoot 中实现启动任务,一起来看看吧

    SpringBoot 中提供了两种项目启动方案,CommandLineRunner 和 ApplicationRunner

    一、CommandLineRunner

    使用 CommandLineRunner ,需要自定义一个类区实现 CommandLineRunner 接口,例如:

    import org.springframework.boot.CommandLineRunner;
    import org.springframework.core.annotation.Order;
    import org.springframework.stereotype.Component;
    
    /**
     * 项目启动任务类
     */
    @Component
    @Order(100)
    public class StartTask implements CommandLineRunner {
    
        @Override
        public void run(String... args) throws Exception {
    
        }
    }
    

    我们首先使用 @Component 将该类注册成为 Spring 容器中的一个 Bean
    然后使用 @Order(100) 标明该启动任务的优先级,值越大,表示优先级越小
    实现 CommandLineRunner 接口,并重写 run() 方法,当项目启动时,run() 方法会被执行,run() 方法中的参数有两种传递方式
    1、在 IDEA 中传入参数传入参数
    2、将项目打包,在启动项目时,输入以下命令:

    java -jar demo-0.0.1-SNAPSHOT.jar hello world
    

    二、ApplicationRunner

    ApplicationRunner 与 CommandLineRunner 的用法基本一致,只是接收的参数不一样,可以接收 key-value 形式的参数,如下:

    import org.springframework.boot.ApplicationArguments;
    import org.springframework.boot.ApplicationRunner;
    import org.springframework.core.annotation.Order;
    import org.springframework.stereotype.Component;
    
    /**
     * 项目启动任务类
     */
    @Component
    @Order(100)
    public class StartTask implements ApplicationRunner {
    
        @Override
        public void run(ApplicationArguments args) throws Exception {
    
        }
    }
    

    关于 run 方法的参数 ApplicationArguments:

    1、args.getNonOptionArgs();可以用来获取命令行中的无key参数(和CommandLineRunner一样)
    2、args.getOptionNames();可以用来获取所有key/value形式的参数的key
    3、args.getOptionValues(key));可以根据key获取key/value 形式的参数的value
    4、args.getSourceArgs(); 则表示获取命令行中的所有参数

    传参方式:
    1、在 IDEA 中传入参数传入参数
    2、将项目打包,在启动项目时,输入以下命令:

    java -jar demo-0.0.1-SNAPSHOT.jar hello world --name=xiaoming
    

    以上就是在 SpringBoot 中实现项目启动任务的两种方式,用法基本一致,主要体现在传参的不同上

    如您在阅读中发现不足,欢迎留言!!!

    展开全文
  • 定时任务任务名称,cron(定时任务表达式),定时任务开关,存储在数据库表中。在不重启项目的情况下,修改定时任务表达式,可以实时获取新的定时任务执行时间规则;修改定时任务执行状态,可以随时开关定时任务。...

    业务场景描述:

    定时任务的任务名称,cron(定时任务表达式),定时任务开关,存储在数据库表中。在不重启项目的情况下,修改定时任务表达式,可以实时获取新的定时任务执行时间规则;修改定时任务执行状态,可以随时开关定时任务。

    使用技术:基于接口  SchedulingConfigurer

    1、建表 管理定时任务

    DROP TABLE IF EXISTS `scheduled`;
    CREATE TABLE `scheduled` (
      `name` varchar(20) DEFAULT NULL,
      `cron` varchar(30) DEFAULT NULL,
      `open` tinyint(1) DEFAULT NULL COMMENT '1开启, 其他为关闭'
    ) ENGINE=InnoDB DEFAULT CHARSET=utf8;
    
    -- ----------------------------
    -- Records of scheduled
    -- ----------------------------
    INSERT INTO `scheduled` VALUES ('demo1', '0/5 * * * * ?', '1');
    INSERT INTO `scheduled` VALUES ('demo2', '0/6 * * * * ?', '1');

    2、代码实现

    定时任务配置类:

    package com.example.demo.scheduled;
    
    import com.google.common.util.concurrent.ThreadFactoryBuilder;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.scheduling.annotation.EnableScheduling;
    import org.springframework.scheduling.annotation.SchedulingConfigurer;
    import org.springframework.scheduling.config.ScheduledTaskRegistrar;
    import org.springframework.scheduling.support.CronTrigger;
    import java.util.concurrent.Executor;
    import java.util.concurrent.Executors;
    import java.util.concurrent.ThreadFactory;
    
    /**
     * @Description: 基于接口SchedulingConfigurer的动态定时任务
     * @Author: 
     * @Date: 2020-08-27
     */
    @Configuration
    @EnableScheduling
    public abstract class ConfigurerSchedulingDemo implements SchedulingConfigurer {
    
        //定时任务周期表达式
        private String cron;
        /** 
         * @Description:  重写配置定时任务的方法
         * @param: scheduledTaskRegistrar 
         * @return: void 
         * @Author: 
         * @Date: 2020/8/28
         */
        @Override
        public void configureTasks(ScheduledTaskRegistrar scheduledTaskRegistrar) {
            scheduledTaskRegistrar.setScheduler(taskScheduler());
            scheduledTaskRegistrar.addTriggerTask(
                    //执行定时任务
                    () ->
                    {
                        taskService();
                    },
                    //设置触发器
                    triggerContext -> {
    
                       cron = getCron();//获取定时任务周期表达式
    
                        CronTrigger trigger = new CronTrigger(cron);
    
                        return trigger.nextExecutionTime(triggerContext);
                    }
            );
    
        }
    
        @Bean
        public Executor taskScheduler() {
            //设置线程名称
            ThreadFactory namedThreadFactory = new ThreadFactoryBuilder().setNameFormat("demo-pool-%d").build();
            //创建线程池
            return Executors.newScheduledThreadPool(5, namedThreadFactory);
        }
    
        /**
         * @Description: 执行定时任务
         * @param:
         * @return: void
         * @Author: 
         * @Date: 2020/8/28
         */
        public abstract void taskService();
    
        /**
         * @Description: 获取定时任务周期表达式
         * @param:
         * @return: java.lang.String
         * @Author: 
         * @Date: 2020/8/28
         */
        public abstract String getCron();
    
    }
    

    定时任务1

    package com.example.demo.scheduled;
    
    import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
    import com.example.demo.dao.CronMapper;
    import com.example.demo.entity.Scheduled;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.context.annotation.Configuration;
    
    import java.time.LocalDateTime;
    
    /**
     * @Description:
     * @Author: 
     * @Date: 2020-08-27
     */
    @Configuration
    public class TaskDemo extends ConfigurerSchedulingDemo {
    
        @Autowired      //注入mapper
        @SuppressWarnings("all")
        CronMapper cronMapper;
    
        @Override
        public void taskService() {
            Integer open = getOpen();
            if (1== open){
                System.out.println("定时任务demo1:"
                        + LocalDateTime.now()+",线程名称:"+Thread.currentThread().getName()
                        + " 线程id:"+Thread.currentThread().getId());
            }
        }
    
        @Override
        public String getCron() {
            QueryWrapper<Scheduled> queryWrapper = new QueryWrapper<>();
            queryWrapper.eq("name","demo1");
            String cron = cronMapper.selectOne(queryWrapper).getCron();
            return cron;
        }
    
        public Integer getOpen() {
            QueryWrapper<Scheduled> queryWrapper = new QueryWrapper<>();
            queryWrapper.eq("name", "demo1");
            Integer open = cronMapper.selectOne(queryWrapper).getOpen();
            return open;
        }
    
    }
    

       定时任务2

    package com.example.demo.scheduled;
    
    import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
    import com.example.demo.dao.CronMapper;
    import com.example.demo.entity.Scheduled;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.context.annotation.Configuration;
    
    import java.time.LocalDateTime;
    
    /**
     * @Description:
     * @Author: 
     * @Date: 2020-08-27
     */
    @Configuration
    public class TaskDemo1 extends ConfigurerSchedulingDemo {
    
        @Autowired      //注入mapper
        @SuppressWarnings("all")
        CronMapper cronMapper;
    
        @Override
        public void taskService() {
            Integer open = getOpen();
            if (1== open){
                System.out.println("定时任务demo2:"
                        + LocalDateTime.now()+",线程名称:"+Thread.currentThread().getName()
                        + " 线程id:"+Thread.currentThread().getId());
            }
        }
    
        @Override
        public String getCron() {
            QueryWrapper<Scheduled> queryWrapper = new QueryWrapper<>();
            queryWrapper.eq("name","demo2");
            String cron = cronMapper.selectOne(queryWrapper).getCron();
            return cron;
        }
    
        public Integer getOpen() {
            QueryWrapper<Scheduled> queryWrapper = new QueryWrapper<>();
            queryWrapper.eq("name", "demo2");
            Integer open = cronMapper.selectOne(queryWrapper).getOpen();
            return open;
        }
    }
    

    效果展示:

    启动项目:控制台输出展示

    修改数据库 demo1的执行时间为每15秒一次:

    关闭demo1的定时任务,将demo1的open状态改为0:

    展开全文
  • XXL-JOB原理--定时任务框架简介(一)

    万次阅读 多人点赞 2018-09-10 21:14:01
    之前在工作中有接触许雪里大神开源的分布式任务调度平台XXL-JOB,最近经过一段时间的源码系统学习,今天简单写一篇博客介绍一下。 相关博客: XXL-JOB原理--执行器注册(二) XXL-JOB原理--任务调度中心执行器...

    之前在工作中有接触许雪里大神开源的分布式任务调度平台XXL-JOB,最近经过一段时间的源码系统学习,今天简单写一篇博客介绍一下。

    相关博客:

    XXL-JOB原理--执行器注册(二)

    XXL-JOB原理--任务调度中心执行器注册(三)

    XXL-JOB原理--任务调度中心任务管理(四)

    XXL-JOB原理--任务执行(五)

    一、完整介绍地址:官方介绍

    二、最新版本架构图:

    三、介绍

    目前我们在项目中可能接触到定时任务框架quartz,应用也是比较广泛的,其也是支持分布式任务调度的,通过数据库竞争锁来实现,当然会有很多的局限性(可能这也是xxl-job出现的原因),quartz支持多种数据库(https://github.com/quartz-scheduler/quartz/tree/master/quartz-core/src/main/resources/org/quartz/impl/jdbcjobstore),xxl-job其实也是在quartz的基础上实现的,但是修改了任务调度的模式,并且任务调度采用注册和RPC调用方式来实现。

    管理后台:

    四、技术栈

    mysql、SSM,内置jetty作为RPC服务调用、quartz

    五、xxl-job支持Postgresql数据库

    目前由于xxl-job只支持mysql数据库,目前在github上拉了一个分支支持Postgresql 地址GitHub地址

     

    六、 xxl-job 底层依赖 quartz 实现,架构如下

     

    展开全文
  • 基于Springboot执行多个定时任务并且动态获取定时任务信息 基于Springboot执行多个定时任务并且动态获取定时任务信息 简介 说明 SpringApplication-启动类 动态获取定时任务信息 mapper service service impl ...
  • JAVA代码实现编程式提交Spark任务

    万次阅读 2020-07-29 16:54:11
    三种方法作为记录: 1)直接调用SparkSubmit的main方法 ...SparkSubmit提交任务 String[] param = { "--class", "org.apache.spark.examples.SparkPi", "--master", "local[2]", "/bigdata/spark-2.
  • Windows7执行Python定时任务

    万次阅读 2019-12-04 20:21:15
    注:Windows10类似,可添加任何你想做的事。 大致步骤: 1.开始-->搜索程序和文件-->计划任务 2.进入任务计划程序-->点击创建任务 3.在创建任务界面填写相关信息(示例): 4.OK。 ...
  • **同步任务:**指的是在主线程傻姑娘排队执行的任务,只有前一个任务执行完毕,才能执行后一个任务。 **异步任务:**指的是不进入主线程,某个异步任务可以执行了,该任务才会进入主线程执行。 异步执行的运行机制...
  • 收发文流程实现,以及流程引擎中动态增加节点|临时子流程的使用。流程引擎动态任务实现。
  • 使用Springboot整合的定时任务和异步任务处理
  • 1.1创建任务表 CREATE TABLE `scheduled_task` ( `id` int(11) NOT NULL AUTO_INCREMENT, `task_key` varchar(128) NOT NULL COMMENT '任务key值(使用bean名称)', `task_desc` varchar(128) DEFAULT NULL ...
  • Linux Crontab 查看定时任务启动没

    万次阅读 2018-01-26 16:19:25
    1、先手动执行定时任务以此来判断脚本是否有问题。2、确认服务器是否开启定时任务计划服务命令:service crond statusservice crond start3、查看crontab执行记录如果出现了crontab定时任务不执行的情况,首先需要...
  • 任务、微任务

    千次阅读 多人点赞 2018-10-10 10:58:47
    任务与微任务? B-树中含511个关键字,B-树为3阶,则包含叶子节点层该树最大深度为? 8 9 10 11
  • 事件循环 JavaScript 语言的一大特点就是单线程,也就是说,同一个时间只能做一件事。为了协调事件、用户交互、脚本、UI 渲染和网络处理等行为,防止主线程的不阻塞,Event Loop 的方案应用而生。...任务队列
  • js中微任务和宏任务的区别

    千次阅读 2019-08-15 10:38:26
    2.微任务: 当前(此次事件循环中)宏任务执行完,在下一个宏任务开始之前需要执行的任务,可以理解为回调事件。(promise.then,proness.nextTick等等)。 3. 宏任务中的事件放在callback queue中,由事件触发线程...
  • 1、在任务栏右键,取消任务栏锁定(如果之前没有锁定过跳过该步骤) 2、上下拖拽任务栏宽度到最小或者是自己满意的宽度 3、重新锁定任务栏(如果不喜欢锁定不锁定也是ok的) 在解决该问题的过程中,发现打开InteliJ...
  • RxJava实现串行任务和并行任务

    千次阅读 2019-09-16 14:53:14
    串行和并行,是针对任务这个概念而来的,也就是串行任务和并行任务。 那我们需要了解一下什么是任务。 用一个http网络请求来看,这一个网络请求就是一个任务。它包含了发送请求、后台处理、处理返回数据这几个步骤。...
  • Linux执行定时任务步骤(crontab)

    万次阅读 2019-12-04 20:50:38
    2.查看当前用户所有定时任务:crontab -l 3.进入定时任务编辑界面,终端输入指令:crontab -e 4.开始编辑,例如添加一个每分钟定时输出hello到test.txt文件的定时任务: 5.* * * * * 分别代表 分 时 日 月 周 ....
  • 任务与微任务

    千次阅读 多人点赞 2018-10-29 17:45:44
    之前写过关于事件循环机制的文章 js 的并发模型一文,当时以为已经讲清楚所有这方面的概念了,但是最近又发现,事件循环机制还有宏任务与微任务这个概念没有涉及,所以这里延续之前的文章,再继续讲一讲。
  • Windows10 任务栏网络图标消失不见的解决办法

    万次阅读 多人点赞 2018-12-27 23:06:19
    前些天,重新装了系统,在装软件的时候需求重启,重启后发现任务栏上的网络图标不见了,然后网络也连不上,进行诊断显示为错误1068:依赖服务或组无法启动,百度了网上的很多方法,也没解决,重装了很多次系统还是会...
  • windows计划任务定时任务

    千次阅读 2019-04-15 09:55:38
    windows计划任务相关: C:\Users\Administrator> schtasks /? SCHTASKS /parameter [arguments] 描述: 允许管理员创建、删除、查询、更改、运行和中止本地或远程系统上的计划任 务。 参数列表: /Create 创建...
  • FreeRTOS 任务调度 任务切换

    万次阅读 2016-10-15 17:07:34
    @(嵌入式) 简述 ...一般来说, 我们会在程序开始先创建若干个任务, 而此时任务调度器还没又开始运行,因此每一次任务创建后都会依据其优先级插入到就绪链表,同时保证全局变量 pxCurrentTCB 指向当

空空如也

空空如也

1 2 3 4 5 ... 20
收藏数 814,008
精华内容 325,603
关键字:

任务