springboot实现定时任务

薄洪涛5年前JAVA1255

之前做php的时候,如果想做个定时任务,或者想特定时间调用某个脚本/接口,我们都会考虑使用linux的crontab来实现,比较对于单线程脚本语言来说,做定时不是那么容易

然后最近因为开始学习java,就用到了springboot这个框架中的定时任务,所以记录下使用定时任务的步骤

  1. 主类application中开启@EnableScheduling 注解

    image.png

  2. 建立定时任务配置类,配置定时计划,定时要做的任务

@Component
public class ScheduledTask {
    val logger = LoggerFactory.getLogger(UserService::class.java)
    @Scheduled(cron = "0/5 * * * * ?")
    fun scheduled1() {
        val now = Timestamp.from(Instant.now())
        logger.info("定时任务调起 ${now}")
    }
}

然后run,你会发现你写的定时任务会自己跑起来了

image.png

当你写了主类中加了@EnableAsync,且第二步中的配置函数加了@Async,就是多线程了

注意,如果主类中你没有写@EnableAsync 的话,此时的定时任务是单线程的,是不是惊喜+意外,我们来证实一下

先试试多线程

import com.chocwell.blog.api.service.UserService
import org.slf4j.LoggerFactory
import org.springframework.scheduling.annotation.Async
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import java.sql.Timestamp
import java.time.Instant

@Component
public class ScheduledTask {
    val logger = LoggerFactory.getLogger(UserService::class.java)
    @Async
    @Scheduled(fixedDelay = 1000)
    fun scheduled1() {
        val now = Timestamp.from(Instant.now())
        logger.info("定时任务1调起 ${now}")
        Thread.sleep(5000)
    }
    @Async
    @Scheduled(fixedDelay = 2000)
    fun scheduled2() {
        val now = Timestamp.from(Instant.now())
        logger.info("定时任务2调起 ${now}")
        Thread.sleep(5000)
}
}

运行结果

image.png

这样你的定时任务1和2就互不干扰,并且单个任务的被调用的时间和其执行时间无关,因为每次运行都是一个新线程,可以看到sleep并没有影响定时任务的执行

注:使用了fixedDelay ,意思是上一次开始执行时间点之后多久开始执行下次任务

接来下,我们试试单线程,把@Async去掉试一下,清楚的看到,每次的任务都受sleep的影响

image.png

好了,这次的学习我学到了定时任务不是只有linux的crontab,springboot下的定时同样好用

相关文章

jenkins部署maven项目

1. 环境配置jenkins安装 Maven Integration plugin插件配置maven,java等路径2. 2.新建item,选择构建maven项目a. 2.1 源码管理填入git地址、...

docker-swarm部署java项目

技术栈Java 版本: 17Spring Boot 版本: 3.xMyBatis-Plus: 简化 MyBatis 操作的增强工具PostgreSQL: 关系型数据库Redis: 分布式缓存解决方案R...

基于dubbo改造现有http调用项目

使用zooker作为注册中心,将现有通过http调用的项目改造成dubbo调用公共项目规定接口public interface OrderService {  ...

ebean相关的查询

where// select * from user where name = "boht"List...

idea 部署Tomcat服务器

idea 部署Tomcat服务器

一、创建一个web项目1.file-new project,选择正确的jdk版本后(没配置的可以先自行google配置),next2.next3.输入项目名字和路径二,创建Module1.鼠标点中项目...

Ebean报错is not enhanced?

Ebean报错is not enhanced?

使用ebean的时候,会提示某个类没有enhanced,这里我们在idea中安装对应的plugin就可以了(需要看你的gradle的ebean版本)我的版本配置如下classpath("io...

发表评论    

◎欢迎参与讨论,请在这里发表您的看法、交流您的观点。