Springboot利用Aop捕捉注解实现业务异步执行

时间：2022-12-31 07:54:36

在开发过程中，尽量会将比较耗时且并不会影响请求的响应结果的业务放在异步线程池中进行处理，那么到时什么任务在执行的时候会创建单独的线程进行处理呢？我们可以在对应的业务方法上打上自定义的注解，再利用AOP去捕捉这个注解，就可以利用环绕通知的特性进行异步的设置。

一、先说说线程的几种创建方式（简要列举）

1、继承Thread类，复写run方法：

public class ExtendsThread extends Thread{
    @Override
    public void run() {
        try{
            System.out.println(Thread.currentThread().getName()+"执行");
        }catch (Exception e){

        }
    }

    public static void main(String[] args) {
        new Thread(new ExtendsThread()).start();
    }
}

2、实现Runnable接口，重写run方法：

public class ImplementsRunnable implements Runnable{

    @Override
    public void run() {
        try{
            System.out.println(Thread.currentThread().getName()+"执行");
        }catch (Exception e){

        }
    }

    public static void main(String[] args) {
        new Thread(new ImplementsRunnable()).start();
        //这里还可以使用匿名内部类的写法创建一个线程
        new Thread(new Runnable() {
            @Override
            public void run() {
                System.out.println(Thread.currentThread().getName()+"执行");
            }
        },"匿名内部类实现Runnable接口的线程");

    }
}

3、实现Callable接口，使用FutureTask创建线程（可以获得返回值）：

public class CallableAndFuture implements Callable<String> {
    @Override
    public String call() throws Exception {
        Thread.sleep(3000);
        System.out.println(Thread.currentThread().getName()+"执行");
        return "success";
    }

    public static void main(String[] args) throws ExecutionException, InterruptedException {
        FutureTask<String> futureTask = new FutureTask<>(new CallableAndFuture());
//        futureTask.run();   主线程执行call方法
        new Thread(futureTask).start();
        String result = futureTask.get();
        System.out.println(result);
    }
}

4、使用线程池创建线程（这里利用提供的线程池框架Executors创建线程池）：

public class Executor {
    public static void main(String[] args) {
        ExecutorService executorService = Executors.newCachedThreadPool();
        executorService.execute(new Runnable() {
            @Override
            public void run() {
                System.out.println(Thread.currentThread().getName()+"执行");
            }
        });
    }
}

二、再聊一聊spring自带的@Async注解实现异步任务的方法

其实很简单，就是在应用程序启动类上打@EnableAsync注解开启异步注解的使用，再在业务类的某个方法上打@Async即可。

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

}

 业务类方法（举例）：

   @Async
    public void insertDb(){
        /*service code......*/
        System.out.println("2----->收到请求,写入数据库  ");
    }

三、那么就来设计一下怎么使用自定义的注解实现异步任务

首先我们写一个注解：

@Target({ElementType.METHOD})
@Retention(RetentionPolicy.RUNTIME)
public @interface MyAsync {
    //规定value是异步开关
    boolean value() default false;
}

我们让注解中的value的值定为布尔类型，从而根据它的真假来决定异步线程的创建。

我们将它打在业务类的方法上：

  @MyAsync(value = true)
    public void deleteDb(){
        /*service code......*/
        System.out.println("delete------>数据删除");
    }

然后我们利用AOP扫描这个注解：

Aspect
@Component
public class AopUtils {

    @Around(value = "@annotation(com.example.aop.Aop异步.MyAsync)")
    public void listenMyAsync(ProceedingJoinPoint joinPoint) throws Throwable {
        MethodSignature signature = (MethodSignature) joinPoint.getSignature();
        Method method = signature.getMethod();
        MyAsync annotation = method.getAnnotation(MyAsync.class);
        boolean value = annotation.value();
        if (value)
            new Thread(new Runnable() {
                @SneakyThrows
                @Override
                public void run() {
                    joinPoint.proceed();
                }
            }).start();
        else
            joinPoint.proceed();
    }
}

我们可以看到利用Around寻找执行的线程中某个含有注解的方法栈，捕捉到之后就可以获得对应的连接点对象了。

利用可通过连接点对象ProcedJoinPoint的getSignture方法获取签名，可以将签名强制转化成方法签名MethdSignture类型，从而利用该类型的getMethod方法获取方法本身，接下来就可以获取方法的注解，利用注解的属性直接获取value的真假，从而决定方法通过的方式是同步的还是异步的。(源码利用到反射机制)。

标签：

相关文章