草庐IT

定时任务

loongnuts 2023-04-19 原文

定时任务

文档

1.实现方案

1、Timer

2、线程池

3、mq的延时队列

4、QUARTZ

1.搭配cron表达式使用
2.支持年,spring不支持年
3.在周几的位置,quartz的周1是2,spring的周1是1
4.


spring框架的定时任务

springboot默认定时任务框架不是QUARTZ,如果需要使用引入即可		


2.cron表达式

1.语法

语法:秒 分 时 日 月 周 年 (spring 不支持年,所以可以不写)
http://www.quartz-scheduler.org/documentation/quartz-2.3.0/tutorials/crontrigger.html

A cron expression is a string comprised of 6 or 7 fields separated by white space. Fields can contain any of the allowed values, along with various combinations of the allowed special characters for that field. The fields are as follows:

Field Name	Mandatory	Allowed Values		Allowed Special Characters
Seconds			YES		0-59				, - * /
Minutes			YES		0-59				, - * /
Hours			YES		0-23				, - * /
Day of month	YES		1-31				, - * ? / L W
Month			YES		1-12 or JAN-DEC		, - * /
Day of week		YES		1-7 or SUN-SAT		, - * ? / L #
                        1:周末 7:周一
Year			NO		empty, 1970-2099	, - * /

特殊字符:
,:枚举;
(cron="7,9,23****?"):任意时刻的7,9,23秒启动这个任务;
-:范围:
(cron="7-20****?""):任意时刻的7-20秒之间,每秒启动一次
*:任意;
指定位置的任意时刻都可以
/:步长;
(cron="7/5****?"):第7秒启动,每5秒一次;
(cron="*/5****?"):任意秒启动,每5秒一次;

?:(出现在日和周几的位置):为了防止日和周冲突,在周和日上如果要写通配符使用?
(cron="***1*?"):每月的1号,而且必须是周二然后启动这个任务;

L:(出现在日和周的位置)”,
last:最后一个
(cron="***?*3L"):每月的最后一个周二(1:周末 2:周一 3:周二 4:周三 5:周四 6:周五 7:周六)

W:Work Day:工作日
(cron="***W*?"):每个月的工作日触发
(cron="***LW*?"):每个月的最后一个工作日触发
#:第几个
(cron="***?*5#2"):每个月的 第2个周4

2.在线Cron表达式生成器

3.cron示例

常用cron表达式例子
  (1)0/2 * * * * ?   表示每2秒 执行任务
  (1)0 0/2 * * * ?    表示每2分钟 执行任务
  (1)0 0 2 1 * ?   表示在每月的1日的凌晨2点调整任务
  (2)0 15 10 ? * MON-FRI   表示周一到周五每天上午10:15执行作业
  (3)0 15 10 ? 6L 2002-2006   表示2002-2006年的每个月的最后一个星期五上午10:15执行作
  (4)0 0 10,14,16 * * ?   每天上午10点,下午2点,4点 
  (5)0 0/30 9-17 * * ?   朝九晚五工作时间内每半小时 
  (6)0 0 12 ? * WED    表示每个星期三中午12点 
  (7)0 0 12 * * ?   每天中午12点触发 
  (8)0 15 10 ? * *    每天上午10:15触发 
  (9)0 15 10 * * ?     每天上午10:15触发 
  (10)0 15 10 * * ?    每天上午10:15触发 
  (11)0 15 10 * * ? 2005    2005年的每天上午10:15触发 
  (12)0 * 14 * * ?     在每天下午2点到下午2:59期间的每1分钟触发 
  (13)0 0/5 14 * * ?    在每天下午2点到下午2:55期间的每5分钟触发 
  (14)0 0/5 14,18 * * ?     在每天下午2点到2:55期间和下午6点到6:55期间的每5分钟触发 
   (15)0 0-5 14 * * ?    在每天下午2点到下午2:05期间的每1分钟触发 
  (16)0 10,44 14 ? 3 WED    每年三月的星期三的下午2:10和2:44触发 
  (17)0 15 10 ? * MON-FRI    周一至周五的上午10:15触发 
  (18)0 15 10 15 * ?    每月15日上午10:15触发 
  (19)0 15 10 L * ?    每月最后一日的上午10:15触发 
  (20)0 15 10 ? * 6L    每月的最后一个星期五上午10:15触发 
  (21)0 15 10 ? * 6L 2002-2005   2002年至2005年的每月的最后一个星期五上午10:15触发 
  (22)0 15 10 ? * 6#3   每月的第三个星期五上午10:15触发

3.SpringBoot整合

开启定时任务

整合步骤:
1.@EnableScheduling【spring 默认是使用自己的定时任务,如果想整合Quartz,参考官方】
2.@Scheduled
3.定时任务配置类:TaskSchedulingAutoConfiguration
package com.atguigu.gulimall.seckill.scheduled;

import lombok.extern.slf4j.Slf4j;
import org.springframework.scheduling.annotation.Async;
import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

/**
 * 定时任务
 *      @EnableScheduling 开启定时任务
 *      @Scheduled 开启一个定时任务
 *      自动配置类 TaskSchedulingAutoConfiguration
 *
 *  异步任务
 *      @EnableAsync 开启异步任务
 *      @Async 给希望异步执行的方法上标注
 *      自动配置类:TaskExecutionAutoConfiguration 属性 TaskExecutionProperties
 */
@Component
@EnableScheduling
@Slf4j
@EnableAsync
public class HelloSchedule {
    /**
     * 1、Spring中6位组成,不允许第7位的年
     * 2、在周几的位置:1-7代表周一到周日;Mon-SUN
     * 3、定时任务不应该阻塞,默认是阻塞的
     *      1、可以让业务运行以异步的方式,自己提交到线程池
     *      2、支持定时任务线程池:通过设置 TaskSchedulingProperties
     *      3、让定时任务异步执行
     *          异步任务
     *      解决:定时任务加上异步任务来完成定时任务不阻塞的功能
     */
    @Async
    @Scheduled(cron = "* * * ? * 6")
    public void Hello() throws InterruptedException {
      log.info("hello....");
      Thread.sleep(3000);
    }
}

定时任务+异步任务

定时任务默认情况排队执行,所以前一个任务超时后面任务也会超时

解决方案:
	方案1:业务方法自己作异步编排【CompletableFuture.runAsync】
	方案2:修改定时任务线程池的线程个数【spring.task.scheduling.pool.size=5】(不一定生效,有BUG)
	方案3:让定时任务异步执行
方案3:让定时任务异步执行
整合步骤:
1.@EnableAsync
2.@Async
3.异步配置类:TaskExecutionAutoConfiguration
    配置线程池:
    	# 核心线程数
    	spring.task.execution.pool.core-size=5
    	# 最大线程数
    	spring.task.execution.pool.max-size=50

@Slf4j
@Component
@EnableAsync// 普通service方法也可以标注异步执行
@EnableScheduling
public class HelloScheduled {
    
     @Async
     @Scheduled(cron = "*/5 * * ? * 4")// 周四的任意秒启动,每隔五秒执行一次
     public void hello() {
         log.info("hello...");
         try {
             TimeUnit.SECONDS.sleep(3);
         } catch (InterruptedException e) { 
             e.printStackTrace(); 
         }
     }
}

有关定时任务的更多相关文章

  1. ruby - 其他文件中的 Rake 任务 - 2

    我试图在一个项目中使用rake,如果我把所有东西都放到Rakefile中,它会很大并且很难读取/找到东西,所以我试着将每个命名空间放在lib/rake中它自己的文件中,我添加了这个到我的rake文件的顶部:Dir['#{File.dirname(__FILE__)}/lib/rake/*.rake'].map{|f|requiref}它加载文件没问题,但没有任务。我现在只有一个.rake文件作为测试,名为“servers.rake”,它看起来像这样:namespace:serverdotask:testdoputs"test"endend所以当我运行rakeserver:testid时

  2. ruby - 如何使用 RSpec::Core::RakeTask 创建 RSpec Rake 任务? - 2

    如何使用RSpec::Core::RakeTask初始化RSpecRake任务?require'rspec/core/rake_task'RSpec::Core::RakeTask.newdo|t|#whatdoIputinhere?endInitialize函数记录在http://rubydoc.info/github/rspec/rspec-core/RSpec/Core/RakeTask#initialize-instance_method没有很好的记录;它只是说:-(RakeTask)initialize(*args,&task_block)AnewinstanceofRake

  3. ruby-on-rails - Rake 任务仅调用一次时执行两次 - 2

    我写了一个非常简单的rake任务来尝试找到这个问题的根源。namespace:foodotaskbar::environmentdoputs'RUNNING'endend当在控制台中执行rakefoo:bar时,输出为:RUNNINGRUNNING当我执行任何rake任务时会发生这种情况。有没有人遇到过这样的事情?编辑上面的rake任务就是写在那个.rake文件中的所有内容。这是当前正在使用的Rakefile。requireFile.expand_path('../config/application',__FILE__)OurApp::Application.load_tasks这里

  4. ruby - 帮助使用 Ruby 中的 "Whenever"gem 来执行 cron 任务 - 2

    我以前没有使用过cron,所以我不能确定我这样做是对的。我想要自动化的任务似乎没有运行。我在终端中执行了这些步骤:sudogeminstall每当切换到应用程序目录无论何时。(这创建了文件schedule.rb)我将此代码添加到schedule.rb:every10.minutesdorunner"User.vote",environment=>"development"endevery:hourdorunner"Digest.rss",:environment=>"development"end我将此代码添加到deploy.rb:after"deploy:symlink","depl

  5. ruby - 在 rake 任务中运行 capybara - 2

    如何在Rake任务中运行Capybara功能?例如:访问('http://google.com')谢谢! 最佳答案 在任务中尝试这样的事情:require'capybara'require'capybara/dsl'Capybara.current_driver=:seleniumBrowser=Class.new{includeCapybara::DSL}page=Browser.new.pagepage.visit("http://www.google.com")puts(page.html)

  6. ruby - 在 Rakefile 中动态生成 Rake 测试任务(基于现有的测试文件) - 2

    我正在根据Rakefile中的现有测试文件动态生成测试任务。假设您有各种以模式命名的单元测试文件test_.rb.所以我正在做的是创建一个以“测试”命名空间内的文件名命名的任务。使用下面的代码,我可以用raketest:调用所有测试require'rake/testtask'task:default=>'test:all'namespace:testdodesc"Runalltests"Rake::TestTask.new(:all)do|t|t.test_files=FileList['test_*.rb']endFileList['test_*.rb'].eachdo|task|n

  7. ruby-on-rails - 使用 Rspec 测试 rake 任务不接受参数 - 2

    根据thispostbyStephenHagemann,我正在尝试为我的一个rake任务编写Rspec测试.lib/tasks/retry.rake:namespace:retrydotask:message,[:message_id]=>[:environment]do|t,args|TextMessage.new.resend!(args[:message_id])endendspec/tasks/retry_spec.rb:require'rails_helper'require'rake'describe'retrynamespaceraketask'dodescribe're

  8. ruby-on-rails - 在 gem 的 rake 任务中需要 gem - 2

    我正在使用jeweler为Rails3创建一个gem。该gem包含一个rake任务,它所做的其中一件事是删除数据库,所以我正在使用“database_cleaner”。我在gem的Gemfile中指定gem依赖项gem'database_cleaner'在Rakefile中Jeweler::Tasks.newdo|gem|...gem.add_dependency'database_cleaner'end然后在lib中我创建了文件my_gem.rb和tasks.rake。如下,my_gem.rb:moduleMyGemclassRailtie和tasks.rake:task:my_ta

  9. ruby-on-rails - 在调用 Rake 任务时设置多个环境变量 - 2

    我可以像这样调用一个Rake任务并设置一个环境变量:$ONE=1raketemp:both但是如何设置两个环境变量呢?这行不通:$ONE=1TWO=2raketemp:both这行得通,但读起来很困惑:$ONE=1raketemp:bothTWO=2如何在调用rake之前传递多个环境? 最佳答案 同意@Ernest;它应该工作。这是一个示例...示例rake任务以回显变量:task:echo_envdoputs"VAR1:#{ENV['VAR1']}"puts"VAR2:#{ENV['VAR2']}"end执行任务:VAR1=fir

  10. ruby - 如何让 Ruby 每 10 分钟运行一次任务? - 2

    我想每10分钟执行一次cron作业,但我的系统只执行1小时。所以我正在寻找一种方法来做到这一点。我看过Timer和sleep但我不确定如何执行此操作,甚至不知道如何实现此操作。 最佳答案 看看http://rufus.rubyforge.org/rufus-scheduler/rufus-scheduler是一个用于调度代码片段(作业)的Rubygem。它了解在特定时间、在特定时间、每x次或仅通过CRON语句运行作业。rufus-scheduler不能替代cron/at,因为它在Ruby内部运行。

随机推荐