文档章节

Spring源码学习之:@async 方法上添加该注解实现异步调用的原理

JackY-Ji
 JackY-Ji
发布于 2017/02/16 19:21
字数 1333
阅读 303
收藏 1
  • Spring源码学习之:@async 方法上添加该注解实现异步调用的原理

    在我们使用spring框架的过程中,在很多时候我们会使用@async注解来异步执行某一些方法,提高系统的执行效率。今天我们来探讨下 spring 是如何完成这个功能的。

        spring 在扫描bean的时候会扫描方法上是否包含@async的注解,如果包含的,spring会为这个bean动态的生成一个子类,我们称之为代理类(?), 代理类是继承我们所写的bean的,然后把代理类注入进来,那此时,在执行此方法的时候,会到代理类中,代理类判断了此方法需要异步执行,就不会调用父类 (我们原本写的bean)的对应方法。spring自己维护了一个队列,他会把需要执行的方法,放入队列中,等待线程池去读取这个队列,完成方法的执行, 从而完成了异步的功能。我们可以关注到再配置task的时候,是有参数让我们配置线程池的数量的。因为这种实现方法,所以在同一个类中的方法调用,添加@async注解是失效的!,原因是当你在同一个类中的时候,方法调用是在类体内执行的,spring无法截获这个方法调用。

        那在深入一步,spring为我们提供了AOP,面向切面的功能。他的原理和异步注解的原理是类似的,spring在启动容器的时候,会扫描切面所定义的 类。在这些类被注入的时候,所注入的也是代理类,当你调用这些方法的时候,本质上是调用的代理类。通过代理类再去执行父类相对应的方法,那spring只 需要在调用之前和之后执行某段代码就完成了AOP的实现了!

       那最后我们还有一个问题,spring是如何动态的生成某一个类的子类的?代理类?

  •  

    @RunWith(SpringJUnit4ClassRunner.class)
    @ContextConfiguration({"classpath:/applicationContext.xml"})
    public class TestAsync {
        @Autowired
        private TestAsyncBean testAsyncBean;
        @Test
        public void test_sayHello1() throws InterruptedException, ExecutionException {
            Future<String> future = null;
            System.out.println("你不爱我了么?");
            future = testAsyncBean.sayHello1();
            System.out.println("你竟无话可说, 我们分手吧。。。");
            Thread.sleep(3 * 1000);// 不让主进程过早结束
            System.out.println(future.get());
        }
    }

     

     

     

    简单介绍:

     

    Spring为任务调度与异步方法执行提供了注解支持。通过在方法上设置@Async注解,可使得方法被异步调用。也就是说调用者会在调用时立即返回,而被调用方法的实际执行是交给Spring的TaskExecutor来完成。

     

     

     

    开启@Async注解:

    <task:annotation-driven executor="annotationExecutor" />
    <!-- 支持 @Async 注解 -->
    <task:executor id="annotationExecutor" pool-size="20"/>

    同时加入<context:component-scan />扫描注解。

    栗子:

    为了比较,先来一个同步调用:

     

    @Component
    public class TestAsyncBean {
        public void sayHello4() throws InterruptedException {
            Thread.sleep(2 * 1000);//网络连接中 。。。消息发送中。。。
            System.out.println("我爱你啊!");
    }

     

    @RunWith(SpringJUnit4ClassRunner.class)
    @ContextConfiguration({"classpath:/applicationContext.xml"})
    public class TestAsync {
        @Test
        public void test_sayHello4() throws InterruptedException, ExecutionException {
            System.out.println("你不爱我了么?");
            testAsyncBean.sayHello4();
            System.out.println("回的这么慢, 你肯定不爱我了, 我们还是分手吧。。。");
            Thread.sleep(3 * 1000);// 不让主进程过早结束
        }
    }

    输出结果:

    你不爱我了么?
    我爱你啊!
    回的这么慢, 你肯定不爱我了, 我们还是分手吧。。。

     

    同步调用会按代码顺序依次进行下去,如果哪里需要等待,那么就阻塞在那里,不再向下继续进行。

     

    使用@Async的异步调用:

     

    @Component
    public class TestAsyncBean {
        @Async
        public void sayHello3() throws InterruptedException {
            Thread.sleep(2 * 1000);//网络连接中 。。。消息发送中。。。
            System.out.println("我爱你啊!");
        }
    }

     

    @RunWith(SpringJUnit4ClassRunner.class)
    @ContextConfiguration({"classpath:/applicationContext.xml"})
    public class TestAsync {
        @Autowired
        private TestAsyncBean testAsyncBean;
        @Test
        public void test_sayHello3() throws InterruptedException, ExecutionException {
            System.out.println("你不爱我了么?");
            testAsyncBean.sayHello3();
            System.out.println("你竟无话可说, 我们分手吧。。。");
            Thread.sleep(3 * 1000);// 不让主进程过早结束
        }
    }

    输出结果:

    你不爱我了么?
    你竟无话可说, 我们分手吧。。。
    我爱你啊!

     

    异步调用,通过开启新的线程来执行调用的方法,不影响主线程。异步方法实际的执行交给了Spring的TaskExecutor来完成。

     

    上面这种方式是没有返回值的,下面尝试有返回值的异步调用:

     

    @Component
    public class TestAsyncBean {
        @Async
        public String sayHello2() throws InterruptedException {
            Thread.sleep(2 * 1000);//网络连接中 。。。消息发送中。。。
            return "我爱你啊!";// 调用方调用后会立即返回,所以返回null
        }
    }

     

    @RunWith(SpringJUnit4ClassRunner.class)
    @ContextConfiguration({"classpath:/applicationContext.xml"})
    public class TestAsync {
        @Autowired
        private TestAsyncBean testAsyncBean;
        @Test
        public void test_sayHello2() throws InterruptedException, ExecutionException {
            System.out.println("你不爱我了么?");
            System.out.println(testAsyncBean.sayHello2());
            System.out.println("你说的啥? 我们还是分手吧。。。");
            Thread.sleep(3 * 1000);// 不让主进程过早结束
        }
    }

    输出结果:

    你不爱我了么?
    null
    你说的啥? 我们还是分手吧。。。

     

    通过直接获取返回值得方式是不行的,这里就需要用到异步回调,异步方法返回值必须为Future<>,就像Callable与Future。

     

    下面通过AsyncResult<>来获得异步调用的返回值:

    @Component
    public class TestAsyncBean {
        @Async
        public Future<String> sayHello1() throws InterruptedException {
            int thinking = 2;
            Thread.sleep(thinking * 1000);//网络连接中 。。。消息发送中。。。
            System.out.println("我爱你啊!");
            return new AsyncResult<String>("发送消息用了"+thinking+"秒");
        }
    }

    输出结果:

    你不爱我了么?
    你竟无话可说, 我们分手吧。。。
    我爱你啊!
    发送消息用了2秒

© 著作权归作者所有

JackY-Ji
粉丝 12
博文 35
码字总数 18318
作品 0
杭州
私信 提问
Spring注解@Async和@Transactional失效问题究竟是什么原因,强势解释一波

原文作者:弥诺R 原文地址:http://www.minuor.com/1524750647/article 转载声明:转载请注明原文地址,注意版权维护,谢谢! 提前说说 项目中涉及到的代码我都会上传到码云(gitee)或者githu...

兴趣e族
2018/04/28
0
0
Spring @Async 注解

1、 spring 在扫描bean的时候会扫描方法上是否包含@async的注解 如果包含的,spring会为这个bean动态的生成一个子类,我们称之为代理类(?),代理类是继承我们所写的bean的,然后把代理类注入...

职业搬砖20年
2018/07/11
0
0
Spring boot异步注解源码解析

一、例子 我们先来看下面这个Demo。 pom.xml中maven依赖: 启动类SpringBootAsyncApplication.java DemoController.java IDemoService接口实现类DemoServiceImpl.java 启动项目后,访问GET h...

Lienson
04/16
0
0
透过现象看原理:详解 Spring 中 Bean 的 this 调用导致 AOP 失效的原因

原文出处:光闪 前言 在我们使用Spring时,可能有前辈教导过我们,在bean中不要使用this来调用被@Async、@Transactional、@Cacheable等注解标注的方法,this下注解是不生效的。 那么大家可曾...

光闪
2018/05/16
0
0
springboot 异步调用

异步调用 启动类:添加@EnableAsync注解 service方法上添加@Async注解 异步线程池 配置 测试 注意事项: 如下方式会使@Async失效 一、异步方法使用static修饰 二、异步类没有使用@Component注...

张欢19933
01/10
0
0

没有更多内容

加载失败,请刷新页面

加载更多

kubernetes API 访问控制在阿里云容器服务(ACK)上的实践

提起K8s API的访问控制,很多同学应该都会想到RBAC,这是K8s用来做权限控制的方法,但是K8s对API的访问控制却不止于此,今天我们就来简单介绍下K8s的访问控制以及ACK如何利用这套方法提供便捷...

zhaowei121
14分钟前
0
0
从HelloWorld看Knative Serving代码实现

概念先知 官方给出的这几个资源的关系图还是比较清晰的: 1.Service: 自动管理工作负载整个生命周期。负责创建route,configuration以及每个service更新的revision。通过Service可以指定路由流...

迷你芊宝宝
15分钟前
0
0
如何防止http请求数据被篡改

故事的开始,面试官问了我一个问题: 如何防止http请求中数据被篡改? 回答: 1.设置客户端IP黑/白名单 1.1.客户端所有请求,请求到代理服务器(nginx),代理服务器维护黑/白名单的ip,决定是...

太猪-YJ
19分钟前
0
0
好程序员大数据笔记之:Hadoop集群搭建

在学习大数据的过程中,我们接触了很多关于Hadoop的理论和操作性的知识点,尤其在近期学习的Hadoop集群的搭建问题上,小细节,小难点拼频频出现,所以,今天集中总结以下笔记,希望对各位同学...

好程序员IT
26分钟前
0
0
MySql用navcat连接时报错 2509

在8版本以后的MySql默认的加密方式都改为了caching_sha2_password 因此进入mysql的命令行更改加密方式即可 ALTER USER 'root'@'localhost' IDENTIFIED BY 'password' PASSWORD EXPIRE NEVER......

lanyu96
28分钟前
0
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部