Spring Boot で複数のスケジュールされたタスクを実装する方法

実際の開発では、多かれ少なかれいくつかのスケジュールされたタスクのシナリオが使用されます。この記事では、一般的に使用されるスケジュールされたタスクについて説明します。

一般的に使用されるタイミング タスクの実装ソリューションには次のものがあります。

• Timer: これは、Java に付属する java.util.Timer クラスです。このクラスを使用すると、java.util.TimerTask タスクをスケジュールできます。 。この方法を使用すると、指定された時間ではなく、特定の頻度でプログラムを実行できます。一般的にはあまり使用されません。
• ScheduledExecutorService: これも jdk に付属するクラスであり、スレッド プール設計に基づいたスケジュールされたタスク クラスです。各スケジュールされたタスクは、次のように割り当てられます。スレッド プール スレッドが実行されます。つまり、タスクは同時に実行され、互いに影響しません。
• Spring タスク:Spring3.0今後のタスクでは、これを軽量の Quartz とみなして使用できます。Quartz よりもはるかに単純です。
• Quartz: これは、指定した時間または周波数でプログラムを実行できるようにする比較的強力なスケジューラです。設定は少し複雑です。
• データベースにテーブルを作成し、cron 式をテーブルに保存します。
• nacos、分散構成を使用して動的構成 cron 式を実装します。
• XXL-JOB、分散タスク

タイマーの使用

これは現在プロジェクトで使用されることはほとんどなく、デモ コードが直接投稿されます。

詳細な紹介については、API をご覧ください:

public class TestTimer {
    public static void main(String[] args) {
        TimerTask timerTask = new TimerTask() {
            @Override
            public void run() {
                System.out.println("task  run:"+ new Date());
            }
        };
        Timer timer = new Timer();
        //安排指定的任务在指定的时间开始进行重复的固定延迟执行。这里是每3秒执行一次
        timer.schedule(timerTask,10,3000);
    }
}

Use ScheduledExecutorService

このメソッドはタイマーに似ています。デモを見てください:

public class TestScheduledExecutorService {
    public static void main(String[] args) {
        ScheduledExecutorService service = Executors.newSingleThreadScheduledExecutor();
        // 参数：1、任务体 2、首次执行的延时时间
        //      3、任务执行间隔 4、间隔时间单位
        service.scheduleAtFixedRate(()->System.out.println("task ScheduledExecutorService "+new Date()), 0, 3, TimeUnit.SECONDS);
    }
}

Use Spring Task

単純なスケジュールされたタスク

Spring Boot プロジェクトでは、アノテーションを使用して、スケジュールされたタスクを非常にエレガントに実装できます。まず、プロジェクトを作成し、依存関係をインポートします。 :

<dependencies>
  <dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
  </dependency>
  <dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter</artifactId>
  </dependency>
  <dependency>
    <groupId>org.projectlombok</groupId>
    <artifactId>lombok</artifactId>
    <optional>true</optional>
  </dependency>
  <dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-test</artifactId>
    <scope>test</scope>
  </dependency>
</dependencies>

タスク クラスを作成します:

@Slf4j
@Component
public class ScheduledService {
    @Scheduled(cron = "0/5 * * * * *")
    public void scheduled(){
        log.info("=====>>>>>使用cron  {}",System.currentTimeMillis());
    }
    @Scheduled(fixedRate = 5000)
    public void scheduled1() {
        log.info("=====>>>>>使用fixedRate{}", System.currentTimeMillis());
    }
    @Scheduled(fixedDelay = 5000)
    public void scheduled2() {
        log.info("=====>>>>>fixedDelay{}",System.currentTimeMillis());
    }
}

メイン クラスで @EnableScheduling アノテーションを使用して、スケジュールされたタスクのサポートを有効にして、プロジェクトを開始します

3 つのスケジュールされたタスクがすべて実行され、それらが同じスレッド内で連続して実行される場合、スケジュールされたタスクが 1 つだけであれば、これは間違いなく問題ありません。スケジュールされたタスクの数が増加すると、 1 つのタスクが停止すると、他のタスクは実行できなくなります。

マルチスレッド実行

従来の Spring プロジェクトでは、xml 構成ファイルにタスク構成を追加できますが、Spring Boot プロジェクトでは通常、構成を追加するために config 構成クラスを使用します。新しい AsyncConfig class

@Configuration
@EnableAsync
public class AsyncConfig {
     /*
    此处成员变量应该使用@Value从配置中读取
     */
    private int corePoolSize = 10;
    private int maxPoolSize = 200;
    private int queueCapacity = 10;
    @Bean
    public Executor taskExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setCorePoolSize(corePoolSize);
        executor.setMaxPoolSize(maxPoolSize);
        executor.setQueueCapacity(queueCapacity);
        executor.initialize();
        return executor;
    }
}

@Configuration: このクラスが構成クラスであることを示します@EnableAsync: 非同期イベントのサポートを有効にします

次に、スケジュールされたタスクのクラスまたはメソッドに @Async を追加します。最後にプロジェクトを再起動します。各タスクは別のスレッドにあります。

実行時間の構成

上記のスケジュールされたタスクでは、メソッドの @Scheduled アノテーションを使用してタスクの実行時間を設定します。 3 つのプロパティ設定方法を使用します:

1. fixedRate: 特定の頻度で実行されるスケジュールされたタスクを定義します
2. fixedDelay: 特定の頻度で実行されるスケジュールされたタスクを定義します。上記のことから、この属性を initialDelay と組み合わせて変更して、タスクの遅延実行時間を定義できることがわかります。
3. cron: 式を使用してタスクの実行時間を構成する

cron 式の詳細な説明

cron 式には少なくとも 6 つの値が含まれます(おそらく 7 つ) スペースで区切られた時間要素。順序:

• 秒 (0 ～ 59)
• # 分 (0 ～ 59)
• 3 時間 (0 ～ 23)
• 4 日 (0 ～ 31)
• 5 か月 (0 ～ 11)
• 6 週 (1~7 1=日または日、月、火、水、木、金、土)
• 年 (1970-2099)

#各要素には、値 (6 など)、連続間隔 (9 ～ 12)、間隔 (8 ～ 18/4) (/ はそれぞれ 4 時間間隔を意味します)、リスト (1,3,5)、ワイルドカード。 「日」と「曜日」の 2 つの要素は相互に排他的であるため、どちらか一方を設定する必要があります。構成例:

• 5 秒ごとに実行: */5* * ?
• 1 分ごとに実行: 0 /1 ?
• 0 0 10,14,16 ? 毎日午前 10 時、午後 2 時、午後 4 時
• 0 0/30 9-17 ? 30 分ごと9 時から 5 時までの勤務時間中
• #0 0 12 ? *WED は毎週水曜日の正午 12 時を意味します
• " 0 0 12 ?" 毎にトリガーされます毎日正午 12 時
#"0 15 10 ? "毎日午前 10 時 15 分にトリガーされます
"0 15 10 ?" 毎回トリガーされます毎日午前 10 時 15 分
• ##"0 15 10 ? *" 毎日午前 10 時 15 分にトリガーされます
• "0 15 10 ? 2005 " 2005 年の毎日午前 10 時 15 分にトリガー
• "0
14
• * ?" 毎日午後 2 時から午後 2 時 59 分まで 1 分ごと トリガー
  ##"0 0/5 14 ?" 毎日午後 2 時から午後 2 時 55 分まで 5 分ごとにトリガーします
• " 0 0/5 14,18 ?" 午後 2 時から午後 2 時 55 分までは 5 分ごとにトリガーし、午後 6 時から午後 6 時 55 分までは 5 分ごとにトリガーします。
• "0 0-5 14 ?" 午後 2 時から午後 2 時までは 1 分ごとにトリガーします毎日午後 5 時
• 「0 10,44 14 ? 3 WED」 3 月の毎週水曜日午後 2 時: 10 時と 2 時 44 分にトリガー
• "0 15 10 ? * MON-FRI" 月曜日から金曜日の午前 10 時 15 分にトリガーされます。
• "0 15 10 15 * ?" 月曜日から金曜日の午前 10 時 15 分にトリガーされます。毎月 15 日
• 「0 15 10 L * ?」毎月末日の午前 10 時 15 分にトリガー
• " 0 15 10 ? * 6L" 毎月最終金曜日の午前 10 時 15 分にトリガーされます
• "0 15 10 ? * 6L 2002- 2005" 各月の最終金曜日にトリガーされます2002 年から 2005 年の月の午前 10 時 15 分
• "0 15 10 ? * 6#3" 毎月第 3 金曜日の午前 10 時 :15 トリガー
• 一部の部分式には範囲またはリストを含めることができます

例: 部分式 (日 (週)) は、「MON-FRI」、「MON、WED、FRI」にすることができます。 、「MON-WED,SAT」

「*」文字はすべての可能な値を表します 「/」文字は値の増分を指定するために使用されます

例: 部分式 (分) の「0/15」は、0 分から 15 分ごとに開始することを意味します。 部分式(分)の「3/20」は、3分から20分ごと(「3、23、43」と同じ意味です)

"?"を意味します。文字は、日 (月) と日 (週) の 2 つの部分式でのみ使用され、値が指定されていないことを示します。 2 つの部分式のいずれかに値が割り当てられている場合、競合を避けるために、もう一方の部分式の値を「?」に設定する必要があります。

「L」文字は日 (月) にのみ使用されます。および day (week) は 2 つの部分式であり、単語「last」の省略形です。 「L」の前に何か特定のものがある場合、それは他の意味を持ちます。

例: 「6L」は今月の 6 日から末日までを意味します 注: 「L」パラメータを使用する場合は、問題が発生するため、リストまたは範囲を指定しないでください。

#W 文字は平日 (月曜から金曜) を表し、日中にのみ使用できます。ドメイン。指定した日付に最も近い平日を指定するために使用されます。ほとんどの業務処理は週の労働時間に基づいているため、W の文字は非常に重要です。

たとえば、日フィールドの 15W は、「月の 15 日に最も近い平日」を意味します。15 日が土曜日の場合、トリガーは 14 日 (金曜日) にトリガーされます。木曜日は月曜日よりも小さいので、15日に近いからです。

C: 「カレンダー」の略です。これは、スケジュールに関連付けられた日付、または日付が関連付けられていない場合はカレンダー内のすべての日付を意味します。

たとえば、日付フィールドの 5C は、カレンダーの 5 日後の最初の日に相当します。曜日フィールドの 1C は、日曜日の後の最初の日に対応します。

##秒0~59, - * /##分時間 日付1-31, - * ? / L W C1~12 または JAN~DEC1~7 または SUN~SAT空白のまま、1970~2099

フィールド	許可される値	許可される特殊文字
0~59	, - * /
#0~23	, - * /
		##month
, - * /		平日
, - * ? / L C		#年 (オプション)
、- * /		在线cron表达式生成：http://qqe2.com/cron/index 整合Quartz 添加依赖 如果Spring Boot版本是2.0.0以后的，则在spring-boot-starter中已经包含了quart的依赖，则可以直接使用spring-boot-starter-quartz依赖： <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-quartz</artifactId> </dependency> 如果是1.5.9则要使用以下添加依赖： <dependency> <groupId>org.quartz-scheduler</groupId> <artifactId>quartz</artifactId> <version>2.3.0</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-context-support</artifactId> </dependency> 这里我使用Spring Boot版本是2.0.0.BUILD-SNAPSHOT ，该版本开始集成了Quartz，所以事实现起来很方便。其它好像比较麻烦，这里就不介绍，以后有时间再详细深入了解Quartz。 创建任务类TestQuartz，该类主要是继承了QuartzJobBean public class TestQuartz extends QuartzJobBean { /** * 执行定时任务 * @param jobExecutionContext * @throws JobExecutionException */ @Override protected void executeInternal(JobExecutionContext jobExecutionContext) throws JobExecutionException { System.out.println("quartz task "+new Date()); } } 创建配置类QuartzConfig @Configuration public class QuartzConfig { @Bean public JobDetail teatQuartzDetail(){ return JobBuilder.newJob(TestQuartz.class).withIdentity("testQuartz").storeDurably().build(); } @Bean public Trigger testQuartzTrigger(){ SimpleScheduleBuilder scheduleBuilder = SimpleScheduleBuilder.simpleSchedule() .withIntervalInSeconds(10) //设置时间周期单位秒 .repeatForever(); return TriggerBuilder.newTrigger().forJob(teatQuartzDetail()) .withIdentity("testQuartz") .withSchedule(scheduleBuilder) .build(); } } 启动项目 最后 上面都是简单的介绍了关于Spring Boot定时任务的处理，直接使用SpringTask注解的方式应该是最方便的，而使用Quartz从2.0开始也变得很方便。对于这两种方式，应该说各有长处吧，按需选择。 以上がSpring Boot で複数のスケジュールされたタスクを実装する方法の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。 このウェブサイトの声明 この記事の内容はネチズンが自主的に寄稿したものであり、著作権は原著者に帰属します。このサイトは、それに相当する法的責任を負いません。盗作または侵害の疑いのあるコンテンツを見つけた場合は、admin@php.cn までご連絡ください。 ホットAIツール Undresser.AI Undress リアルなヌード写真を作成する AI 搭載アプリ AI Clothes Remover 写真から衣服を削除するオンライン AI ツール。 Undress AI Tool 脱衣画像を無料で Clothoff.io AI衣類リムーバー Video Face Swap 完全無料の AI 顔交換ツールを使用して、あらゆるビデオの顔を簡単に交換できます。 もっと見る 人気の記事 アサシンのクリードシャドウズ：シーシェルリドルソリューション 3週間前 By DDD Windows11 KB5054979の新しいものと更新の問題を修正する方法 2週間前 By DDD Atomfallのクレーンコントロールキーカードを見つける場所 3週間前 By DDD <🎜>：Dead Rails-すべての課題を完了する方法 4週間前 By DDD Atomfall Guide：アイテムの場所、クエストガイド、およびヒント 1 か月前 By DDD もっと見る ホットツール メモ帳++7.3.1 使いやすく無料のコードエディター SublimeText3 中国語版 中国語版、とても使いやすい ゼンドスタジオ 13.0.1 強力な PHP 統合開発環境 ドリームウィーバー CS6 ビジュアル Web 開発ツール SublimeText3 Mac版 神レベルのコード編集ソフト（SublimeText3） もっと見る ホットトピック Gmailメールのログイン入り口はどこですか？ 7677 15 CakePHP チュートリアル 1393 52 C# チュートリアル 1207 24 Steamのアカウント名の形式は何ですか 91 11 Win11 Activation Key Permanent 73 19 もっと見る Related knowledge Spring Boot + MyBatis + Atomikos + MySQL (ソースコード付き) Aug 15, 2023 pm 04:12 PM 実際のプロジェクトでは、分散トランザクションを避けるように努めます。ただし、場合によってはサービスを分割する必要があり、分散トランザクションの問題が発生することがあります。同時に、分散取引についても面接で質問されるので、このケースで練習し、面接で 123 について話すことができます。 Spring Boot を通じて多言語サポートと国際アプリケーションを実現 Jun 23, 2023 am 09:09 AM グローバリゼーションの進展に伴い、多言語サポートや国際化機能を提供する必要のある Web サイトやアプリケーションがますます増えています。開発者にとって、これらの機能を実装することは、言語翻訳、日付、時刻、通貨の形式など、多くの側面を考慮する必要があるため、簡単な作業ではありません。ただし、SpringBoot フレームワークを使用すると、多言語サポートと国際アプリケーションを簡単に実装できます。まず、SpringBoot が提供する LocaleResolver インターフェースについて理解しましょう。ロック Spring Boot を使用してビッグデータ処理アプリケーションを構築する方法 Jun 23, 2023 am 09:07 AM ビッグデータ時代の到来により、ますます多くの企業がビッグデータの価値を理解し、認識し、ビジネスに活用し始めています。それに伴う問題は、この大規模なデータ フローをどのように処理するかです。この場合、ビッグ データ処理アプリケーションは、すべての企業が検討しなければならないものになっています。開発者にとっては、SpringBoot を使用して効率的なビッグデータ処理アプリケーションを構築する方法も非常に重要な問題です。 SpringBoot は非常に人気のある Java フレームワークです。 Spring Boot を使用してブロックチェーン アプリケーションとスマート コントラクトを構築する方法 Jun 22, 2023 am 09:33 AM ビットコインなどのデジタル通貨の台頭により、ブロックチェーン技術が徐々に話題になっています。スマート コントラクトは、ブロックチェーン テクノロジーの重要な部分とみなすことができます。 SpringBoot は、人気のある Java バックエンド開発フレームワークとして、ブロックチェーン アプリケーションやスマート コントラクトの構築にも使用できます。この記事では、SpringBoot を使用してブロックチェーン テクノロジーに基づいたアプリケーションとスマート コントラクトを構築する方法を紹介します。 1. SpringBoot とブロックチェーン まず、ブロックチェーンに関連するいくつかの基本概念を理解する必要があります。ブロックチェーン Spring Boot と MyBatis Plus に基づいて ORM マッピングを実装する Jun 22, 2023 pm 09:27 PM Java Web アプリケーションの開発プロセスでは、ORM (Object-RelationalMapping) マッピング テクノロジを使用してデータベース内のリレーショナル データを Java オブジェクトにマッピングし、開発者がデータにアクセスして操作するのを容易にします。 SpringBoot は、最も人気のある Java Web 開発フレームワークの 1 つとして、MyBatis を統合する方法を提供しています。MyBatisPlus は、MyBatis に基づいて拡張された ORM フレームワークです。 Spring Boot と NoSQL データベースの統合と使用 Jun 22, 2023 pm 10:34 PM インターネットの発展に伴い、ビッグデータ分析とリアルタイム情報処理が企業にとって重要なニーズとなっています。このようなニーズを満たすために、従来のリレーショナル データベースはビジネスやテクノロジー開発のニーズを満たせなくなりました。代わりに、NoSQL データベースを使用することが重要なオプションになっています。この記事では、最新のアプリケーションの開発と展開を可能にする、NoSQL データベースと統合された SpringBoot の使用について説明します。 NoSQL データベースとは何ですか? NoSQL は SQL だけではありません Spring Boot と Apache ServiceMix を使用した ESB システムの構築 Jun 22, 2023 pm 12:30 PM 現代のビジネスがさまざまな異種のアプリケーションやシステムにますます依存するようになるにつれて、企業の統合がさらに重要になります。 Enterprise Service Bus (ESB) は、さまざまなシステムとアプリケーションを接続して共通のデータ交換サービスとメッセージ ルーティング サービスを提供し、エンタープライズ レベルのアプリケーション統合を実現する統合アーキテクチャ モデルです。 SpringBootとApacheServiceMixを使えば簡単にESBシステムを構築できるので、その実装方法を紹介します。 SpringBoot と A Spring Boot に基づく分散データ キャッシュおよびストレージ システム Jun 22, 2023 am 09:48 AM インターネットの継続的な発展と普及に伴い、データの処理と保存の需要も増加しており、データを効率的かつ確実に処理および保存する方法が業界や研究者の間で話題になっています。 SpringBoot をベースとした分散データ キャッシュおよびストレージ システムは、近年大きな注目を集めているソリューションです。分散データ キャッシュおよびストレージ システムとは何ですか?分散データ キャッシュおよびストレージ システムとは、複数のノード (サーバー) を介したデータの分散ストレージを指します。これにより、データのセキュリティと信頼性が向上し、データ処理も向上します。 See all articles 福祉オンライン PHP トレーニング，PHP 学習者の迅速な成長を支援します！ 私たちについて 免責事項 Sitemap © php.cn All rights reserved