7、SpringBoot整合实现异步任务

喜欢ヅ旅行 2023-10-08 17:12 25阅读 0赞

## 注解使用 ##

*  使用注解@EnableAsync开启异步,会自动扫描
 *  定义 @Component @Async作为组件被容器扫描执行

## 代码实现 ##

**1、启动类 @EnableAsync**

@EnableAsync //开启异步，会自动扫描
    public class SpringbootStartApplication {
        
    
    	public static void main(String[] args) {
        
    		SpringApplication.run(SpringbootStartApplication.class, args);
    	}
    }

**2、定义任务类**

注意：一定要加入@Async 注解，否则就是同步任务了

package com.springboot.test.task;
    
    import org.springframework.scheduling.annotation.Async;
    import org.springframework.scheduling.annotation.AsyncResult;
    import org.springframework.stereotype.Component;
    
    import java.util.concurrent.Future;
    
    /**
     * @author cf
     *  异步任务类
     */
    @Component
    public class AsyncTask {
        
    
        @Async
        public Future<Boolean> doTaskA() throws Exception {
        
            long start = System.currentTimeMillis();
            Thread.sleep(1000);
            long end = System.currentTimeMillis();
            System.out.println("任务1耗时："+(end - start)+"毫秒");
            return new AsyncResult<>(true);
        }
    
        @Async
        public Future<Boolean> doTaskB() throws Exception {
        
            long start = System.currentTimeMillis();
            Thread.sleep(500);
            long end = System.currentTimeMillis();
            System.out.println("任务2耗时："+(end - start)+"毫秒");
            return new AsyncResult<>(true);
        }
    
    
        @Async
        public Future<Boolean> doTaskC() throws Exception {
        
            long start = System.currentTimeMillis();
            Thread.sleep(100);
            long end = System.currentTimeMillis();
            System.out.println("任务4耗时："+(end - start)+"毫秒");
            return new AsyncResult<>(true);
        }
    }

**3、调用任务**

package com.springboot.test.controller;
    
    import com.alibaba.fastjson.JSON;
    import com.springboot.test.task.AsyncTask;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.web.bind.annotation.GetMapping;
    import org.springframework.web.bind.annotation.RestController;
    
    import java.util.concurrent.Future;
    
    @RestController
    public class TaskController {
        
    
        @Autowired
        AsyncTask asyncTask;
    
        @GetMapping("task/run")
        public String run() throws Exception {
        
            long start = System.currentTimeMillis();
    
            Future<Boolean> a = asyncTask.doTaskA();
            Future<Boolean> b = asyncTask.doTaskB();
            Future<Boolean> c = asyncTask.doTaskC();
    
            //isDone任务已完成，则返回true，所有任务完成在走下去
            while (!a.isDone() || !b.isDone() || !c.isDone()){
        
                if (a.isDone() && b.isDone() && c.isDone()) {
        
                    break;
                }
            }
    
            long end = System.currentTimeMillis();
    
            String times = "任务全部完成，总耗时："+(end - start)+"毫秒";
            return JSON.toJSONString(times);
        }
    }

**返回结果：**  
![在这里插入图片描述][36490a2b82e441ab99c61f6d8dc1018e.png]

## 应用场景 ##

一般以下场景都可以使用，但是也有其他的方法，比如消息中间件啊，线程池也可以实现，要看自己怎么选择了。

*  发送短信
 *  App消息推送
 *  发送邮件
 *  节省运维凌晨发布任务时间提供效率

[36490a2b82e441ab99c61f6d8dc1018e.png]: https://img-blog.csdnimg.cn/36490a2b82e441ab99c61f6d8dc1018e.png