Servlet3.0: 简介AsyncContext
每个请求来到Web容器,Web容器会为其分配一条执行绪来专门负责该请求,直到回应完成前,该执行绪都不会被释放回容器。 执行绪会耗用系统资源,若有些请求需要长时间处理(例如长时间运算、等待某个资源),就会长时间占用执行绪,若这类的请求很多,许多执行绪都被长时间占用,对于系统就会是个效能负担,甚至造成应用程式的效能瓶颈。
基本上一些需长时间处理的请求,通常客户端也较不在乎请求后要有立即的回应,若可以,让这类请求先释放容器分配给该请求的执行绪,让容器可以有机会将执行绪资源分配给其它的请求,可以减轻系统负担。 原先释放了容器所分配执行绪的请求,其回应将被延后,直到处理完成(例如长时间运算完成、所需资源已获得)再行对客户端的回应。
在Servlet 3.0中,在ServletRequest上提供了 startAsync( )方法:
- AsyncContext startAsync() throws java.lang.IllegalStateException;
- AsyncContext startAsync(ServletRequest servletRequest,
- ServletResponse servletResponse)
- throws java.lang.IllegalStateException
这两个方法都会传回AsyncContext介面的实作物件,前者会直接利用原有的请求与回应物件来建立AsyncContext ,后者可以让你传入自己建立的请求、回应包裹物件。 在呼叫了startAsync()方法取得AsyncContext物件之后,这次的回应会被延后,并释放容器所分配的执行绪。
你可以透过AsyncContext的getRequest() 、 getResponse()方法取得请求、回应物件,此次对客户端的回应将暂缓至呼叫AsyncContext的complete()方法或dispatch()为止,前者表示回应完成,后者表示将回应调派给指定的URL 。
若要能呼叫ServletRequest的startAsync()使用AsyncContext,你的 Servlet 必须能支援非同步处理,如果使用@WebServlet来标注,则可以设定其asyncSupported为true 。 例如:
- @WebServlet(urlPatterns = "/some.do", asyncSupported = true )
- public class AsyncServlet extends HttpServlet {
- ...
如果使用web.xml设定Servlet,则可以设定<async-supported>标签为true :
- ...
- <servlet>
- <servlet-name>AsyncServlet</servlet-name>
- <servlet-class>cc.openhome.AsyncServlet</servlet-class>
- <async-supported>true</async-supported>
- </servlet>
- ...
如果Servlet将会非同步处理,若其前端有过滤器,则过滤器亦需标示其支援非同步处理,如果使用@WebFilter ,同样是可以设定其asyncSupported为true 。 例如:
- @WebFilter(urlPatterns = "/some.do", asyncSupported = true )
- public class AsyncFilter implements Filter{
- ...
如果使用web.xml设定过滤器,则可以设定<async-supported>标签为true :
- ...
- <filter>
- < filter -name>AsyncFilter</ filter -name>
- < filter -class>cc.openhome.AsyncFilter</ filter -class>
- <async-supported>true</async-supported>
- </ filter >
- ...
底下示范一个非同步处理的例子,对于进来的请求,Servlet会取得其AsyncContext ,并释放容器所分配的执行绪,回应被延后,对于这些被延后回应的请求,建立一个Runnable的物件,并将其排入一个执行绪池(Thread pool),执行绪池的执行绪数量是固定的,让这些必须长时间处理的请求,在这些有限数量的执行绪中完成,而不用每次请求都占用容器所分配的执行绪。
- package cc.openhome;
- import java.io.*;
- import java.util.concurrent.*;
- import javax.servlet.*;
- import javax.servlet.annotation.*;
- import javax.servlet.http.*;
- @WebServlet(name="AsyncServlet", urlPatterns={"/async.do"},
- asyncSupported = true )
- public class AsyncServlet extends HttpServlet {
- // 执行绪池
- private ExecutorService executorService = Executors.newFixedThreadPool(10);
- protected void processRequest(HttpServletRequest request,
- HttpServletResponse response)
- throws ServletException, IOException {
- response.setContentType("text/html; charset=UTF8");
- AsyncContext ctx = request.startAsync();
- executorService.submit(new AsyncRequest(ctx));
- }
- @Override
- protected void doGet(HttpServletRequest request,
- HttpServletResponse response)
- throws ServletException, IOException {
- processRequest(request, response);
- }
- @Override
- protected void doPost(HttpServletRequest request,
- HttpServletResponse response)
- throws ServletException, IOException {
- processRequest(request, response);
- }
- @Override
- public void destroy() {
- executorService.shutdown();
- }
- }
AsyncRequest是个实作Runnable的类别,其模拟了长时间处理:
- package cc.openhome;
- import java.io.PrintWriter;
- import javax.servlet.AsyncContext;
- public class AsyncRequest implements Runnable {
- private AsyncContext ctx;
- public AsyncRequest( AsyncContext ctx ) {
- this.ctx = ctx;
- }
- @Override
- public void run() {
- try {
- // 模拟长时间的处理
- Thread.sleep(10000);
- PrintWriter out = ctx.getResponse() .getWriter();
- out.println("久等了...XD");
- // 这边才真正送出回应
- ctx.complete();
- } catch (Exception e) {
- e.printStackTrace();
- }
- }
- }
最新文章
- ZIP压缩算法详细分析及解压实例解释
- PHP SESSION机制,从存储到读取
- Mybatis映射文件
- URL编码与解码
- AX 2012 query应用collections
- Volley(三)—— ImageRequest &; Request简介
- jiffies
- SSH 基础
- Android Studio中导入第三方库
- Androidstudio 点9图报错的问题
- win10安装MySQL
- 【iOS开发】添加子控件方式(懒加载,GCC)
- TDD(测试驱动开发)学习二:创建第一个TDD程序
- mysql 触发器学习
- Spring Boot 学习(3)
- Spring知识点回顾(08)spring aware
- NOPI实现导入导出泛型List,支持自定义列
- C# 插入超链接到PDF文档(3种情况)
- linux上的图片查看器FEH_image_view
- 【Eclipse】_Eclipse自动补全增强方法 &; 常用快捷键
热门文章
- Scrum生命周期
- java中Frame Jpanel等中间显示
- Longest Absolute File Path -- LeetCode
- [九省联考2018]林克卡特树(DP+wqs二分)
- POJ 1113 Wall(凸包)
- 7.3(java学习笔记)网络编程之UDP
- 《深入理解Spark-核心思想与源码分析》(三)第三章SparkContext的初始化
- (转)Android Eclipse 代码混淆
- 移动端与PHP服务端接口通信流程设计(增强版)
- 如何让vs2017 EF实体生成支持Mysql 和 Oracle?