SpringBoot实现定时任务和异步调用

SpringBoot实现定时任务和异步调用 SpringBoot框架提供了强大的功能来实现定时任务和异步调用，这在业务场景中非常常见。例如，在电商平台中，需要定时发送邮件、短信、统计监控数据等操作，而在订单流程中，需要异步调用下单、发货通知、短信推送、消息推送等子程序。 一、定时任务 定时任务是指在指定的时间点或间隔执行具体的任务，这在业务场景中非常常见。例如，在电商平台中，需要定时发送邮件、短信、统计监控数据等操作。SpringBoot框架提供了 @EnableScheduling 注解来开启定时任务。 1. 启动定时任务 在 Spring Boot 主类上使用 @EnableScheduling 注解来启动定时任务： ```java package com.example.demo; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.scheduling.annotation.EnableScheduling; // 启动定时任务 @EnableScheduling @SpringBootApplication public class DemoApplication { public static void main(String[] args) { SpringApplication.run(DemoApplication.class, args); } } ``` 2. 实现定时任务 使用 @Component 注解来标注组件，并使用 @Scheduled 注解来指定定时任务的执行规则： ```java package com.example.demo.test1.component; import java.util.Date; import org.springframework.scheduling.annotation.Scheduled; import org.springframework.stereotype.Component; @Component public class SchedulingComponent { / * 测试定时任务，没三秒执行一次 */ @Scheduled(fixedRate = 3000) public void testScheduling1() { System.out.println("执行时间为" + new Date() + "执行testScheduling1"); } } ``` @Scheduled 注解提供了多种执行规则，例如： * @Scheduled(fixedRate = 5000)：上一次开始执行时间点之后5秒再执行 * @Scheduled(fixedDelay = 5000)：上一次执行完毕时间点之后5秒再执行 * @Scheduled(initialDelay=1000, fixedRate=5000)：第一次延迟1秒后执行，之后按 fixedRate 的规则每5秒执行一次 * @Scheduled(cron="*/5 * * * * *")：通过 cron 表达式定义规则 二、异步调用 异步调用是指在业务流程中，需要执行多个子程序，而这些子程序可以同时进行且不影响主程序的运行。SpringBoot框架提供了 @EnableAsync 注解来开启异步调用。 1. 启动异步调用 在 Spring Boot 主类上使用 @EnableAsync 注解来启动异步调用： ```java package com.example.demo; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.scheduling.annotation.EnableAsync; // 启动异步调用 @EnableAsync @SpringBootApplication public class DemoApplication { public static void main(String[] args) { SpringApplication.run(DemoApplication.class, args); } } ``` 2. 实现异步调用 使用 @Async 注解来标注异步方法： ```java package com.example.demo.test1.component; import org.springframework.scheduling.annotation.Async; @Component public class AsyncComponent { / * 测试异步调用 */ @Async public void testAsync() { System.out.println("执行异步调用"); } } ``` 异步调用可以提高系统的性能和响应速度，但需要注意线程安全和资源竞争问题。