Servlet3.0之异步支持

alex.Lin

浏览: 65749 次
性别:
来自: 上海

最近访客更多访客>>

topcloud

NigelChow

promiseloney

kencsdn

博主相关

博客

微博

相册

留言

关于我

文章分类

社区版块

存档分类

博客分类：

java

java servlet3.0 异步

将该部分单独拧出来，方便查看

3.3 异步的支持

3.3.1 AsyncContext接口

ServletRequest执行startAsync()或者startAsync(ServletRequest, ServletResponse) 进入异步模式，将会创建一个AsyncContext，将其需要异步的操作放在此AsyncContext中

addListener(AsyncListener listener)//可以增加监听器

3.3.2 ServletRequest接口

startAsync()

startAsync(ServletRequest, ServletResponse)

将当前请求/响应或指定请求/响应放到异步模式中

3.3.3 AsyncListener异步监听器

void	onComplete`(`AsyncEvent `event)` Notifies this AsyncListener that an asynchronous operation has been completed.
`void`	onError`(`AsyncEvent `event)` Notifies this AsyncListener that an asynchronous operation has failed to complete.
`void`	onStartAsync`(`AsyncEvent `event)` Notifies this AsyncListener that a new asynchronous cycle is being initiated via a call to one of the `ServletRequest#startAsync` methods.
`void`	onTimeout`(`AsyncEvent `event)` Notifies this AsyncListener that an asynchronous operation has timed out.

可以给AsyncContext实例增加一个AsyncListener监听器，当AsyncContext调用complete()完成后即可触发onComplete(e)方法

3.3.4 例子

asyncSupported要定义为true

3.3.4.1简单例子

@WebServlet(name = "syncServlet", value = { "/syncServlet"},asyncSupported=true)

publicclass SyncTestServlet extends HttpServlet {

privatestaticfinallongserialVersionUID = -126107068129496624L;

publicvoid doGet(HttpServletRequest request, HttpServletResponse response)

throws ServletException, IOException {

response.setContentType("text/html");

PrintWriter out = response.getWriter();

out.println("<!DOCTYPE HTML PUBLIC \"-//W3C//DTD HTML 4.01 Transitional//EN\">");

out.println("<HTML>");

out.println(" <HEAD><TITLE>A Servlet</TITLE></HEAD>");

out.println(" <BODY>");

out.print(" Servlet Start::: This is ");

out.print(this.getClass());

out.println(" using the GET method ");

out.flush();

//-------------增加一个异步线程

System.out.println("主response对象:"+response);

AsyncContext sc = request.startAsync(request,response);

Thread t = new Thread(new MyThread(sc));

t.start();

//-------------继续主线程

//注：主线程不需要等待子线程完毕，可以先执行并打印出来【异步进行】

out.println(" -------Servlet end.");

out.flush();

}

class MyThread extends Thread{

private AsyncContext syncContext;

public MyThread(AsyncContext syncContext){

this.syncContext = syncContext;

}

publicvoid run(){

System.out.println("MyThread start2....");

HttpServletResponse resp = (HttpServletResponse) syncContext.getResponse();

System.out.println("MyThread end2....");

try {

PrintWriter out = resp.getWriter();

out.println(" -----MyThread start----");

out.println(" -----wait running.....");

out.flush();//flush即可先输出，不需要等全部完成

System.out.println("子线程里的response对象（和主线程是同一个）:"+resp);

Thread.sleep(3000);

out.println(" -----MyThread end----");

out.println(" </BODY>");

out.println("</HTML>");

out.flush();

//out.close();

} catch (IOException e) {

// TODO Auto-generated catch block

e.printStackTrace();

} catch (InterruptedException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

syncContext.complete();//完成异步操作

}

代码之余轻松一下：当前热门-人民的名义

JAVAEE容器如何管理EntityManager和PersistenceContext

0
顶

0
踩

分享到：

Getting started with HTML5(整理) | Servlet3.0入门使用

2012-02-14 11:24
浏览 2611
评论(0)
分类:编程语言
查看更多

发表评论

您还没有登录,请您登录后再发表评论

最近访客更多访客>>

博主相关

文章分类

社区版块

存档分类

最新评论