spring mvc的异步特性介绍

1.为什么需要异步模式

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

 

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

就要使用异步！

异步的本质在于请求处理线程不在阻塞（请求处理线程对后台处理的调用使用了“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。