spring mvc的异步特性介绍

谁借莪１个温暖的怀抱￠ 2022-06-08 04:59 130阅读 0赞

### 1.为什么需要异步模式 ###

绝大多数Web服务器的做法，请求处理线程会在Call了之后等待Return，自身处于阻塞状态。这种模式会出现什么问题呢？会出现的问题就是请求处理线程的短缺！如果类似的请求多了，所有的**处理线程**处于阻塞的状态，那新的请求也就无法处理了，也就所谓影响了服务器的**吞吐能力**。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2l0c29mdGNoZW5mZWk_size_16_color_FFFFFF_t_70][]

**那么怎么才能解决上面的问题呢？**

就要使用异步！

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2l0c29mdGNoZW5mZWk_size_16_color_FFFFFF_t_70 1][]

异步的本质在于请求处理线程不在阻塞（请求处理线程对后台处理的调用使用了“invoke”的方式，就是说调了之后直接返回，而不等待，这样请求处理线程就“自由”了，它可以接着去处理别的请求），当后端处理完成后，会钩起一个回调处理线程来处理调用的结果，这个回调处理线程跟请求处理线程也许都是线程池中的某个线程，相互间可以完全没有关系，由这个回调处理线程向浏览器返回内容。这就是异步的过程。

### 2.springMvc在4.x版本开始支持异步 ###

环境要求，Servlet版本是3.x以上，Spring MVC版本是4.x以上，建议使用最新，例如:

<dependency>  
    <groupId>javax.servlet</groupId>  
    <artifactId>javax.servlet-api</artifactId>  
    <version>3.1.0</version>  
    <scope>provided</scope>  
</dependency>  
<dependency>  
    <groupId>org.springframework</groupId>  
    <artifactId>spring-webmvc</artifactId>  
    <version>4.2.3.RELEASE</version>  
</dependency>

### 3.使用DefferedResult特性 ###

由于Spring MVC的良好封装，异步功能使用特别简单。在Controller中，传统的同步模式返回的ModelAndView，而异步模式则是返回DeferredResult

@GetMapping("/sync")
        public DeferredResult sync() {
            DeferredResult result = new DeferredResult();
            LOGGER.info("start....");
            longTimeAsyncCallService.exec((ret) -> {
                LOGGER.info("sync complete...." + ret);
                result.setResult("OK");
            });
            return result;
        }
    //结果：
    // [nio-8080-exec-1] com.example.demo.DemoController          : start....
    // [nio-8080-exec-1] c.example.demo.LongTimeAsyncCallService  : 完成此任务需要等待:5秒.
    // [pool-1-thread-1] c.example.demo.LongTimeAsyncCallService  : sync start.
    // [pool-1-thread-1] com.example.demo.DemoController          : sync complete....callback // result 3

### 4.使用WebAsyncTask特性 ###

与上一个不同之处在于返回WebAsyncTask的话是不需要我们主动去调用Callback的，它仅仅是简单地把请求处理线程的任务转交给另一工作线程而已

@GetMapping("/sync2")
        public WebAsyncTask syncTask() {
            LOGGER.info("start....");
            Callable callable = new Callable() {
                public String call() throws Exception {
                    Thread.sleep(5000); //假设是一些长时间任务
                    LOGGER.info("exec sync complete....");
                    return "suc";
                }
            };
            return new WebAsyncTask(callable);
        }
    //结果：
    // [nio-8080-exec-4] com.example.demo.DemoController          : start....
    // [      my-task-2] com.example.demo.DemoController          : exec sync complete....

### 5.超时处理 ###

@GetMapping("/sync-timeout")
    public DeferredResult syncTimeout() {
        DeferredResult deferredResult = new DeferredResult(2000L);
        LOGGER.info("start....timeout:2s");
        longTimeAsyncCallService.exec(new LongTermTaskCallback() {
            @Override
            public void callback(Object result) {
                LOGGER.info("exec sync complete...." + result);
                deferredResult.setResult("Ok");
            }
        });
        deferredResult.onTimeout(new Runnable() {
            @Override
            public void run() {
                LOGGER.info("exec timeout complete....");
                deferredResult.setResult("timeout");
            }
        });
        return deferredResult;
    }
    //DefferedResult结果：
    //    [nio-8080-exec-7] com.example.demo.DemoController          : start....timeout:2s
    //    [nio-8080-exec-7] c.example.demo.LongTimeAsyncCallService  : 完成此任务需要等待:5秒.
    //    [nio-8080-exec-8] com.example.demo.DemoController          : exec timeout complete....
    //    [pool-1-thread-1] c.example.demo.LongTimeAsyncCallService  : sync start.
    //    [pool-1-thread-1] com.example.demo.DemoController          : exec sync complete....callback result 8

@GetMapping("/sync-timeout2")
    public WebAsyncTask syncTaskTimeout() {
        LOGGER.info("start....timeout:2s");
        Callable callable = new Callable() {
            public String call() throws Exception {
                Thread.sleep(5000); //假设是一些长时间任务
                LOGGER.info("exec sync complete....");
                return "suc";
            }
        };
        WebAsyncTask asyncTask = new WebAsyncTask(2000, callable);
        asyncTask.onTimeout(new Callable() {
            public String call() throws Exception {
                LOGGER.info("exec timeout complete....");
                return "timeout";
            }
        });
        return asyncTask;
    }
    // WebAsyncTask结果：
    //    [io-8080-exec-10] com.example.demo.DemoController          : start....timeout:2s
    //    [nio-8080-exec-1] com.example.demo.DemoController          : exec timeout complete....
    //    [      my-task-3] com.example.demo.DemoController          : exec sync complete....

源码：https://github.com/alex2chen/springboot-sync-web。![88076245][]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2l0c29mdGNoZW5mZWk_size_16_color_FFFFFF_t_70]: /images/20220608/776e07e1eb1742b29c739ba6fa52fec0.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2l0c29mdGNoZW5mZWk_size_16_color_FFFFFF_t_70 1]: /images/20220608/06a7b2fab52448018afd28db27c04c27.png
[88076245]: /images/20220608/e281228abf644b2aa739224fd6e7c28f.png