ApplicationRunner 是 Spring Boot 中的一个接口,用于在 Spring Boot 应用程序启动后执行特定的任务或逻辑。它允许开发者在应用程序完全启动后执行一些初始化操作,例如加载数据、调用外部服务或执行其他业务逻辑。
要使用 ApplicationRunner,需要创建一个实现了 ApplicationRunner 接口的类,并实现其 run() 方法。在该方法中编写希望在应用程序启动后执行的代码逻辑。示例代码如下:
import org.springframework.boot.*;
import org.springframework.stereotype.*;
@Component
public class MyApplicationRunner implements ApplicationRunner {
@Override
public void run(ApplicationArguments args) throws Exception {
System.out.println("ApplicationRunner started with arguments: " + args.getOptionNames());
// 在这里编写你的初始化逻辑
}
}
也可以直接在启动类Application.class文件中直接引入:
/**
* 创建线程池任务
*/
@Bean
public ApplicationRunner applicationRunner(ExecutorService threadPoolExecutor01) {
System.out.println("threadPoolExecutor01:");
System.out.println(threadPoolExecutor01);
return args -> {
while (true) {
// 创建一个随机时间生成器
Random random = new Random();
// 随机启动时间,用于模拟任务启动延迟
int randomInitialTime = random.nextInt(10) + 1; // 随机生成1-10之间的整数
// 随机任务时间,用于模拟任务执行时间
int randomTaskTime = random.nextInt(10) + 1; // 随机生成1-10之间的整数
// 提交任务到线程池
threadPoolExecutor01.submit(() -> {
try {
// 模拟任务启动延迟
Thread.sleep(randomInitialTime * 1000);
System.out.println("线程池任务在 " + randomInitialTime + " 秒后启动。");
// 模拟任务执行时间
Thread.sleep(randomTaskTime * 1000);
System.out.println("线程池任务执行了 " + randomInitialTime + " 秒。");
} catch (Exception exception) {
// 中断当前线程
Thread.currentThread().interrupt();
}
});
}
};
}
ApplicationRunner 的 run() 方法在 Spring Boot 应用程序启动完成后立即执行。这意味着它可以用来执行需要在整个应用程序上下文初始化后进行的操作。
run() 方法的参数 ApplicationArguments 提供了启动参数的访问。通过 ApplicationArguments 可以获取命令行参数、选项和非选项参数等信息,从而更灵活地配置和初始化应用程序。