Spring Bootで動的にジョブスケジューリングを作成する方法
Spring Bootにおける動的タスクスケジューリングの実装では、SpringのTaskSchedulerインターフェースを使用できます。TaskSchedulerインターフェースはタスクスケジューリングを作成、管理するためのメソッドを複数提供します。
まず、Spring Bootアプリケーションの中にTaskScheduler beanを設定する必要があります。ThreadPoolTaskSchedulerというクラスを使ってスレッドプールタスクスケジューラを作成することができます。
@Configuration
@EnableScheduling
public class SchedulerConfig {
@Bean
public TaskScheduler taskScheduler() {
ThreadPoolTaskScheduler scheduler = new ThreadPoolTaskScheduler();
scheduler.setPoolSize(10);
scheduler.setThreadNamePrefix("MyScheduler-");
scheduler.setAwaitTerminationSeconds(60);
scheduler.setWaitForTasksToCompleteOnShutdown(true);
return scheduler;
}
}
タスクスケジューラBeanをダイナミックなタスクのスケジュールが必要な場所に注入すれば、scheduleメソッドを用いてタスクを作成できるようになります。
@Service
public class MySchedulerService {
@Autowired
private TaskScheduler taskScheduler;
public void createScheduledTask() {
Runnable task = () -> {
// 任务逻辑
System.out.println("Executing scheduled task...");
};
// 创建任务并指定调度规则
Trigger trigger = new CronTrigger("0 0/5 * * * *"); // 每5分钟执行一次
taskScheduler.schedule(task, trigger);
}
}
createScheduledTaskメソッドは説明したコードサンプルのようにcron式を指定することで、定时タスクを生成します。必要に応じてスケジューリングルールを設定できます。
上記コードを実行するには、Springのスケジュール機能を有効にするために、アプリケーション起動時に起動するTaskScheduler beanの設定に@EnableSchedulingアノテーションを追加すること
最後に、createScheduledTask メソッドをアプリケーションの任意の場所で呼び出して、タスク スケジュールを動的に作成できます。
@Autowired
private MySchedulerService schedulerService;
public void someMethod() {
// 创建任务调度
schedulerService.createScheduledTask();
}
上記のコード例では、createScheduledTask メソッドを必要な任意の場所で呼び出すことで、スケジュール済みタスクを動的に作成できます。