项目中发现了一个新的玩意WebAsyncTask

简介: 前言文本已收录至我的GitHub仓库,欢迎Star:github.com/bin39232820…种一棵树最好的时间是十年前,其次是现在

絮叨


刚好在读项目代码的时候,发现了WebAsyncTask这个新玩意,给大家来科普科普,不是那么的深入,不喜勿喷!

网络异常,图片无法展示
|
网络异常,图片无法展示
|


SpringBoot中同异步调用的使用


异步请求的处理。除了异步请求,一般上我们用的比较多的应该是异步调用。通常在开发过程中,会遇到一个方法是和实际业务无关的,没有紧密性的。比如记录日志信息等业务。这个时候正常就是启一个新线程去做一些业务处理,让主线程异步的执行其他业务。

  • 同步请求

网络异常,图片无法展示
|


  • 异步请求

网络异常,图片无法展示
|


SprinBoot中@Async异步方法


异步的好处是,可以提高程序吞吐量,一个任务,让耗时的异步处理,并继续同步处理后面的任务,异步任务可以返回结果,拿到结果后可结合同步处理过程中的变量一起处理计算


具体的使用

在Spring中,基于@Async标注的方法,称之为异步方法;这些方法将在执行的时候,将会在独立的线程中被执行,调用者无需等待它的完成,即可继续其他的操作。


自定义线程池异步调用

配置@EnableAsync使@Async生效

@SpringBootApplication
@EnableAsync
public class Application {
  public static void main(String[] args) {
    SpringApplication.run(Application.class, args);
  }
}
复制代码


自定义线程池

@Component
@Scope  //单例
public class MyExecutePoll {
    @Bean
    public Executor myAsyncPool() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        //核心线程池大小
        executor.setCorePoolSize(20);
        //最大线程数
        executor.setMaxPoolSize(40);
        //队列容量
        executor.setQueueCapacity(50);
        // 活跃时间
        executor.setKeepAliveSeconds(300);
        // 线程名字前缀
        executor.setThreadNamePrefix("MyExecutor-");
        //设置线程池关闭的时候等待所有任务都完成再继续销毁其他的Bean,使异步线程的销毁优先于Redis等其他处理报错
        executor.setWaitForTasksToCompleteOnShutdown(true);
        //设置线程池中任务的等待时间,如果超过这个时候还没有销毁就强制销毁,以确保应用最后能够被关闭,而不是阻塞住
        executor.setAwaitTerminationSeconds(60);
        // setRejectedExecutionHandler:当pool已经达到max size的时候,如何处理新任务
        // CallerRunsPolicy:不在新线程中执行任务,而是由调用者所在的线程来执行
        executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
        executor.initialize();
        return executor;
    }
}
复制代码


使用@Async

@Async("myAsyncPool")   //@Async使用默认的线程
public Future<String> doTask() throws Exception {
    //业务处理   使用Future返回异步调用结果
    return new AsyncResult<>("任务一完成");
复制代码


在Spring中运用 Async注解 需要注意几点:

  • AsyncTest.java,测试类,调用异步任务,同时执行同步方法
  • OrderService.java,异步任务类,提供异步方法
  • AsyncThreadPoolConfig.java,异步任务线程池配置类,配置异步任务运行的线程池大小等


基于Spring实现异步请求


Spring可以通过Callable或者WebAsyncTask等方式实现异步请求, 我们来看看,这2种实现方式!


Callable

Callable是为了异步生成返回值提供基本的支持。简单来说就是一个请求进来,如果你使用了Callable,在没有得到返回数据之前,DispatcherServlet和所有Filter就会退出Servlet容器线程,但响应保持打开状态,一旦返回数据有了,这个DispatcherServlet就会被再次调用并且处理,以异步产生的方式,向请求端返回值。 这么做的好处就是请求不会长时间占用服务连接池,提高服务器的吞吐量。


@GetMapping("/callable")
    public Callable<String> testCallable() throws InterruptedException {
        log.info("主线程开始!");
        Callable<String> result = new Callable<String>() {
            @Override
            public String call() throws Exception {
                log.info("副线程开始!");
                Thread.sleep(1000);
                log.info("副线程结束!");
                return "SUCCESS";
            }
        };
        log.info("主线程结束!");
        return result;
    }
复制代码


输出结果

主线程开始!
主线程结束!
副线程开始!
副线程结束!
复制代码


WebAsyncTask

一个请求到服务上,是用的web容器的线程接收的

我们可以使用WebAsyncTask将这个请求分发给一个新的线程去执行,容器的线程可以去接收其他请求的处理。一旦WebAsyncTask返回数据有了,就会被再次调用并且处理,以异步产生的方式,向请求端返回值,但是其实我觉得前端的请求rt并不会说变短。

/**
     * 查询
     */
    @RequestMapping(method = RequestMethod.GET, value = "/aysncTask/{testId}")
    @ResponseStatus(HttpStatus.OK)
    public WebAsyncTask<Response> aysncTask(@PathVariable("testId") String testId) {
        System.out.println(String.format("/aysncTask/%s 被调用 thread id is: %s", testId,Thread.currentThread().getName()));
        Callable<Response> callable = () -> {
            Thread.sleep(1000L);
            Response response = new Response(true,"异步执行成功");
            System.out.println(String.format("/aysncTask/%s 被调用 thread id is: %s", testId,Thread.currentThread().getName()));
            return response;
        };
        return new WebAsyncTask<Response>(callable);
    }
复制代码


控制台打印如下: 在执行业务逻辑之前的线程和具体处理业务逻辑的线程不是同一个,达到了我们的目的。async-customize-1这个前缀是我们自定义的下边会说

/aysncTask/12348567676 被调用 thread id is: http-nio-8084-exec-1
/aysncTask/12348567676 被调用 thread id is: async-customize-1
复制代码


其实WebAsyncTask比起Callable是有以下几个优点的

官方有这么一句话,截图给你:

网络异常,图片无法展示
|
如果我们需要超时处理的回调或者错误处理的回调,我们可以使用WebAsyncTask代替Callable

实际使用中,我并不建议直接使用Callable ,而是使用Spring提供的WebAsyncTask 代替,它包装了Callable,功能更强大些


总结


其实本文就是给大家科普下,一些异步的用法,不至于说看到人家这么用很蒙b,多线程的东西还是优点东西的,大家一起学习。

相关文章
|
5月前
|
缓存 Java 应用服务中间件
2021年9月28日,老是遇到一些非常奇葩的问题。就离谱、好好的一个web项目就莫名奇妙坏了。
开发者在使用IDEA 2020编辑器搭建的SSM框架图书管理系统中,遇到删除功能异常问题,经过一系列尝试后发现是IDEA编译缓存导致的,最终通过重新编译项目解决了问题。
|
8月前
|
XML Java 数据格式
🚀今天,我们来详细的聊一聊SpringBoot自动配置原理,学了这么久,你学废了吗?
🚀今天,我们来详细的聊一聊SpringBoot自动配置原理,学了这么久,你学废了吗?
127 0
|
设计模式 运维 架构师
我懵了!架构描述是个啥玩意?
我懵了!架构描述是个啥玩意?
106 0
|
Java Linux 开发者
撸个反向代理工具,搞一搞JRebel
前言 本地反向代理 服务器反向代理【个人推荐】 IDEA安装JRebel并激活 服务器安装JRebel并激活
|
算法 NoSQL API
到底该不该看源码(懂这三点儿就够了)
1、不要为了看源码而看源码 2、代码积累到一定程度,遇到问题自然就去查源码了,然后你就看懂了 3、两年内不要刻意去看源码,可以点开简单了解一下就行,前两年疯狂做项目就行了,后期项目做的多了,你自己就会有疑问,每次写代码就会问自己为什么要这样写?底层的原理是什么?很自觉的带着问题就去看源码了,如果你没有这样的疑问,那说明你也不适合去看源码了,写写业务代码,了了一生
206 0
|
SQL 存储 监控
聊聊那些年遇到过的奇葩代码
无论是开发新需求还是维护旧平台,在工作的过程中我们都会接触到各种样式的代码,有时候会碰到一些优秀的代码心中不免肃然起敬,但是更多的时候我们会遇到很多奇葩代码,有的时候骂骂咧咧的吐槽一段奇葩代码后定睛一看作者,居然是几个月以前自己的写的,心中难免浮现曹操的那句名言:不可能,绝对不可能。
聊聊那些年遇到过的奇葩代码
|
前端开发 Java Spring
项目中发现了一个新的玩意WebAsyncTask
前言 文本已收录至我的GitHub仓库,欢迎Star:github.com/bin39232820… 种一棵树最好的时间是十年前,其次是现在
183 0
|
设计模式 Java
从头捋一遍Java项目中的五大设计原则,就不信你学不会!(中)
从头捋一遍Java项目中的五大设计原则,就不信你学不会!(中)
从头捋一遍Java项目中的五大设计原则,就不信你学不会!(中)
|
人工智能 5G 数据安全/隐私保护
5G时代都要来了,你还没用过它?
5G时代已经成为了近期热词,2019年也被认为是5G的开局之年。作为跨时代的移动通信技术,5G能让人与物、物与物之间形成更快速更全面的连接,彻底改变我们的生活和商业模式。各家设备商和运营商都在积极布局5G产业,深化5G应用。 但是,5G网络完成搭建,大规模投入商用,还需要一些时间。除此之外,还有很多移动终端的技术改变在发生着。
161 0
5G时代都要来了,你还没用过它?
3分钟理解tintColor是个啥玩意
3分钟理解tintColor是个啥玩意
242 0