惯性聚合 高效追踪和阅读你感兴趣的博客、新闻、科技资讯
阅读原文 在惯性聚合中打开

推荐订阅源

SecWiki News
SecWiki News
I
InfoQ
The Cloudflare Blog
人人都是产品经理
人人都是产品经理
博客园 - Franky
T
Tailwind CSS Blog
让小产品的独立变现更简单 - ezindie.com
让小产品的独立变现更简单 - ezindie.com
量子位
博客园_首页
罗磊的独立博客
V
V2EX
李成银的技术随笔
大猫的无限游戏
大猫的无限游戏
钛媒体:引领未来商业与生活新知
钛媒体:引领未来商业与生活新知
T
True Tiger Recordings
Vercel News
Vercel News
Cyberwarzone
Cyberwarzone
Cisco Talos Blog
Cisco Talos Blog
F
Fox-IT International blog
D
Darknet – Hacking Tools, Hacker News & Cyber Security
M
Microsoft Research Blog - Microsoft Research
Know Your Adversary
Know Your Adversary
爱范儿
爱范儿
The Register - Security
The Register - Security
G
Google Developers Blog
The Hacker News
The Hacker News
Malwarebytes
Malwarebytes
S
Securelist
博客园 - 三生石上(FineUI控件)
Jina AI
Jina AI
T
Threat Research - Cisco Blogs
T
The Exploit Database - CXSecurity.com
S
SegmentFault 最新的问题
博客园 - 叶小钗
F
Fortinet All Blogs
Apple Machine Learning Research
Apple Machine Learning Research
宝玉的分享
宝玉的分享
博客园 - 聂微东
T
Threatpost
博客园 - 【当耐特】
D
Docker
P
Privacy & Cybersecurity Law Blog
www.infosecurity-magazine.com
www.infosecurity-magazine.com
G
GRAHAM CLULEY
V
Visual Studio Blog
C
Cisco Blogs
IT之家
IT之家
S
Security Archives - TechRepublic
Latest news
Latest news
阮一峰的网络日志
阮一峰的网络日志

小松鼠的博客

记录一次线上k8s工作节点无法创建容器的问题排查思路与解决办法 记一次线上GoLang项目OOM排查过程 从LastPass转向拥抱开源KeePass的心路历程 故障定位与 AI 结合前后端编码实践 FileBeat收集nginx-ingress-controller日志 K8s云原生环境下文件描述符占用过高查询思路 2024年最新关闭火绒安全工具的开机自启方法 Kubernetes任务调度实践-Go语言实现Job和CronJob对比分析 离线更新k8s环境下的trivy漏洞库方法 使用Go语言接入Choerodon实现基于OAuth2的统一身份认证登录 在Vue2中自定义Switch组件并实现父子组件双向数据绑定 关于docker jdk1.8镜像中的GB18030-2022标准支持及验证 Go框架gin中的session存储gin-contrib-sessions和go-session 关于修改node_module中的源码问题记录 docker-compose网络和内网服务IP冲突问题 慎用存储过程:一条语句引发的数据库存储100%占用 Spring Boot中4种文件下载方法的实现 避坑-不能将specific类型的gitlab-runner改变为share类型 Docker compose中的MySQL主从复制模式和percona-toolkit工具使用 在minio中开启https访问以及使用rclone备份minio桶 在多机Docker环境下部署Choerodon的解决方案 Prometheus中Monitor添加对SpringBoot Actuator的Basic认证 在Nginx的容器镜像中隐藏Nginx的Server响应头 K8s中的两种nginx-ingress-controller及其区别 两个docker工具:runlike和whaler Grafana中的邮件报警和截图插件grafana-image-enderer K8s中externalName-service和services-without-selectors maven配置文件settings.xml中的一些概念总结 K8s中flexvolume插件驱动的安装 K8s中的coredns无法解析svc问题排查 K8s中使用Ingress访问请求体过大问题解决 关于k8s中对于SpringBoot应用TCP类型的就绪探针不准确的问题发现 K8s中的环境变量与应用程序的对应关系与操作 SpringMVC4升级为SpringBoot2实战 在Vmware中Ubuntu22.04的vm-tools和网络问题 修改k8s节点主机名并重新加入集群 离线安装Grafana插件 Spring Data Jpa 中使用CriteriaBuilder动态拼接SQL 在SpringBoot项目配置Liquibase数据库版本管理 记录Vue中父子组件传值的实战应用 实现单例模式的8种方法 三种常用的生产者消费者模式实现 使用两个线程交替打印0-100的奇偶数 关于部署于JBoss5中的Spring应用获取项目真实部署路径的问题 获取下一个完全对称日 通过短信验证码验证修改密码的解决方案 在Win10中使用Win+R快速启动软件 使用RSA加解密时注意Cipher.getInstance(String var0,Provider var1)提供的Provider是否正确 在RestEasy2.x中解决接口重复提交问题 几道简单的CTF题目思路 重温Spring---Spring事务控制与基于XML和注解的配置方法 重温Spring---Spring AOP基于XML和注解的配置 重温Spring---AOP动态代理和Spring AOP及其基本原理 重温Spring---Spring IOC基于XML和注解的配置和比较 在Windows10中安装MySQL5.7 Zip版本及常用配置 重温Spring---使用Spring IOC解决程序耦合 策略模式与责任链模式实战应用 Linux上直接打开war包修改文件 在Windows上运行两个微信的简单脚本 ThreadPoolExecutor的使用方法与分页查询数据实例 IDEA中Shelve Changes 和 Git Stash 通过resteasy发布RESTful接口 解决前端请求后台接口,后台报错Can not deserialize instance of java.util.ArrayList out of START_OBJECT token 使用VBA脚本汇总Excel文档 使用Jenkins+GitLab实现自动部署vue项目 Kubernetes:使用hostPath挂载nginx集群的配置文件和html 彻底搞定VirtualBox虚拟机的网络设定 在Docker中安装MySQL5.7并开启远程访问(附授权和修改密码方式) 利用git命令和java文件流 获取自己改动过的文件 在Spring项目简单配置Flyway(V4.2版本)数据库版本管理 解决Spring单元测试中因外键关联导致的失败integrity constraint violation:foreign key no action Redis安装与哨兵模式配置入门 关于Vue中使用Element-UI样式row-class-name失效的问题 Element-UI中实现可动态增加行列和可编辑单元格的表格 Windows系统查看端口占用、结束进程方法和命令 层次分析法(AHP)分析步骤与计算方法 源码分析之解决layui框架重载表格时额外参数不清空的问题 Spring Data Jpa 返回自定义对象(实体部分属性、多表联查) 如何将一个jar放到本地maven仓库中 关于SSM项目停止Tomcat时Log4j出现java.lang.NoClassDefFoundError: 获取el-table单元格值并根据该值对元素自定义样式渲染 解决Git每次push都要重新输入账号密码和HttpRequestException encountered的问题 解决前后端分离项目中Vue不带cookies的问题 SSM集成Shiro自定义权限过滤器不执行解决方案 SSM集成Shiro不进入自定义Realm的doGetAuthorizationInfo的解决方案 Vue+SSM中使用Token验证登录 Git拉代码推送代码提示密码错误如何修改 Git配置SSH Key(Git配置多个账户) 安装Tomcat服务器以及错误汇总(tomcat8.0、jdk8) 关于我
浅谈Spring定时任务的使用(Scheduled注解)
2020-11-03 · via 小松鼠的博客

环境说明

  使用maven3、Spring4.3构建、jdk7编译、运行在tomcat7.0中。

定时任务的基本配置

pom.xml:加入依赖

  <properties>
    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    <maven.compiler.source>1.7</maven.compiler.source>
    <maven.compiler.target>1.7</maven.compiler.target>
    <org.springframework.version>4.3.29.RELEASE</org.springframework.version>
  </properties>

  <dependencies>
    <!--SpringMVC依赖-->
    <dependency>
      <groupId>org.springframework</groupId>
      <artifactId>spring-webmvc</artifactId>
      <version>${org.springframework.version}</version>
    </dependency>
  </dependencies>

添加Spring配置文件applicationContext.xml:

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns="http://www.springframework.org/schema/beans"
       xmlns:context="http://www.springframework.org/schema/context"
       xmlns:task="http://www.springframework.org/schema/task"
       xsi:schemaLocation="http://www.springframework.org/schema/beans
       http://www.springframework.org/schema/beans/spring-beans-4.3.xsd
       http://www.springframework.org/schema/context
       http://www.springframework.org/schema/context/spring-context-4.3.xsd
       http://www.springframework.org/schema/task
       http://www.springframework.org/schema/task/spring-task-4.3.xsd">

    <context:component-scan base-package="com.yyc"></context:component-scan>
    <task:annotation-driven />

</beans>

web.xml:配置如下

<web-app>
  <display-name>Archetype Created Web Application</display-name>
  <context-param>
    <param-name>contextConfigLocation</param-name>
    <param-value>classpath:applicationContext.xml</param-value>
  </context-param>
  <listener>
    <!--一定要有这个监听器-->  
    <listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>
  </listener>
</web-app>

使用@Scheduled注解开启定时任务

package com.yyc;

import org.springframework.scheduling.annotation.Async;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import java.util.Date;

@Component
public class TaskImpl implements ITask{

    @Override
    @Scheduled(cron = "0/5 * * * * ? ") // cron表达式,每5秒执行一次
    public void taskMethod() {
        System.out.println("exec-"+new Date()+"--"+Thread.currentThread());
    }
}

遇到的问题

  第一次使用@Scheduled注解进行定时任务使用,发现部署成功,但定时任务老是不执行。最终发现web.xml配置出现了问题,在web.xml中,只使用context-param标签初始化了Spring的配置文件,还需要加入ContextLoaderListener监听器的配置才可以。百度一波,网友说到:tomcat启动时会加载web.xml 、加载<listener> <context-param>属性,项目启动,会找这个监听器去查contextConfigLocation

关于scheduler(调度线程)

  当有多个@Scheduled定时任务时,我们可以配置Scheduler,即调度线程池配置,可以实现多个定时任务并行执行。

未配置Scheduler的执行情况

  先来看看未配置Scheduler的执行情况。定时任务1每5秒执行一次;定时任务2也是每5秒执行一次,但是在打印之前,我们sleep 10秒,所以定时任务2会每15秒输出一次。

import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import java.util.Date;

@Component
public class TaskImpl implements ITask{

    /**
     * 定时任务1
     */
    @Override
    //@Async
    @Scheduled(cron = "0/5 * * * * ? ")
    public void taskMethod1() {
        System.out.println("TASK1-"+new Date()+"--"+Thread.currentThread());
    }

    /**
     * 定时任务2
     * @throws InterruptedException
     */
    @Override
    @Scheduled(cron = "0/5 * * * * ? ")
    public void taskMethod2() throws InterruptedException {
        Thread.sleep(10*1000);
        System.out.println("TASK2-"+new Date()+"--"+Thread.currentThread());
    }
}

xml配置:

<context:component-scan base-package="com.yyc"></context:component-scan>
<task:annotation-driven />

输出结果:

TASK2-Wed Nov 04 15:13:30 CST 2020--Thread[pool-1-thread-1,5,RMI Runtime]
TASK1-Wed Nov 04 15:13:30 CST 2020--Thread[pool-1-thread-1,5,RMI Runtime]
TASK2-Wed Nov 04 15:13:45 CST 2020--Thread[pool-1-thread-1,5,RMI Runtime]
TASK1-Wed Nov 04 15:13:45 CST 2020--Thread[pool-1-thread-1,5,RMI Runtime]
TASK2-Wed Nov 04 15:14:00 CST 2020--Thread[pool-1-thread-1,5,RMI Runtime]
TASK1-Wed Nov 04 15:14:00 CST 2020--Thread[pool-1-thread-1,5,RMI Runtime]
TASK2-Wed Nov 04 15:14:15 CST 2020--Thread[pool-1-thread-1,5,RMI Runtime]
TASK1-Wed Nov 04 15:14:15 CST 2020--Thread[pool-1-thread-1,5,RMI Runtime]
TASK2-Wed Nov 04 15:14:30 CST 2020--Thread[pool-1-thread-1,5,RMI Runtime]
TASK1-Wed Nov 04 15:14:30 CST 2020--Thread[pool-1-thread-1,5,RMI Runtime]
TASK2-Wed Nov 04 15:14:45 CST 2020--Thread[pool-1-thread-1,5,RMI Runtime]
TASK1-Wed Nov 04 15:14:45 CST 2020--Thread[pool-1-thread-1,5,RMI Runtime]

可以清晰的看到,未配置Scheduler时,任务1和任务2是串行方式执行的,都是每过15秒才打印一次,说明任何一个任务都需要等待其它任务执行完成,都是线程pool-1-thread-1执行的。

配置Scheduler的执行情况

xml配置:

<context:component-scan base-package="com.yyc"></context:component-scan>
<task:annotation-driven scheduler="dataScheduler"/>
<task:scheduler id="dataScheduler" pool-size="2"/>

输出结果:

TASK1-Wed Nov 04 15:35:50 CST 2020--Thread[dataScheduler-1,5,RMI Runtime]
TASK1-Wed Nov 04 15:35:55 CST 2020--Thread[dataScheduler-1,5,RMI Runtime]
TASK1-Wed Nov 04 15:36:00 CST 2020--Thread[dataScheduler-1,5,RMI Runtime]
TASK2-Wed Nov 04 15:36:00 CST 2020--Thread[dataScheduler-2,5,RMI Runtime]
TASK1-Wed Nov 04 15:36:05 CST 2020--Thread[dataScheduler-1,5,RMI Runtime]
TASK1-Wed Nov 04 15:36:10 CST 2020--Thread[dataScheduler-1,5,RMI Runtime]
TASK2-Wed Nov 04 15:36:15 CST 2020--Thread[dataScheduler-2,5,RMI Runtime]
TASK1-Wed Nov 04 15:36:15 CST 2020--Thread[dataScheduler-1,5,RMI Runtime]
TASK1-Wed Nov 04 15:36:20 CST 2020--Thread[dataScheduler-1,5,RMI Runtime]
TASK1-Wed Nov 04 15:36:25 CST 2020--Thread[dataScheduler-1,5,RMI Runtime]
TASK2-Wed Nov 04 15:36:30 CST 2020--Thread[dataScheduler-2,5,RMI Runtime]

为了方便查看,我们有两个任务配置pool-size为2。通过输出可以发现任务1和任务2并行执行,任务1每5秒输出一次(调度线程dataScheduler-1),任务2每15秒输出一次(调度线程dataScheduler-2)。

关于executor(执行线程)

  这里引入另一个参数,可以看任务 1上方注释掉的 @Async 注解:这个注解,代表可以异步执行。异步执行的话,调度线程池就会不用当前调度线程来执行,而是交给 task:executor 这个执行线程池来执行。

我们使用@Async注解配置任务1,任务2不变:

@Async
@Scheduled(cron = "0/5 * * * * ? ")
public void taskMethod1() {
   System.out.println("TASK1-"+new Date()+"--"+Thread.currentThread());
}

xml配置:

<context:component-scan base-package="com.yyc"></context:component-scan>
<task:annotation-driven scheduler="dataScheduler" executor="dataExecutor"/>
<task:scheduler id="dataScheduler" pool-size="2"/>
<task:executor id="dataExecutor" pool-size="10"/>

输出结果:

TASK1-Wed Nov 04 15:58:25 CST 2020--Thread[dataExecutor-1,5,RMI Runtime]
TASK1-Wed Nov 04 15:58:30 CST 2020--Thread[dataExecutor-2,5,RMI Runtime]
TASK1-Wed Nov 04 15:58:35 CST 2020--Thread[dataExecutor-3,5,RMI Runtime]
TASK2-Wed Nov 04 15:58:35 CST 2020--Thread[dataScheduler-2,5,RMI Runtime]
TASK1-Wed Nov 04 15:58:40 CST 2020--Thread[dataExecutor-4,5,RMI Runtime]
TASK1-Wed Nov 04 15:58:45 CST 2020--Thread[dataExecutor-5,5,RMI Runtime]
TASK2-Wed Nov 04 15:58:50 CST 2020--Thread[dataScheduler-2,5,RMI Runtime]
TASK1-Wed Nov 04 15:58:50 CST 2020--Thread[dataExecutor-6,5,RMI Runtime]
TASK1-Wed Nov 04 15:58:55 CST 2020--Thread[dataExecutor-7,5,RMI Runtime]
TASK1-Wed Nov 04 15:59:00 CST 2020--Thread[dataExecutor-8,5,RMI Runtime]
TASK2-Wed Nov 04 15:59:05 CST 2020--Thread[dataScheduler-2,5,RMI Runtime]
TASK1-Wed Nov 04 15:59:05 CST 2020--Thread[dataExecutor-9,5,RMI Runtime]
TASK1-Wed Nov 04 15:59:10 CST 2020--Thread[dataExecutor-10,5,RMI Runtime]
TASK1-Wed Nov 04 15:59:15 CST 2020--Thread[dataExecutor-1,5,RMI Runtime]
TASK1-Wed Nov 04 15:59:20 CST 2020--Thread[dataExecutor-2,5,RMI Runtime]
TASK2-Wed Nov 04 15:59:20 CST 2020--Thread[dataScheduler-2,5,RMI Runtime]
TASK1-Wed Nov 04 15:59:25 CST 2020--Thread[dataExecutor-3,5,RMI Runtime]

可以发现,任务1使用了@Async注解后,任务1的线程是 dataExecutor-1 到 dataExecutor-10,说明 dataScheduler-1 这个调度线程调度了任务1,但是交给了线程池中的dataExecutor中的执行线程来具体执行的;而任务2没有使用@Async注解,所以还是使用dataScheduler-2 这个调度线程调度任务2。

源码下载

本文示例源码:点击下载

总结

  1. Spring定时任务,需要spring-context jar包,我这里为了方便直接用的mvc的包;
  2. 配置的时候,一定要细心,配置文件schemaLocation等配置完整;
  3. web.xml中一定要配置org.springframework.web.context.ContextLoaderListener这个监听器;
  4. 配置task:scheduler参数的线程池,是为了根据任务总数来分配调度线程池的大小;而配置task:executor,是为了某个任务如果要异步的执行时,实现当前任务内的多线程并发。

参考

https://blog.csdn.net/yx0628/article/details/80873774