Spring Boot的异步与定时任务

🏆本文收录于「滚雪球学SpringBoot」专栏(全网一个名)，手把手带你零基础入门Spring Boot，从入门到就业，助你早日登顶实现财富自由🚀；同时，欢迎大家关注&&收藏&&订阅！持续更新中，up！up！up！！

环境说明：Windows 10 + IntelliJ IDEA 2021.3.2 + Jdk 1.8

前言

在这篇文章中，我们将深入探讨如何在Spring Boot中实现异步操作和定时任务。这两者是开发高效、响应快速应用程序的重要工具。Spring Boot提供了很好的支持，使得异步操作和定时任务变得容易实现。我们将讨论如何使用**@Async来进行异步操作，以及如何使用@Scheduled**来配置和运行定时任务。

🌱 一、使用@Async进行异步操作

1.1 什么是异步操作？

异步操作是指任务执行后，调用者可以继续执行其他操作，而无需等待任务完成。与同步操作不同，异步操作不会阻塞主线程，这对于需要执行耗时任务（如网络请求、文件操作、数据库查询等）的应用尤为重要。异步任务通常在后台线程中执行，从而提高了系统的响应速度和吞吐量。

1.2 配置Spring Boot异步支持

要使用Spring Boot的异步功能，我们需要做两个步骤的配置：

1.2.1 启用异步支持

首先，我们需要在Spring Boot应用的配置类中启用异步支持。在主配置类或某个配置类上加上@EnableAsync注解。

import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.EnableAsync;

@Configuration
@EnableAsync
public class AsyncConfig {
    // 可以自定义异步配置
}

1.2.2 使用@Async注解进行异步操作

一旦异步支持被启用，我们就可以在需要异步执行的方法上使用@Async注解。通过@Async标记的方法将会在独立的线程中执行，而不是阻塞当前线程。

import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;

@Service
public class UserService {

    // 异步执行
    @Async
    public void performTask() {
        try {
            // 模拟耗时操作
            Thread.sleep(5000);
            System.out.println("Task performed in async thread: " + Thread.currentThread().getName());
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

在这个例子中，performTask()方法被标记为@Async，Spring会将其运行在一个新的线程中。当你调用performTask()方法时，主线程不会被阻塞，方法将在后台执行。

1.2.3 异步任务的返回值

如果需要异步任务返回值，可以使用Future、CompletableFuture或ListenableFuture来表示异步结果。

例如，使用CompletableFuture：

import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;
import java.util.concurrent.CompletableFuture;

@Service
public class UserService {

    // 异步执行并返回结果
    @Async
    public CompletableFuture<String> performTaskWithResult() {
        try {
            // 模拟耗时操作
            Thread.sleep(3000);
            System.out.println("Task completed in async thread: " + Thread.currentThread().getName());
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        return CompletableFuture.completedFuture("Task Result");
    }
}

调用异步方法时，返回的是CompletableFuture，我们可以在需要的时候通过get()方法来获取结果：

@Autowired
private UserService userService;

public void testAsync() throws Exception {
    CompletableFuture<String> result = userService.performTaskWithResult();
    System.out.println("Main thread continues execution...");
    // 获取异步任务的结果
    System.out.println("Async result: " + result.get());
}

1.3 异步任务执行的线程池配置

默认情况下，Spring Boot会为异步任务分配一个线程池。如果你需要更细致的控制线程池配置，可以在配置类中使用TaskExecutor来定制线程池。

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;

@Configuration
public class AsyncConfig {

    @Bean(name = "taskExecutor")
    public ThreadPoolTaskExecutor taskExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setCorePoolSize(5); // 核心线程池大小
        executor.setMaxPoolSize(10); // 最大线程池大小
        executor.setQueueCapacity(25); // 队列容量
        executor.setThreadNamePrefix("async-task-");
        executor.initialize();
        return executor;
    }
}

通过这种方式，所有的异步任务将会使用自定义的线程池，而不是默认的线程池。

🕰️ 二、使用@Scheduled配置定时任务

2.1 什么是定时任务？

定时任务是指在特定时间间隔内自动执行的任务。它可以用于定期执行一些重复性的操作，比如定期清理缓存、发送通知、备份数据等。

Spring Boot提供了@Scheduled注解来帮助我们轻松地创建定时任务。

2.2 配置Spring Boot的定时任务

为了启用定时任务，首先需要在配置类中使用@EnableScheduling注解。

import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.EnableScheduling;

@Configuration
@EnableScheduling
public class SchedulingConfig {
    // 配置定时任务
}

2.2.1 使用@Scheduled注解执行定时任务

@Scheduled注解可以与不同的触发方式一起使用，例如固定间隔时间、固定时间点等。常见的触发方式有：

• fixedRate：每隔固定的时间间隔执行任务（单位为毫秒）。
• fixedDelay：每次执行完成后，延迟一定时间再执行任务。
• cron：基于Cron表达式配置执行时间。

示例：固定间隔时间执行任务（fixedRate）

import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Service;

@Service
public class TaskService {

    // 每隔5秒钟执行一次任务
    @Scheduled(fixedRate = 5000)
    public void performTaskAtFixedRate() {
        System.out.println("Task executed at fixed rate: " + System.currentTimeMillis());
    }
}

在这个例子中，任务将每隔5秒钟执行一次。

示例：固定延迟时间执行任务（fixedDelay）

@Scheduled(fixedDelay = 5000)
public void performTaskWithFixedDelay() {
    System.out.println("Task executed with fixed delay: " + System.currentTimeMillis());
}

在此示例中，每次任务执行完成后，延迟5秒钟再执行下一次。

示例：使用Cron表达式配置定时任务（cron）

@Scheduled(cron = "0 0 12 * * ?") // 每天中午12点执行
public void performTaskAtNoon() {
    System.out.println("Task executed at noon: " + System.currentTimeMillis());
}

Cron表达式非常强大，它可以让你非常灵活地指定任务执行的时间。上面的Cron表达式表示每天中午12点执行任务。

2.3 定时任务的其他配置

• initialDelay：表示定时任务开始执行前的初始延迟时间（单位为毫秒）。
• zone：可以指定时区。

例如：

@Scheduled(fixedRate = 5000, initialDelay = 1000)
public void performTaskWithDelay() {
    System.out.println("Task executed after initial delay: " + System.currentTimeMillis());
}

这个例子中，任务会在启动后的1秒钟开始执行，然后每隔5秒执行一次。

🎉 三、总结

在这篇文章中，我们深入讨论了如何在Spring Boot应用中实现异步操作和定时任务：

1. 使用@Async进行异步操作：通过@Async注解，将方法标记为异步执行，避免主线程被阻塞，提升应用的响应速度。
2. 使用@Scheduled配置定时任务：定时任务用于在指定时间间隔执行任务，支持固定间隔、延迟执行和Cron表达式配置。

通过合理使用异步操作和定时任务，你可以大大提升应用的性能和效率，尤其是在处理大量数据、外部请求和定时任务时。

希望这篇文章能帮助你更好地理解和使用Spring Boot的异步与定时任务功能，提高你的开发效率！ 🚀

🧧福利赠与你🧧

  无论你是计算机专业的学生，还是对编程有兴趣的小伙伴，都建议直接毫无顾忌的学习此专栏「滚雪球学SpringBoot」专栏(全网一个名)，bug菌郑重承诺，凡是学习此专栏的同学，均能获取到所需的知识和技能，全网最快速入门SpringBoot，就像滚雪球一样，越滚越大， 无边无际，指数级提升。

  最后，如果这篇文章对你有所帮助，帮忙给作者来个一键三连，关注、点赞、收藏，您的支持就是我坚持写作最大的动力。

  同时欢迎大家关注公众号:「猿圈奇妙屋」 ，以便学习更多同类型的技术文章，免费白嫖最新BAT互联网公司面试题、4000G pdf电子书籍、简历模板、技术文章Markdown文档等海量资料。

✨️ Who am I?

我是bug菌，CSDN | 掘金 | InfoQ | 51CTO | 华为云 | 阿里云 | 腾讯云 等社区博客专家，C站博客之星Top30，华为云多年度十佳博主/价值贡献奖，掘金多年度人气作者Top40，掘金等各大社区平台签约作者，51CTO年度博主Top12，掘金/InfoQ/51CTO等社区优质创作者；全网粉丝合计 30w+；更多精彩福利点击这里；硬核微信公众号「猿圈奇妙屋」，欢迎你的加入！免费白嫖最新BAT互联网公司面试真题、4000G PDF电子书籍、简历模板等海量资料，你想要的我都有，关键是你不来拿。

-End-