扫码关注官方微信

扫码下载APP
返回顶部
首页 > 资讯 > 后端开发 > Python >一文搞懂SpringBoot如何利用@Async实现异步调用
  • 426

0
分享到

一文搞懂SpringBoot如何利用@Async实现异步调用

2024-04-02 19:04:59 426人浏览 泡泡鱼

Python 官方文档：入门教程 => 点击学习

摘要

目录前言简单使用异步处理异步回调自定义线程池注意事项（一定注意）前言 异步调用几乎是处理高并发，解决性能问题常用的手段，如何开启异步调用？SpringBoot中提供了非常简单的方式，

前言

异步调用几乎是处理高并发，解决性能问题常用的手段，如何开启异步调用？SpringBoot中提供了非常简单的方式，就是一个注解@Async。今天我们重新认识一下@Async,以及注意事项

简单使用

新建三个作业任务：

@Service
public class TaskDemo {
    private static Logger logger = LoggerFactory.getLogger(TaskDemo.class);
    public void execute1() {
        logger.info("处理耗时任务1......开始");
        try {
            TimeUnit.SECONDS.sleep(3);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        logger.info("处理耗时任务1......结束");
    }
    public void execute2() {
        logger.info("处理耗时任务2......开始");
        try {
            TimeUnit.SECONDS.sleep(3);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        logger.info("处理耗时任务2......结束");
    }
    public void execute3() {
        logger.info("处理耗时任务3......开始");
        try {
            TimeUnit.SECONDS.sleep(3);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        logger.info("处理耗时任务3......结束");
    }
}

测试代码：

@RestController
public class TaskController {
    @Autowired
    private TaskDemo taskDemo;

    @GetMapping("/task/test")
    public String testTask() {
        taskDemo.execute1();
        taskDemo.execute2();
        taskDemo.execute3();
        return "ok";
    }
}

执行后我们可以发现，上面的代码是同一个线程的同步执行，整体耗时9秒才完成。

异步处理

springboot的异步，是非常简单的，加2个注解即可

@Service
public class TaskDemo {

    private static Logger logger = LoggerFactory.getLogger(TaskDemo.class);

    @Async
    public void execute1() {
        logger.info("处理耗时任务1......开始");
        try {
            TimeUnit.SECONDS.sleep(3);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        logger.info("处理耗时任务1......结束");
    }

    @Async
    public void execute2() {
        logger.info("处理耗时任务2......开始");
        try {
            TimeUnit.SECONDS.sleep(3);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        logger.info("处理耗时任务2......结束");
    }

    @Async
    public void execute3() {
        logger.info("处理耗时任务3......开始");
        try {
            TimeUnit.SECONDS.sleep(3);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        logger.info("处理耗时任务3......结束");
    }

}
@SpringBootApplication
@EnableAsync
public class DemoApp {
    public static void main(String[] args) {
        SpringApplication.run(DemoApp.class,args);
    }
}

增加了@Async和@EnableAsync两个注解

从执行结果发现，整个流程用了3秒，以及用了3个线程执行。完成了异步调用

异步回调

有些场景我们需要知道异步处理的任务什么时候完成，需要做额外的业务处理。如：我们需要在3个任务都完成后，提示一下给用户

@Service
public class TaskDemo {

    private static Logger logger = LoggerFactory.getLogger(TaskDemo.class);

    @Async
    public Future<String> execute1() {
        logger.info("处理耗时任务1......开始");
        try {
            TimeUnit.SECONDS.sleep(3);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        logger.info("处理耗时任务1......结束");

        return new AsyncResult<>("任务1 ok");
    }

    @Async
    public Future<String> execute2() {
        logger.info("处理耗时任务2......开始");
        try {
            TimeUnit.SECONDS.sleep(3);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        logger.info("处理耗时任务2......结束");

        return new AsyncResult<>("任务2 ok");
    }

    @Async
    public Future<String> execute3() {
        logger.info("处理耗时任务3......开始");
        try {
            TimeUnit.SECONDS.sleep(3);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        logger.info("处理耗时任务3......结束");

        return new AsyncResult<>("任务3 ok");
    }
}
@RestController
public class TaskController {

    private static Logger logger = LoggerFactory.getLogger(TaskController.class);

    @Autowired
    private TaskDemo taskDemo;

    @GetMapping("/task/test")
    public String testTask() throws InterruptedException {
        Future<String> task1 = taskDemo.execute1();
        Future<String> task2 = taskDemo.execute2();
        Future<String> task3 = taskDemo.execute3();

        while (true){
            if (task1.isDone() && task2.isDone() && task3.isDone()){
                break;
            }
            TimeUnit.SECONDS.sleep(1);
        }

        logger.info(">>>>>>3个任务都处理完成");
        return "ok";
    }
}

执行结果发现，在请求线程里面给用户提示了3个任务都处理完成了。

这段代码主要改变了什么：

1、把具体任务返回类型改为了Future类型对象

2、在调用任务时，循环判断任务是否处理完

自定义线程池

说到异步处理，一定要考虑到线程池，什么是线程池，小伙伴可自行网补。@Async的线程池定义比较方便，直接上代码：

@Configuration
public class ThreadPoolConfig {

    @Bean(name = "taskPool01Executor")
    public ThreadPoolTaskExecutor getTaskPool01Executor() {

        ThreadPoolTaskExecutor taskExecutor = new ThreadPoolTaskExecutor();
        //核心线程数
        taskExecutor.setCorePoolSize(10);
        //线程池维护线程的最大数量,只有在缓冲队列满了之后才会申请超过核心线程数的线程
        taskExecutor.setMaxPoolSize(100);
        //缓存队列
        taskExecutor.setQueueCapacity(50);
        //许的空闲时间,当超过了核心线程出之外的线程在空闲时间到达之后会被销毁
        taskExecutor.seTKEepAliveSeconds(200);
        //异步方法内部线程名称
        taskExecutor.setThreadNamePrefix("TaskPool-01-");
        
        taskExecutor.setRejectedExecutionHandler(new ThreadPoolExecutor.AbortPolicy());
        taskExecutor.setWaitForTasksToCompleteOnShutdown(true);

        taskExecutor.initialize();

        return taskExecutor;
    }

    @Bean(name = "taskPool02Executor")
    public ThreadPoolTaskExecutor getTaskPool02Executor() {

        ThreadPoolTaskExecutor taskExecutor = new ThreadPoolTaskExecutor();
        //核心线程数
        taskExecutor.setCorePoolSize(10);
        //线程池维护线程的最大数量,只有在缓冲队列满了之后才会申请超过核心线程数的线程
        taskExecutor.setMaxPoolSize(100);
        //缓存队列
        taskExecutor.setQueueCapacity(50);
        //许的空闲时间,当超过了核心线程出之外的线程在空闲时间到达之后会被销毁
        taskExecutor.setKeepAliveSeconds(200);
        //异步方法内部线程名称
        taskExecutor.setThreadNamePrefix("TaskPool-02-");
        
        taskExecutor.setRejectedExecutionHandler(new ThreadPoolExecutor.AbortPolicy());
        taskExecutor.setWaitForTasksToCompleteOnShutdown(true);

        taskExecutor.initialize();

        return taskExecutor;
    }

}

定义了2个线程池Bean

@Service
public class TaskDemo {

    private static Logger logger = LoggerFactory.getLogger(TaskDemo.class);

    @Async("taskPool01Executor")
    public Future<String> execute1() {
        logger.info("处理耗时任务1......开始");
        try {
            TimeUnit.SECONDS.sleep(3);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        logger.info("处理耗时任务1......结束");

        return new AsyncResult<>("任务1 ok");
    }

    @Async("taskPool01Executor")
    public Future<String> execute2() {
        logger.info("处理耗时任务2......开始");
        try {
            TimeUnit.SECONDS.sleep(3);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        logger.info("处理耗时任务2......结束");

        return new AsyncResult<>("任务2 ok");
    }

    @Async("taskPool02Executor")
    public Future<String> execute3() {
        logger.info("处理耗时任务3......开始");
        try {
            TimeUnit.SECONDS.sleep(3);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        logger.info("处理耗时任务3......结束");

        return new AsyncResult<>("任务3 ok");
    }

}

@Async(“线程池名称”)，指定value使用自己定义的线程池：

执行结果利用了线程池。

注意事项（一定注意）

在使用@Async注解时，很多小伙伴都会发现异步使用失败。主要原因是异步方法的定义出了问题。

1、异步方法不能使用static修饰

2、异步类没有使用@Component注解（或其他注解）导致spring无法扫描到异步类

3、异步方法和调用异步方法的方法不能在同一个类

4、类中需要使用@Autowired或@Resource等注解自动注入，不能自己手动new对象

5、如果使用SpringBoot框架必须在启动类中增加@EnableAsync注解​

到此这篇关于一文搞懂SpringBoot如何利用@Async实现异步调用的文章就介绍到这了,更多相关SpringBoot @Async异步调用内容请搜索编程网以前的文章或继续浏览下面的相关文章希望大家以后多多支持编程网！

您可能感兴趣的文档:

--结束END--

本文标题: 一文搞懂SpringBoot如何利用@Async实现异步调用

本文链接: https://lsjlt.com/news/167151.html(转载时请注明来源链接)

有问题或投稿请发送至: 邮箱/279061341@qq.com    QQ/279061341

猜你喜欢
  • 一文搞懂SpringBoot如何利用@Async实现异步调用
    目录前言简单使用异步处理异步回调自定义线程池注意事项（一定注意）前言 异步调用几乎是处理高并发，解决性能问题常用的手段，如何开启异步调用？SpringBoot中提供了非常简单的方式，...
    99+
    2024-04-02
  • 一文详解SpringBoot如何优雅地实现异步调用
    目录前言实现步骤自定义异步任务执行器和异常处理@Async如何工作的总结前言 SpringBoot想必大家都用过，但是大家平时使用发布的接口大都是同步的，那么你知道如何优雅的实现异步...
    99+
    2023-03-19
    SpringBoot实现异步调用 SpringBoot异步调用 SpringBoot调用
  • Java SpringBoot @Async如何实现异步任务
    本篇内容介绍了“Java SpringBoot @Async如何实现异步任务”的有关知识，在实际案例的操作过程中，不少人都会遇到这样的困境，接下来就让小编带领大家学习一下如何处理这些情况吧！希望大家仔细阅读，能够学有所成...
    99+
    2023-07-04
  • 在spring boot中如何使用@Async实现异步调用
    在spring boot中如何使用@Async实现异步调用？相信很多没有经验的人对此束手无策，为此本文总结了问题出现的原因和解决方法，通过这篇文章希望你能解决这个问题。什么是”异步调用”与”同步调用”“同步调用”就是程序按照一定的顺序依次执...
    99+
    2023-05-31
    springboot @async 异步调用
  • springboot @Async 注解如何实现方法异步
    目录@Async注解如何实现方法异步一、springboot的App类需要的注解二、service层的注解三、调用层异步注解@Async的使用以及注意事项第一步开启异步下面显示配置线...
    99+
    2024-04-02
  • 一文搞懂Vue3中的异步组件defineAsyncComponentAPI的用法
    目录前言传递工厂函数作为参数传递对象类型作为参数总结前言 当我们的项目达到一定的规模时，对于某些组件来说，我们并不希望一开始全部加载，而是需要的时候进行加载；这样的做得目的可以很好的...
    99+
    2024-04-02
  • Spring中的如何使用@Async异步调用
    这篇文章主要介绍了Spring中的如何使用@Async异步调用，具有一定借鉴价值，感兴趣的朋友可以参考下，希望大家阅读完这篇文章之后大有收获，下面让小编带着大家一起了解一下。使用@Async异步调用方法Async简介异步方法调用使用场景：处...
    99+
    2023-06-25
  • 一文搞懂如何实现Go 超时控制
    为什么需要超时控制？ 请求时间过长，用户侧可能已经离开本页面了，服务端还在消耗资源处理，得到的结果没有意义 过长时间的服务端处理会占用过多资源，导致并发能力下降，甚至...
    99+
    2022-06-07
    GO
  • JavaScript如何实现异步调用
    小编给大家分享一下JavaScript如何实现异步调用，相信大部分人都还不怎么了解，因此分享这篇文章给大家参考一下，希望大家阅读完这篇文章后大有收获，下面让我们一起去了解一下吧！问题可修改下面的 aa() ...
    99+
    2024-04-02
  • 如何实现WCF异步调用
    小编给大家分享一下如何实现WCF异步调用，相信大部分人都还不怎么了解，因此分享这篇文章给大家参考一下，希望大家阅读完这篇文章后大有收获，下面让我们一起去了解一下吧！原来上网我下了很多WCF异步调用Demo。而我用的是VS2005，我在使用这...
    99+
    2023-06-17
  • WCF如何实现异步调用
    这篇文章主要为大家展示了“WCF如何实现异步调用”，内容简而易懂，条理清晰，希望能够帮助大家解决疑惑，下面让小编带领大家一起研究并学习一下“WCF如何实现异步调用”这篇文章吧。异步调用是编程中不可缺少的，在工作中积累一点经验，现在我们里关注...
    99+
    2023-06-17
  • 一文搞懂JavaScript如何实现图片懒加载
    目录实现思路准备知识data-*getBoundingClientRect()throttlewindow.innerHeight完整代码js部分CSS部分运行结果总结图片懒加载，往...
    99+
    2024-04-02
  • C#中如何实现异步调用
    C#中如何实现异步调用，很多新手对此不是很清楚，为了帮助大家解决这个难题，下面小编将为大家详细讲解，有这方面需求的人可以来学习下，希望你能有所收获。.NET Framework 允许您C#异步调用任何方法。定义与您需要调用的方法具有相同签名...
    99+
    2023-06-17
  • Java中如何实现异步调用
    Java中如何实现异步调用，相信很多没有经验的人对此束手无策，为此本文总结了问题出现的原因和解决方法，通过这篇文章希望你能解决这个问题。@Test一、创建线程public void test0() throws...
    99+
    2023-06-02
  • 一文搞懂MySQL XA如何实现分布式事务
    目录前言XA 协议如何通过MySQL XA实现分布式事务前言 MySQL支持单机事务的良好表现毋庸置疑，那么在分布式系统中，涉及多个节点，MySQL又是如何实现分布式事务的呢？比如开...
    99+
    2024-04-02
  • springboot怎么利用aop实现接口异步
    小编给大家分享一下springboot怎么利用aop实现接口异步，希望大家阅读完这篇文章之后都有所收获，下面让我们一起去探讨吧！一、前言在项目中发现有接口（excel导入数据）处理数据需要耗时比较长的时间，是因为数据量比较大，同时数据的校验...
    99+
    2023-06-22
  • SpringBoot怎么优雅地实现异步调用
    这篇文章主要讲解了“SpringBoot怎么优雅地实现异步调用”，文中的讲解内容简单清晰，易于学习与理解，下面请大家跟着小编的思路慢慢深入，一起来研究和学习“SpringBoot怎么优雅地实现异步调用”吧！前言同步编程：在同步编程中，任务一...
    99+
    2023-07-05
  • 如何利用HTML5实现图片文件异步上传
    小编给大家分享一下如何利用HTML5实现图片文件异步上传，相信大部分人都还不怎么了解，因此分享这篇文章给大家参考一下，希望大家阅读完这篇文章后大有收获，下面让我们一起去了解一下吧！ 1.文件未选择 2.文...
    99+
    2024-04-02
  • C#中怎么利用委托实现异步调用
    这篇文章将为大家详细讲解有关C#中怎么利用委托实现异步调用，文章内容质量较高，因此小编分享给大家做个参考，希望大家阅读完这篇文章后对相关知识有一定的了解。委托实现C#异步调用的步骤：定义委托。将要进行异步调用的方法“实例化”到定义的委托。在...
    99+
    2023-06-17
  • 如何使用IDEA开发Spark SQL程序(一文搞懂)
    目录前言Spark SQL是什么1、使用IDEA开发Spark SQL 1.1、指定列名添加Schema1.2、通过StructType指定Schema1.3、反射推断Sc...
    99+
    2024-04-02
软考高级职称资格查询
热门wiki
近期文章
推荐阅读
热门问答
热门标签
编程网，编程工程师的家园，是目前国内优秀的开源技术社区之一，形成了由开源软件库、代码分享、资讯、协作翻译、讨论区和博客等几大频道内容，为IT开发者提供了一个发现、使用、并交流开源技术的平台。

  • 官方手机版

  • 微信公众号

  • 商务合作