在Springboot中设置定时任务

蔚落 2022-10-01 05:53 47阅读 0赞

在Springboot中定时任务会相对来说简单一些 ，可以通过注解来进行实现。  
首先在maven里面加入包名，所以直接加入这个依赖就是了：

1 <dependencies>
     2 <dependency>
     3 <groupId>org.springframework.boot</groupId>
     4 <artifactId>spring-boot-starter-web</artifactId>
     5 </dependency>
     6 <dependency>
     7 <groupId>org.springframework.boot</groupId>
     8 <artifactId>spring-boot-starter</artifactId>
     9 </dependency>
    10 <dependency>
    11 <groupId>org.projectlombok</groupId>
    12 <artifactId>lombok</artifactId>
    13 <optional>true</optional>
    14 </dependency>
    15 <dependency>
    16 <groupId>org.springframework.boot</groupId>
    17 <artifactId>spring-boot-starter-test</artifactId>
    18 <scope>test</scope>
    19 </dependency>
    20 </dependencies>

然后书写一个配置类

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

然后是在在启动上加上定时任务的注解就是了

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80Mzg4OTY4MQ_size_16_color_FFFFFF_t_70]  
加上这个注解就可以了

如果需要与数据库进行交互，就在利用注解在项目中注入就是了。

下面是一个多线程，进行定时任务的多线程。

//@Component注解用于对那些比较中立的类进行注释；
    //相对与在持久层、业务层和控制层分别采用 @Repository、@Service 和 @Controller 对分层中的类进行注释
    @Component
    @EnableScheduling   // 1.开启定时任务
    @EnableAsync        // 2.开启多线程
    public class MultithreadScheduleTask {
    
            @Async
            @Scheduled(fixedDelay = 1000)  //间隔1秒
            public void first() throws InterruptedException {
                System.out.println("第一个定时任务开始 : " + LocalDateTime.now().toLocalTime() + "\r\n线程 : " + Thread.currentThread().getName());
                System.out.println();
                Thread.sleep(1000 * 10);
            }
    
            @Async
            @Scheduled(fixedDelay = 2000)
            public void second() {
                System.out.println("第二个定时任务开始 : " + LocalDateTime.now().toLocalTime() + "\r\n线程 : " + Thread.currentThread().getName());
                System.out.println();
            }
        }

在控制台输出之后可以发现结果互不影响，但是可能数据会乱，需要进行线程保护，如果需要的话。

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80Mzg4OTY4MQ_size_16_color_FFFFFF_t_70]: /images/20220119/8475c9c2e88146d5bc0118248083034f.png