Springboot利用Aop捕捉注解实现业务异步执行
在开发过程中,尽量会将比较耗时且并不会影响请求的响应结果的业务放在异步线程池中进行处理,那么到时什么任务在执行的时候会创建单独的线程进行处理呢?我们可以在对应的业务方法上打上自定义的注解,再利用AOP去捕捉这个注解,就可以利用环绕通知的特性进行异步的设置。
一、先说说线程的几种创建方式(简要列举)
1、继承Thread类,复写run方法:
1 2 3 4 5 6 7 8 9 10 11 12 13 | 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方法:
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 | 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创建线程(可以获得返回值):
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 | 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创建线程池):
1 2 3 4 5 6 7 8 9 10 11 | 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即可。
1 2 3 4 5 6 7 | @SpringBootApplication @EnableAsync public class AopApplication { public static void main(String[] args) { SpringApplication.run(AopApplication. class , args); } } |
业务类方法(举例):
1 2 3 4 5 | @Async public void insertDb(){ /*service code......*/ System.out.println( "2----->收到请求,写入数据库 " ); } |
三、那么就来设计一下怎么使用自定义的注解实现异步任务
首先我们写一个注解:
1 2 3 4 5 6 | @Target ({ElementType.METHOD}) @Retention (RetentionPolicy.RUNTIME) public @interface MyAsync { //规定value是异步开关 boolean value() default false ; } |
我们让注解中的value的值定为布尔类型,从而根据它的真假来决定异步线程的创建。
我们将它打在业务类的方法上:
1 2 3 4 5 | @MyAsync (value = true ) public void deleteDb(){ /*service code......*/ System.out.println( "delete------>数据删除" ); } |
然后我们利用AOP扫描这个注解:
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 | 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的真假,从而决定方法通过的方式是同步的还是异步的。(源码利用到反射机制)。
到此这篇关于Springboot利用Aop捕捉注解实现业务异步执行的文章就介绍到这了,更多相关Springboot业务异步执行内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!
微信公众号搜索 “ 脚本之家 ” ,选择关注
程序猿的那些事、送书等活动等着你
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。
如若内容造成侵权/违法违规/事实不符,请将相关资料发送至 reterry123@163.com 进行投诉反馈,一经查实,立即处理!
相关文章
详解Jenkins 实现Gitlab事件自动触发Jenkins构建及钉钉消息推送
这篇文章主要介绍了Jenkins 实现Gitlab事件自动触发Jenkins构建及钉钉消息推送,应该会对大家学习Jenkins有所启发2021-04-04springMVC MultipartFile上传图片时如何修改图片大小
这篇文章主要介绍了springMVC MultipartFile上传图片时如何修改图片大小问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教2023-12-12SpringBoot3和ShardingSphere5框架实现数据分库分表
这篇文章主要介绍了SpringBoot3和ShardingSphere5框架实现数据分库分表的相关资料,需要的朋友可以参考下2023-08-08详解如何让Spring MVC显示自定义的404 Not Found页面
这篇文章主要介绍了详解如何让Spring MVC显示自定义的404 Not Found页面,小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧2018-10-10
最新评论