专栏名称: 程序员大咖
为程序员提供最优质的博文、最精彩的讨论、最实用的开发资源;提供最新最全的编程学习资料:PHP、Objective-C、Java、Swift、C/C++函数库、.NET Framework类库、J2SE API等等。并不定期奉送各种福利。
目录
相关文章推荐
程序员的那些事  ·  百度:报案了 ·  3 天前  
OSC开源社区  ·  使用DeepSeek拯救数据中台 ·  4 天前  
程序员的那些事  ·  65 ... ·  4 天前  
51好读  ›  专栏  ›  程序员大咖

高性能的关键:Spring MVC的异步模式

程序员大咖  · 公众号  · 程序员  · 2016-11-26 22:11

正文

点击上方 蓝色字体 关注「程序员大咖」


来源:蒋国纲

链接:cnblogs.com/guogangj/p/5457959.html


什么是异步模式


要知道什么是异步模式,就先要知道什么是同步模式,先看最典型的同步模式:



(图1)


浏览器发起请求,Web服务器开一个线程处理,处理完把处理结果返回浏览器。好像没什么好说的了,绝大多数Web服务器都如此般处理。现在想想如果处理的过程中需要调用后端的一个业务逻辑服务器,会是怎样呢?



(图2)


调就调吧,上图所示,请求处理线程会在Call了之后等待Return,自身处于阻塞状态。这也是绝大多数Web服务器的做法,一般来说这样做也够了,为啥?一来“长时间处理服务”调用通常不多,二来请求数其实也不多。要不是这样的话,这种模式会出现什么问题呢?——会出现的问题就是请求处理线程的短缺!因为请求处理线程的总数是有限的,如果类似的请求多了,所有的处理线程处于阻塞的状态,那新的请求也就无法处理了,也就所谓影响了服务器的吞吐能力。要更加好地发挥服务器的全部性能,就要使用异步,这也是标题上所说的“高性能的关键”。接下来我们来看看异步是怎么一回事:



(图3)


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


带来的改进是显而易见的,请求处理线程不需要阻塞了,它的能力得到了更充分的使用,带来了服务器吞吐能力的提升。


Spring MVC的使用——DefferedResult


要使用Spring MVC的异步功能,你得先确保你用的是Servlet 3.0或以上的版本,Maven中如此配置:


javax.servlet

javax.servlet-api

3.1.0

provided

org.springframework

spring-webmvc

4.2.3.RELEASE


我这里使用的Servlet版本是3.1.0,Spring MVC版本是4.2.3,建议使用最新的版本。


由于Spring MVC的良好封装,异步功能使用起来出奇的简单。传统的同步模式的Controller是返回ModelAndView,而异步模式则是返回DeferredResult


看这个例子:


@RequestMapping(value="/asynctask", method = RequestMethod.GET)

public DeferredResult asyncTask(){

DeferredResult deferredResult = new DeferredResult ();

System.out.println("/asynctask 调用!thread id is : " + Thread.currentThread().getId());

longTimeAsyncCallService.makeRemoteCallAndUnknownWhenFinish(new LongTermTaskCallback() {

@Override

public void callback(Object result) {

System.out.println("异步调用执行完成, thread id is : " + Thread.currentThread().getId());

ModelAndView mav = new ModelAndView("remotecalltask");

mav.addObject("result", result);

deferredResult.setResult(mav);

}

});

}


longTimeAsyncCallService是我写的一个模拟长时间异步调用的服务类,调用之,立即返回,当它处理完成时候,就钩起一个线程调用我们提供的回调函数,这跟“图3”描述的一样,它的代码如下:


public interface LongTermTaskCallback {

void callback(Object result);

}

public class LongTimeAsyncCallService {

private final int CorePoolSize = 4;

private final int NeedSeconds = 3;

private Random random = new Random();

private ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(CorePoolSize);

public void makeRemoteCallAndUnknownWhenFinish(LongTermTaskCallback callback){

System.out.println("完成此任务需要 : " + NeedSeconds + " 秒");

scheduler.schedule(new Runnable() {

@Override

public void run() {

callback.callback("长时间异步调用完成.");

}

}, "这是处理结果:)", TimeUnit.SECONDS);

}

}


输出的结果是:


/asynctask 调用!thread id is : 46

完成此任务需要 : 3 秒

异步调用执行完成, thread id is : 47


由此可见返回结果的线程和请求处理线程不是同一线程。


还有个叫WebAsyncTask


返回DefferedResult 并非唯一做法,还可以返回WebAsyncTask来实现“异步”,但略有不同,不同之处在于返回WebAsyncTask的话是不需要我们主动去调用Callback的,看例子:


@RequestMapping(value="/longtimetask", method = RequestMethod.GET)

public WebAsyncTask longTimeTask(){

System.out.println("/longtimetask被调用 thread id is : " + Thread.currentThread().getId());

Callable callable = new Callable () {

public ModelAndView call() throws Exception {







请到「今天看啥」查看全文