SpringBoot任务调度实现

在Spring Boot中，我们可以使用@Scheduled注解和TaskScheduler接口来实现任务调度。下面是两种实现方法的详细说明和示例代码。

方法一：使用@Scheduled注解

1. 在Spring Boot的主类或者配置类上添加@EnableScheduling注解，以启用定时任务支持。

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.scheduling.annotation.EnableScheduling;

@SpringBootApplication
@EnableScheduling
public class Application {
    public static void main(String[] args) {
        SpringApplication.run(Application.class, args);
    }
}

2. 创建一个定时任务类，并在需要执行的方法上添加@Scheduled注解。你可以通过fixedRate、fixedDelay或cron表达式来配置任务的执行频率。

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

@Component
public class MyScheduledTasks {

    @Scheduled(fixedRate = 5000) // 每隔5秒执行一次
    public void task1() {
        System.out.println("Task 1 is running");
    }

    @Scheduled(cron = "0 * * * * *") // 每小时的0分执行一次
    public void task2() {
        System.out.println("Task 2 is running");
    }
}

方法二：使用TaskScheduler接口

1. 在Spring Boot的主类或者配置类上添加@EnableScheduling注解，以启用定时任务支持。

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.scheduling.annotation.EnableScheduling;

@SpringBootApplication
@EnableScheduling
public class Application {
    public static void main(String[] args) {
        SpringApplication.run(Application.class, args);
    }
}

2. 创建一个定时任务类，并实现TaskScheduler接口。

import org.springframework.scheduling.TaskScheduler;
import org.springframework.stereotype.Component;

import java.util.concurrent.ScheduledFuture;

@Component
public class MyScheduledTasks implements TaskScheduler {

    private final TaskScheduler taskScheduler;
    private ScheduledFuture<?> scheduledFuture;

    public MyScheduledTasks(TaskScheduler taskScheduler) {
        this.taskScheduler = taskScheduler;
    }

    @Override
    public ScheduledFuture<?> schedule(Runnable command, long delay) {
        scheduledFuture = taskScheduler.schedule(command, new Trigger() {
            @Override
            public Date nextExecutionTime(TriggerContext triggerContext) {
                return new Date(System.currentTimeMillis() + delay);
            }
        });
        return scheduledFuture;
    }

    @Override
    public ScheduledFuture<?> scheduleAtFixedRate(Runnable command, long initialDelay, long period) {
        scheduledFuture = taskScheduler.scheduleAtFixedRate(command, initialDelay, period);
        return scheduledFuture;
    }

    @Override
    public ScheduledFuture<?> scheduleWithFixedDelay(Runnable command, long initialDelay, long delay) {
        scheduledFuture = taskScheduler.scheduleWithFixedDelay(command, initialDelay, delay);
        return scheduledFuture;
    }

    public void cancel() {
        if (scheduledFuture != null) {
            scheduledFuture.cancel(false);
        }
    }
}

3. 在需要执行的方法中，调用MyScheduledTasks类中的相应方法来执行任务。

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class MyController {

    @Autowired
    private MyScheduledTasks myScheduledTasks;

    @GetMapping("/startTask")
    public String startTask() {
        myScheduledTasks.scheduleAtFixedRate(() -> {
            System.out.println("Task is running");
        }, 0, 5000); // 每隔5秒执行一次
        return "Task started";
    }

    @GetMapping("/stopTask")
    public String stopTask() {
        myScheduledTasks.cancel();
        return "Task stopped";
    }
}

这样，你就可以在Spring Boot应用中使用任务调度功能了。