java

关注公众号 jb51net

关闭
首页 > 软件编程 > java > springboot异步@Async

springboot异步@Async的使用及失效场景介绍

作者：YD_1989

本文主要介绍了springboot异步@Async的使用及失效场景介绍,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧

引言

在 java 中很多业务涉及到异步线程，比如在业务流处理时，需要发短信发邮件通知用户，或者需要上传一些文件资源到其他服务器这种耗时的操作。
这种比较耗时的操作如果都在主线程里处理会阻塞整理流程，而且我们也不需要等待处理结果之后再进行下一步操作，这时候就可以使用异步线程进行处理，这样主线程不会因为这些耗时的操作而阻塞，保证主线程的流程可以正常进行。

一、@Async 使用位置

二、@Async 使用

在 Springboot 中使用 @Async：

代码示例：

本文不做新配置，全部使用默认的线程池及配置。

（1）创建 AsyncService 写异步方法

import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;

@Service
public class AsyncService {

    @Async
    public void Async() throws InterruptedException {
        Thread.sleep(10000);
        System.out.println("程序睡眠结束");

    }

（2）编写业务层 AsyncTestService

package com.ruoyi.system.service;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;

@Service
public class AsyncTestService {
    @Autowired
    private AsyncService asyncService;


    public String testSync() throws InterruptedException {
        System.out.println("开始进入方法");
        System.out.println("进行时");
        System.out.println("正在进行时");
		asyncService.Async();
        return "成功";
    }
}

（3）编写接口 AsyncTestController

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;

@RestController
@RequestMapping(value = "/async/lost")
public class AsyncTestController {

    @Autowired
    private AsyncTestService asyncTestService;

    @RequestMapping(value = "/test", method = {RequestMethod.POST})
    public String testAsync() throws InterruptedException {
        asyncTestService.testSync();
        System.out.println("调用Controller控制器结束");
        return "成功";
    }
}

postman 测试：

从下图测试结果可知，打印语句 “调用Controller控制器结束” 在 “程序睡眠结束” 之前执行，异步实现成功，没有影响到主线程的任务。

在这里插入图片描述

三、注解 @Async 失效的情况

（1）调用同一个类中的异步方法（内部调用）

从上面的 @Async 使用我们看到，添加注解的异步方法在一个单独的类 AsyncService 中，然后注入到 AsyncTestService 中进行调用。如果异步方法和调用的方法在同一个类中，还会正常进行异步调用吗？

AsyncTestService 代码如下：

@Service
public class AsyncTestService {

    public String testSync() throws InterruptedException {
        System.out.println("开始进入方法");
        System.out.println("进行时");
        System.out.println("正在进行时");
        Async();
        return "成功";
    }

    @Async
    public void Async() throws InterruptedException {
        Thread.sleep(10000);
        System.out.println("程序睡眠结束");

    }
}

postman 测试：

在这里插入图片描述

如上图所示，打印语句 “调用Controller控制器结束” 在 “程序睡眠结束” 之后执行，说明异步并没有生效，程序还是走了主线程。

这是因为 @Async注解是通过aop代理实现的，需要通过JDK动态代理或者cglib，生成代理对象。异步的功能，是在代理对象中增加的，我们必须调用代理对象的 testSync() 方法才行。而在类中直接进行方法的内部调用，在 testSync() 方法中调用Async()方法，调用的是该类原对象的Async方法，相当于调用了this.Async()方法，而并非AsyncTestService 代理类的 Async() 方法。 因此，像这种内部方法调用，@Async注解的异步功能会失效。

要想在同一个类中调用异步方法，需要使用 ApplicationContext 获得到该类。

AsyncTestService 代码如下：

import org.springframework.aop.support.AopUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.ApplicationContext;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;

@Service
public class AsyncTestService {

    @Autowired
    private ApplicationContext applicationContext;


    public String testSync() throws InterruptedException {
        AsyncTestService asyncBean = applicationContext.getBean(AsyncTestService.class);
        System.out.println("当前对象是否是代理对象:" + AopUtils.isAopProxy(asyncBean));
        System.out.println("是否是cglib代理对象:" + AopUtils.isCglibProxy(asyncBean));
        System.out.println("是否是jdk代理对象:" + AopUtils.isJdkDynamicProxy(asyncBean));
        System.out.println(asyncBean == this);
        asyncBean.Async();
        return "成功";
    }

    @Async
    public void Async() throws InterruptedException {
        Thread.sleep(10000);
        System.out.println("程序睡眠结束");

    }
}

postman 测试：

打印控制器语句在前，异步实现成功。

在这里插入图片描述

（2）未使用 @EnableAsync 注解

在 Springboot 中要开启@Async注解异步的功能，需要在项目的启动类，或者配置类上，使用@EnableAsync注解。

@EnableAsync注解相当于一个开关，控制是否开启@Async注解异步的功能，默认是关闭的。

@EnableAsync
@SpringBootApplication(exclude = {DataSourceAutoConfiguration.class})
public class Application {

    public static void main(String[] args) {
        SpringApplication.run(Application.class, args);
    }
}

（3）注解@Async的方法不是public方法

异步的方法必须是 public修饰的，否则 aop 代理异常，异步失效。

（4）返回值错误

注解 @Async 的返回值只能为 void 或 Future。

（5）方法用static修饰了

使用@Async注解声明的方法，必须是能被重写的，很显然static修饰的方法，是类的静态方法，是不允许被重写的。
因此这种情况下，@Async注解的异步功能会失效。

（6）类中需要使用@Autowired或@Resource等注解自动注入,不能自己手动new对象

（7）方法用final修饰

（8）业务类没加@Service注解

到此这篇关于springboot异步@Async的使用及失效场景介绍的文章就介绍到这了,更多相关springboot异步@Async内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

您可能感兴趣的文章:
阅读全文