Springboot怎么用Aop捕捉注解實(shí)現(xiàn)業(yè)務(wù)異步執(zhí)行

這篇“Springboot怎么用Aop捕捉注解實(shí)現(xiàn)業(yè)務(wù)異步執(zhí)行”文章的知識(shí)點(diǎn)大部分人都不太理解，所以小編給大家總結(jié)了以下內(nèi)容，內(nèi)容詳細(xì)，步驟清晰，具有一定的借鑒價(jià)值，希望大家閱讀完這篇文章能有所收獲，下面我們一起來(lái)看看這篇“Springboot怎么用Aop捕捉注解實(shí)現(xiàn)業(yè)務(wù)異步執(zhí)行”文章吧。

一、先說(shuō)說(shuō)線程的幾種創(chuàng)建方式（簡(jiǎn)要列舉）

1、繼承Thread類，復(fù)寫run方法：

public class ExtendsThread extends Thread{
    @Override
    public void run() {
        try{
            System.out.println(Thread.currentThread().getName()+"執(zhí)行");
        }catch (Exception e){
 
        }
    }
    public static void main(String[] args) {
        new Thread(new ExtendsThread()).start();
    }
}

2、實(shí)現(xiàn)Runnable接口，重寫run方法：

public class ImplementsRunnable implements Runnable{
    @Override
    public void run() {
        try{
            System.out.println(Thread.currentThread().getName()+"執(zhí)行");
        }catch (Exception e){
 
        }
    }
    public static void main(String[] args) {
        new Thread(new ImplementsRunnable()).start();
        //這里還可以使用匿名內(nèi)部類的寫法創(chuàng)建一個(gè)線程
        new Thread(new Runnable() {
            @Override
            public void run() {
                System.out.println(Thread.currentThread().getName()+"執(zhí)行");
            }
        },"匿名內(nèi)部類實(shí)現(xiàn)Runnable接口的線程");
    }
}

3、實(shí)現(xiàn)Callable接口，使用FutureTask創(chuàng)建線程（可以獲得返回值）：

public class CallableAndFuture implements Callable<String> {
    @Override
    public String call() throws Exception {
        Thread.sleep(3000);
        System.out.println(Thread.currentThread().getName()+"執(zhí)行");
        return "success";
    }
    public static void main(String[] args) throws ExecutionException, InterruptedException {
        FutureTask<String> futureTask = new FutureTask<>(new CallableAndFuture());
//        futureTask.run();   主線程執(zhí)行call方法
        new Thread(futureTask).start();
        String result = futureTask.get();
        System.out.println(result);
    }
}

4、使用線程池創(chuàng)建線程（這里利用提供的線程池框架Executors創(chuàng)建線程池）：

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()+"執(zhí)行");
            }
        });
    }
}

二、再聊一聊spring自帶的@Async注解實(shí)現(xiàn)異步任務(wù)的方法

其實(shí)很簡(jiǎn)單，就是在應(yīng)用程序啟動(dòng)類上打@EnableAsync注解開啟異步注解的使用，再在業(yè)務(wù)類的某個(gè)方法上打@Async即可。

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

業(yè)務(wù)類方法（舉例）：

   @Async
    public void insertDb(){
        /*service code......*/
        System.out.println("2----->收到請(qǐng)求,寫入數(shù)據(jù)庫(kù)  ");
    }

三、那么就來(lái)設(shè)計(jì)一下怎么使用自定義的注解實(shí)現(xiàn)異步任務(wù)

首先我們寫一個(gè)注解：

@Target({ElementType.METHOD})
@Retention(RetentionPolicy.RUNTIME)
public @interface MyAsync {
    //規(guī)定value是異步開關(guān)
    boolean value() default false;
}

我們讓注解中的value的值定為布爾類型，從而根據(jù)它的真假來(lái)決定異步線程的創(chuàng)建。

我們將它打在業(yè)務(wù)類的方法上：

  @MyAsync(value = true)
    public void deleteDb(){
        /*service code......*/
        System.out.println("delete------>數(shù)據(jù)刪除");
    }

然后我們利用AOP掃描這個(gè)注解：

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尋找執(zhí)行的線程中某個(gè)含有注解的方法棧，捕捉到之后就可以獲得對(duì)應(yīng)的連接點(diǎn)對(duì)象了。

利用可通過(guò)連接點(diǎn)對(duì)象ProcedJoinPoint的getSignture方法獲取簽名，可以將簽名強(qiáng)制轉(zhuǎn)化成方法簽名MethdSignture類型，從而利用該類型的getMethod方法獲取方法本身，接下來(lái)就可以獲取方法的注解，利用注解的屬性直接獲取value的真假，從而決定方法通過(guò)的方式是同步的還是異步的。(源碼利用到反射機(jī)制)。

以上就是關(guān)于“Springboot怎么用Aop捕捉注解實(shí)現(xiàn)業(yè)務(wù)異步執(zhí)行”這篇文章的內(nèi)容，相信大家都有了一定的了解，希望小編分享的內(nèi)容對(duì)大家有幫助，若想了解更多相關(guān)的知識(shí)內(nèi)容，請(qǐng)關(guān)注億速云行業(yè)資訊頻道。