springMvc异步的DeferredResult long polling应用方法


本篇内容介绍了“springMvc异步的DeferredResultlongpolling应用方法”的有关知识,在实际案例的操作过程中,不少人都会遇到这样的困境,接下来就让小编带领大家学习一下如何处理这些情况吧!希望大家仔细阅读,能够学有所成!Spring MVC 3.2开始引入了基于Servlet 3的异步请求处理。相比以前,控制器方法已经不一定需要返回一个值,而是可以返回一个java.util.concurrent.Callable的对象,并通过Spring MVC所管理的线程来产生返回值。与此同时,Servlet容器的主线程则可以退出并释放其资源了,同时也允许容器去处理其他的请求。通过一个TaskExecutor,Spring MVC可以在另外的线程中调用Callable。当Callable返回时,请求再携带Callable返回的值,再次被分配到Servlet容器中恢复处理流程。以下代码给出了一个这样的控制器方法作为例子:另一个选择,是让控制器方法返回一个DeferredResult的实例。这种场景下,返回值可以由任何一个线程产生,也包括那些不是由Spring MVC管理的线程。举个例子,返回值可能是为了响应某些外部事件所产生的,比如一条JMS的消息,一个计划任务,等等。以下代码给出了一个这样的控制器作为例子:如果对Servlet 3.0的异步请求处理特性没有了解,理解这个特性可能会有点困难。因此,阅读一下前者的文档将会很有帮助。以下给出了这个机制运作背后的一些原理:一个servlet请求ServletRequest可以通过调用request.startAsync()方法而进入异步模式。这样做的主要结果就是该servlet以及所有的过滤器都可以结束,但其响应(response)会留待异步处理结束后再返回调用request.startAsync()方法会返回一个AsyncContext对象,可用它对异步处理进行进一步的控制和操作。比如说它也提供了一个与转向(forward)很相似的dispatch方法,只不过它允许应用恢复Servlet容器的请求处理进程ServletRequest提供了获取当前DispatherType的方式,后者可以用来区别当前处理的是原始请求、异步分发请求、转向,或是其他类型的请求分发类型。有了上面的知识,下面可以来看一下Callable的异步请求被处理时所依次发生的事件:控制器先返回一个Callable对象Spring MVC开始进行异步处理,并把该Callable对象提交给另一个独立线程的执行器TaskExecutor处理DispatcherServlet和所有过滤器都退出Servlet容器线程,但此时方法的响应对象仍未返回Callable对象最终产生一个返回结果,此时Spring MVC会重新把请求分派回Servlet容器,恢复处理DispatcherServlet再次被调用,恢复对Callable异步处理所返回结果的处理对DeferredResult异步请求的处理顺序也非常类似,区别仅在于应用可以通过任何线程来计算返回一个结果:控制器先返回一个DeferredResult对象,并把它存取在内存(队列或列表等)中以便存取Spring MVC开始进行异步处理DispatcherServlet和所有过滤器都退出Servlet容器线程,但此时方法的响应对象仍未返回由处理该请求的线程对 DeferredResult进行设值,然后Spring MVC会重新把请求分派回Serv免费云主机域名let容器,恢复处理DispatcherServlet再次被调用,恢复对该异步返回结果的处理这里暂抛开某些场景webSocket的解决方案。举一个生活中的列子来说明长轮询比轮询好在哪里:电商云集的时代,大家肯定都有查询快递的经历,怎么最快知道快递的进度呢?polling和long polling的方式分别如下:polling:如果我想在两分钟内看到快递的变化,那么,轮询会每隔两分钟去像服务器发起一次快递变更的查询请求,如果快递其实是一个小时变更一次,那么polling的方式在获取一次真实有效信息时需要发起30次long polling:首先发起查询请求,服务端没有更新的话就不回复,直到一个小时变更时才将结果返回给客户,然后客户发起下次查询请求。长轮询保证了每次发起的查询请求都是有效的,极大的减少了与服务端的交互,基于web异步处理技术,大大的提升了服务性能如果在发散的触类旁通一下,long polling的方式和发布订阅的模式有点类似之处,只是每次拿到了发布的结果之后需要再次发起消息订阅因为DeferredResult技术,所以使得long polling不会一直占用容器资源,使得长轮询成为可能。长轮询的应用有很多,简述下就是:需要及时知道某些消息的变更的场景都可以用长轮询来解决,当然,你可能又想起了发布订阅了,哈哈比如:在线聊天?一个服务端,多个客户端,服务端管理所有的人的消息,客户端向服务端发起给自己的消息的请求,服务端处理后给返回,然后客户端再次发起?在比如类发布订阅的例子:配置中心服务,当配置中心的配置变更好,相关的客户端程序需要及时更新最新的配置。disconf就是基于zookeeper的发布订阅来做的,apollo就是采用的DeferredResult的long polling来做的,客户端发起长轮询,配置中心监听器监听到配置变更后,将结果响应给客户端。多个请求的结果,使用另一个请求控制他的响应返回。本实例构建在spring boot 1.5.7上。测试时,先启动contextLoads会发起四个异步请求,一直等待请求结果响应,直到testLongPolling通知服务端返回deferredResult的值。“springMvc异步的DeferredResultlongpolling应用方法”的内容就介绍到这里了,感谢大家的阅读。如果想了解更多行业相关的知识可以关注百云主机网站,小编将为大家输出更多高质量的实用文章!

相关推荐: Java SE如何求解汉诺塔问题

这篇文章主要介绍了JavaSE如何求解汉诺塔问题,具有一定借鉴价值,感兴趣的朋友可以参考下,希望大家阅读完这篇文章之后大有收获,下面让小编带着大家一起了解一下。汉诺塔问题是一个经典的问题。汉诺塔(Hanoi Tower),又称河内塔,源于印度一个古老传说。大梵…

免责声明:本站发布的图片视频文字,以转载和分享为主,文章观点不代表本站立场,本站不承担相关法律责任;如果涉及侵权请联系邮箱:360163164@qq.com举报,并提供相关证据,经查实将立刻删除涉嫌侵权内容。

(0)
打赏 微信扫一扫 微信扫一扫
上一篇 10/09 18:24
下一篇 10/09 18:25

相关推荐