spring mvc 异步请求

Myth丶恋晨 2022-07-14 02:07 251阅读 0赞

需要环境：servlet >3.0 and Spring MVC>3.2

和普通的`new Thread` 进行能异步处理却无法返回异步处理的结果不同，spring 提供的异步支持异步处理的同时还能对异步处理的结果进行返回

他有三种实现方式

第一种：直接返回Callable< T>对象

@RequestMapping("/async")
        public Callable<String> asyncQuest() throws Exception {
            Callable<String> result =  new Callable<String>() {
                public String call() throws Exception {
                    Thread.sleep(3000);
                    String str = "异步处理完成，返回";
                    System.out.println(str);
                    return str;
                }
            };
            System.out.println("主线程结束");
            return result;
        }

第二种：返回DeferredResult< T>对象

这种方式我更喜欢，也更强大，通过这种方式，返回值可以由任意线程产生，包括非spring mvc管理的线程。文档上是这样描述的“返回值可能是为了响应某些外部事件所产生的，比如一条JMS的消息，一个计划任务”

@RequestMapping("/async")
        public DeferredResult<String> asyncQuest() throws Exception {
            DeferredResult<String> result = new DeferredResult<String>(1000l,"超时");
            return result;
        }
    
    
        //在外部线程执行一些操作把结果写到result,完成response操作
        result.setResult(str);

第三种:返回WebAsyncTask< T>,这种方式主要是对第一种的增强,使Callable支持超时设置，超时处理，操作完成的封装

@RequestMapping("/async")
        public WebAsyncTask<String> asyncQuest() throws Exception {
            WebAsyncTask<String> result = new WebAsyncTask<String>(1000,new Callable<String>() {
                public String call() throws Exception {
                    Thread.sleep(3000);
                    String str = "异步处理完成，返回";
                    System.out.println(str);
                    return str;
                }
            });
            //result.onTimeout();
            //result.onCompletion();
            return result;
        }

*  超时时间如果未指定，会使用容器的超时时间
    
    主要场景：  
    1、提升请求并发量，毕竟请求连接数是有限的  
    特殊场景:  
    1、前端发起统计请求，调用离线计算任务开始统计计算，在规定时间内没有计算完成，要求返回显示“任务执行中，稍后查看”，如果在规定时间内计算完成。返回计算的结果
 *  还有其他场景欢迎补充