【SpringBoot】整合定时任务和异步任务

2022-10-15 17:52:07

========================10、SpringBoot整合定时任务和异步任务处理 ===============================

1、SpringBoot定时任务schedule讲解
简介：讲解什么是定时任务和常见定时任务区别

1、常见定时任务 Java自带的java.util.Timer类
timer:配置比较麻烦，时间延后问题
timertask:不推荐

2、Quartz框架
配置更简单
xml或者注解

3、SpringBoot使用注解方式开启定时任务
1）启动类里面 @EnableScheduling开启定时任务，自动扫描
2）定时任务业务类加注解 @Component被容器扫描
3）定时执行的方法加上注解 @Scheduled(fixedRate=2000) 定期执行一次

2、SpringBoot常用定时任务配置实战
简介：SpringBoot常用定时任务表达式配置和在线生成器

package net.xdclass.base_project.task;

import java.util.Date;

import org.springframework.scheduling.annotation.Scheduled;

import org.springframework.stereotype.Component;

/**

 * 功能描述：定时任务业务类

 *

 * <p> 创建时间：Apr 30, 2018 10:21:48 AM </p>

 *

 *@作者 小D课堂  小D

 */

@Component

public class TestTask {

    @Scheduled(fixedRate=2000) //两秒执行一次

    public void sum(){

        System.out.println("当前时间:"+new Date());

    }

}

Task

控制台

1、cron 定时任务表达式 @Scheduled(cron="*/1 * * * * *") 表示每秒
1）crontab 工具 https://tool.lu/crontab/
2、fixedRate: 定时多久执行一次（上一次开始执行时间点后xx秒再次执行；）
3、fixedDelay: 上一次执行结束时间点后xx秒再次执行
4、fixedDelayString: 字符串形式，可以通过配置文件指定

流程:新建任务类注册到context,通过@Scheduled注解自动执行

package net.xdclass.base_project.task;

import java.util.Date;

import org.springframework.scheduling.annotation.Scheduled;

import org.springframework.stereotype.Component;

/**

 * 功能描述：定时任务业务类

 *

 * <p> 创建时间：Apr 30, 2018 10:21:48 AM </p>

 *

 *@作者 小D课堂  小D

 */

@Component

public class TestTask {

    @Scheduled(fixedRateString="2000")//两秒执行一次

    //@Scheduled(cron="*/2 * * * * *")

    public void sum() throws InterruptedException{

        Thread.sleep(4000L);

        System.out.println("结束 当前时间:"+new Date());

    }

    //@Scheduled(cron="*/1 * * * * *")

    public void sum2(){

        System.out.println("cron 每秒 当前时间:"+new Date());

    }

}

task

3、SpringBoot2.x异步任务实战（核心知识）
简介：讲解什么是异步任务，和使用SpringBoot2.x开发异步任务实战
1、什么是异步任务和使用场景：适用于处理log、发送邮件、短信……等
下单接口->查库存 100
余额校验 150
风控用户100
....

2、启动类里面使用@EnableAsync注解开启功能，自动扫描

3、定义异步任务类并使用@Component标记组件被容器扫描,异步方法加上@Async(可以注解到类)

流程:新建任务类注册到context, controller成员属性注入任务类, 成员方法中执行任务类方法
注意点：
1）要把异步任务封装到类里面，不能直接写到Controller
2）增加Future<String> 返回结果 AsyncResult<String>("task执行完成");
3）如果需要拿到结果需要判断全部的 task.isDone()
4、通过注入方式，注入到controller里面，如果测试前后区别则改为同步则把Async注释掉

package net.xdclass.base_project.task;

import java.util.concurrent.Future;

import org.springframework.scheduling.annotation.Async;

import org.springframework.scheduling.annotation.AsyncResult;

import org.springframework.stereotype.Component;

/**

 * 功能描述：异步任务业务类

 *

 * <p> 创建时间：Apr 30, 2018 11:25:15 PM </p>

 *

 *@作者 小D课堂  小D

 */

@Component

//@Async

public class AsyncTask {

    public void task1() throws InterruptedException{

        long begin = System.currentTimeMillis();

        Thread.sleep(1000L);

        long end = System.currentTimeMillis();

        System.out.println("任务1耗时="+(end-begin));

    }

    public void task2() throws InterruptedException{

        long begin = System.currentTimeMillis();

        Thread.sleep(2000L);

        long end = System.currentTimeMillis();

        System.out.println("任务2耗时="+(end-begin));

    }

    public void task3() throws InterruptedException{

        long begin = System.currentTimeMillis();

        Thread.sleep(3000L);

        long end = System.currentTimeMillis();

        System.out.println("任务3耗时="+(end-begin));

    }

    //获取异步结果

    public Future<String> task4() throws InterruptedException{

        long begin = System.currentTimeMillis();

        Thread.sleep(2000L);

        long end = System.currentTimeMillis();

        System.out.println("任务4耗时="+(end-begin));

        return new AsyncResult<String>("任务4");

    }

    public Future<String> task5() throws InterruptedException{

        long begin = System.currentTimeMillis();

        Thread.sleep(3000L);

        long end = System.currentTimeMillis();

        System.out.println("任务5耗时="+(end-begin));

        return new AsyncResult<String>("任务5");

    }

    public Future<String> task6() throws InterruptedException{

        long begin = System.currentTimeMillis();

        Thread.sleep(1000L);

        long end = System.currentTimeMillis();

        System.out.println("任务6耗时="+(end-begin));

        return new AsyncResult<String>("任务6");

    }

}

AsynTask

package net.xdclass.base_project.controller;

import java.util.concurrent.Future;

import net.xdclass.base_project.domain.JsonData;

import net.xdclass.base_project.task.AsyncTask;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.web.bind.annotation.GetMapping;

import org.springframework.web.bind.annotation.RequestMapping;

import org.springframework.web.bind.annotation.RestController;

@RestController

@RequestMapping("/api/v1")

public class UserController {

    @Autowired

    private AsyncTask task;

    @GetMapping("async_task")

    public JsonData exeTask() throws InterruptedException{

        long begin = System.currentTimeMillis();

//        task.task1();

//        task.task2();

//        task.task3();

        Future<String> task4 = task.task4();

        Future<String> task5 = task.task5();

        Future<String> task6 = task.task6();

        for(;;){

            if (task4.isDone() && task5.isDone() && task6.isDone()) {

                break;

            }

        }

        long end = System.currentTimeMillis();

        long total = end-begin;

        System.out.println("执行总耗时="+total);

        return JsonData.buildSuccess(total);

    }

}

controller

异步执行,拿回结果,

码农公寓

相关文章