如何在无参@Scheduled方法中按6分钟间隔依次调用REST接口？

这个场景很典型——@Scheduled确实硬性要求方法无参，但我们完全可以通过动态任务调度+线程安全队列的组合来实现你要的「处理完一个接口后间隔6分钟再处理下一个」的逻辑，不用被固定频率的调度注解捆住手脚。下面是具体的实现思路和代码示例：

核心思路 #

1. 用线程安全队列存储待检查的REST接口地址，避免多线程操作时出现并发问题。
2. 编写一个核心的接口处理方法：负责取出队列中的一个接口执行检查，处理完成后，通过TaskScheduler动态安排6分钟后再次调用自身（如果队列还有剩余接口）。
3. 用@Scheduled或者应用启动事件触发第一次任务执行，启动整个检查流程。

具体代码实现 #

1. 初始化队列与调度器 #

首先，我们注入Spring默认配置的TaskScheduler，并初始化存储接口地址的线程安全队列：

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.ApplicationListener;
import org.springframework.context.event.ContextRefreshedEvent;
import org.springframework.scheduling.TaskScheduler;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import java.util.concurrent.ConcurrentLinkedQueue;
import java.util.concurrent.TimeUnit;

@Component
public class RestApiChecker {

    // 线程安全队列，存储待检查的接口地址
    private final ConcurrentLinkedQueue<String> apiQueue = new ConcurrentLinkedQueue<>();

    @Autowired
    private TaskScheduler taskScheduler;

    // 初始化接口列表（你可以从配置文件/数据库加载，这里模拟示例）
    public RestApiChecker() {
        apiQueue.add("https://api.example.com/service1");
        apiQueue.add("https://api.example.com/service2");
        apiQueue.add("https://api.example.com/service3");
        // 可添加更多接口...
    }

2. 核心接口处理方法 #

这个方法是整个逻辑的核心，负责单个接口的检查，并在完成后动态调度下一个任务：

// 核心处理逻辑：取出一个接口执行检查，完成后调度下一个
    private void processNextApi() {
        String apiUrl = apiQueue.poll();
        if (apiUrl == null) {
            // 队列空了，结束流程（可在这里添加重置队列或告警逻辑）
            return;
        }

        try {
            // 执行接口检查逻辑，替换成你的实际REST调用代码
            System.out.println("正在检查接口: " + apiUrl);
            // 示例：用RestTemplate/WebClient发送请求
            // restTemplate.getForObject(apiUrl, String.class);
        } catch (Exception e) {
            // 处理接口调用异常，比如记录日志
            System.err.println("检查接口 " + apiUrl + " 失败: " + e.getMessage());
        } finally {
            // 不管成功失败，6分钟后安排下一个接口检查
            taskScheduler.schedule(this::processNextApi, System.currentTimeMillis() + TimeUnit.MINUTES.toMillis(6));
        }
    }

3. 触发第一次任务执行 #

你可以根据需求选择两种启动方式：

方式一：定时启动（比如每天凌晨1点开始检查）

// 每天凌晨1点启动检查流程，同时重置接口队列
    @Scheduled(cron = "0 0 1 * * ?")
    public void startDailyApiCheck() {
        apiQueue.clear();
        // 重新加载接口列表
        apiQueue.add("https://api.example.com/service1");
        apiQueue.add("https://api.example.com/service2");
        // 启动第一个任务
        processNextApi();
    }

方式二：应用启动时自动触发

实现ApplicationListener监听上下文刷新事件，应用启动后立即开始检查：

@Override
    public void onApplicationEvent(ContextRefreshedEvent event) {
        // 应用启动完成后，立即执行第一次检查
        processNextApi();
    }

关键细节说明 #

• 线程安全：使用ConcurrentLinkedQueue确保队列的poll()和add()操作在多线程环境下安全，避免数据混乱。
• 动态调度：通过TaskScheduler的schedule方法，我们可以灵活控制下一次任务的执行时间，完美贴合「处理完一个再等6分钟」的需求，比固定频率的@Scheduled更灵活。
• 异常容错：在finally块中安排下一次任务，确保即使某个接口调用失败，整个检查流程也能继续推进。
• 可扩展性：你可以轻松修改接口列表的加载方式（比如从数据库、配置中心读取），或者调整间隔时间，只需要修改TimeUnit.MINUTES.toMillis(6)的值即可。

内容的提问来源于stack exchange，提问作者Tom