Servlet 3.0 异步传输的使用
AjaxCometServlet.java
import java.io.IOException;
import java.io.PrintWriter;
import java.util.Queue;
import java.util.concurrent.ConcurrentLinkedQueue;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;
import javax.servlet.AsyncContext;
import javax.servlet.AsyncEvent;
import javax.servlet.AsyncListener;
import javax.servlet.ServletConfig;
import javax.servlet.ServletException;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
@WebServlet(urlPatterns = {"/chat"}, asyncSupported = true)
public class AjaxCometServlet extends HttpServlet {
private static final Queue<AsyncContext> queue = new ConcurrentLinkedQueue<AsyncContext>();
private static final BlockingQueue<String> messageQueue = new LinkedBlockingQueue<String>();
private static final String BEGIN_SCRIPT_TAG = "<script type='text/javascript'>\n";
private static final String END_SCRIPT_TAG = "</script>\n";
private static final long serialVersionUID = -2919167206889576860L;
private Thread notifierThread = null;
@Override
public void init(ServletConfig config) throws ServletException {
Runnable notifierRunnable = new Runnable() {
public void run() {
boolean done = false;
while (!done) {
String cMessage = null;
try {
cMessage = messageQueue.take();
for (AsyncContext ac : queue) {
try {
PrintWriter acWriter = ac.getResponse().getWriter();
acWriter.println(cMessage);
acWriter.flush();
} catch(IOException ex) {
System.out.println(ex);
queue.remove(ac);
}
}
} catch(InterruptedException iex) {
done = true;
System.out.println(iex);
}
}
}
};
notifierThread = new Thread(notifierRunnable);
notifierThread.start();
}
@Override
protected void doGet(HttpServletRequest req, HttpServletResponse res) throws ServletException, IOException {
res.setContentType("text/html");
res.setHeader("Cache-Control", "private");
res.setHeader("Pragma", "no-cache");
PrintWriter writer = res.getWriter();
// for IE
writer.println("<!-- Comet is a programming technique that enables web servers to send data to the client without having any need for the client to request it. -->\n");
writer.flush();
final AsyncContext ac = req.startAsync();
ac.setTimeout(10 * 60 * 1000);
ac.addListener(new AsyncListener() {
public void onComplete(AsyncEvent event) throws IOException {
queue.remove(ac);
}
public void onTimeout(AsyncEvent event) throws IOException {
queue.remove(ac);
}
public void onError(AsyncEvent event) throws IOException {
queue.remove(ac);
}
public void onStartAsync(AsyncEvent event) throws IOException {
}
});
queue.add(ac);
}
@Override
@SuppressWarnings("unchecked")
protected void doPost(HttpServletRequest req, HttpServletResponse res) throws ServletException, IOException {
res.setContentType("text/plain");
res.setHeader("Cache-Control", "private");
res.setHeader("Pragma", "no-cache");
req.setCharacterEncoding("UTF-8");
String action = req.getParameter("action");
String name = req.getParameter("name");
if ("login".equals(action)) {
String cMessage = BEGIN_SCRIPT_TAG + toJsonp("System Message", name + " has joined.") + END_SCRIPT_TAG;
notify(cMessage);
res.getWriter().println("success");
} else if ("post".equals(action)) {
String message = req.getParameter("message");
String cMessage = BEGIN_SCRIPT_TAG + toJsonp(name, message) + END_SCRIPT_TAG;
notify(cMessage);
res.getWriter().println("success");
} else {
res.sendError(422, "Unprocessable Entity");
}
}
@Override
public void destroy() {
queue.clear();
notifierThread.interrupt();
}
private void notify(String cMessage) throws IOException {
try {
messageQueue.put(cMessage);
} catch(Exception ex) {
IOException t = new IOException();
t.initCause(ex);
throw t;
}
}
private String escape(String orig) {
StringBuffer buffer = new StringBuffer(orig.length());
for (int i = 0; i < orig.length(); i++) {
char c = orig.charAt(i);
switch (c) {
case '\b':
buffer.append("\\b");
break;
case '\f':
buffer.append("\\f");
break;
case '\n':
buffer.append("<br />");
break;
case '\r':
// ignore
break;
case '\t':
buffer.append("\\t");
break;
case '\'':
buffer.append("\\'");
break;
case '\"':
buffer.append("\\\"");
break;
case '\\':
buffer.append("\\\\");
break;
case '<':
buffer.append("<");
break;
case '>':
buffer.append(">");
break;
case '&':
buffer.append("&");
break;
default:
buffer.append(c);
}
}
return buffer.toString();
}
private String toJsonp(String name, String message) {
return "window.parent.update({ name: \"" + escape(name) + "\", message: \"" + escape(message) + "\" });\n";
}
}
ajax.js
var count=0;
$(document).ready(function () {
var url='/ajax/chat';
$('#login-name').focus();
$('#comet-frame')[0].src=url + '?' + count;
count ++;
$("#login-button").click(function () {
var name = $('#login-name').val();
if(! name.length > 0) {
$('#system-message').css("color","red");
$('#login-name').focus();
return;
}
$('#system-message').css("color","#2d2b3d") ;
$('#system-message').html(name + ':');
$('#login-button').disabled = true;
$('#login-form').css("display","none");
$('#message-form').css("display","");
var query =
'action=login' +
'&name=' + encodeURI($('#login-name').val());
$.ajax({
type:"post",
url:url,
data:query,
success:function (data,status) {
$('#message').focus();
},
error:function () {
alert("error occured!!!");
}
});
});
$("#post-button").click(function () {
var message = $('#message').val();
if(!message > 0) {
return;
}
$('#message').disabled = true;
$('#post-button').disabled = true;
var query =
'action=post' +
'&name=' + encodeURI($('#login-name').val()) +
'&message=' + encodeURI(message);
$.ajax({
type:"post",
url:url,
data:query,
success:function (data,status) {
$('#message').disabled = false;
$('#post-button').disabled = false;
$('#message').focus();
$('#message').val("");
},
error:function () {
alert("error occured!!!");
}
});
}
)
});
function update(data){
var p = document.createElement('p');
p.innerHTML = data.name + ':<br/>' + data.message;
$('#display')[0].appendChild(p);
}
index.html
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE html
PUBLIC "-//W3C//DTD XHTML 1.0 Strict//EN"
"http://www.w3.org/TR/xhtml1/DTD/xhtml1-strict.dtd">
<html xmlns="http://www.w3.org/1999/xhtml" xml:lang="en" lang="en">
<head>
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8" />
<title>Glassfish Chat</title>
<link rel="stylesheet" href="css/default.css" type="text/css" />
<script type="text/javascript" src="js/jquery-1.4.min.js"></script>
<script type="text/javascript" src="js/ajax.js"></script>
</head>
<body>
<div id="container">
<div id="container-inner">
<div id="header">
<h1>Glassfish Chat</h1>
</div>
<div id="main">
<div id="display">
</div>
<div id="form">
<div id="system-message">Please input your name:</div>
<div id="login-form">
<input id="login-name" type="text" />
<br />
<input id="login-button" type="button" value="Login" />
</div>
<div id="message-form" style="display: none;">
<div>
<textarea id="message" name="message" rows="2" cols="40"></textarea>
<br />
<input id="post-button" type="button" value="Post Message" />
</div>
</div>
</div>
</div>
</div>
</div>
<iframe id="comet-frame" style="display: none;"></iframe>
</body>
</html>
servlet形成异步处理的过程
在init()方法里，开启一条线程从消息队列中读取消息，并且在AsyncContext（异步上下文）中处理这些消息
PrintWriter acWriter = ac.getResponse().getWriter();
acWriter.println(cMessage);
acWriter.flush();
前面的代码写入一个信息，每个异步请求对应AsyncContext。
在doGet方法里，设置超时时间为10分钟，开始异步并且增加AsyncContext到队列中
final AsyncContext ac = req.startAsync();
ac.setTimeout(10 * 60 * 1000);
queue.add(ac);
对AsyncContext注册AsyncListener 监听器，在这种情况下，只有从队列中清理AsyncContext
ac.addListener(new AsyncListener() {
public void onComplete(AsyncEvent event) throws IOException {
queue.remove(ac);
}
public void onTimeout(AsyncEvent event) throws IOException {
queue.remove(ac);
}
public void onError(AsyncEvent event) throws IOException {
queue.remove(ac);
}
public void onStartAsync(AsyncEvent event) throws IOException {
}
});
在doPost方法里，将消息加入到消息队列里，消息在init方法里开启线程执行
问题：不明白在ajax.js中为什么要加上$('#comet-frame')[0].src=url + '?' + count;这么一句，不加上的话，页面显示不了！
分享到：
相关推荐
非常好的学习Servlet3.0资料。特此共享。
本系列讲座主要讲述如何利用Servlet3.0+mybatis+bootstrap+mysql构建企业级应用解决方案,主要分为三部分完成 第一部分：技能储备阶段，学习项目所需要的技能知识 第二部分：设计部分，通过需求分析，设计物理模型，...
本篇文章主要介绍了Servlet3.0学习总结之基于Servlet3.0的文件上传实例，具有一定的参考价值，有兴趣的可以了解一下
《Java Web开发详解——XML+DTD+XML Schema+XSLT+Servlet3.0+JSP2.2深入剖析与实例应用》不仅可以作为Java Web开发的学习用书，还可以作为从事Java Web开发的程序员的参考用书和必备手册。 此外，《Java Web开发详解...
学习servlet3.0 学习servlet3.0
这是最新的javaSERVLET贵发，包含了很多新的特性和功能，欢迎学习
Servlet3.0规范是JavaEE6.0规范中的子规范。其要求运行环境最多是JDK6.0、Tomcat7.0。而之前学习的是Servlet2.5版本规范，其是JavaEE5.0规范，其要求运行环境最多是JDK5.0、Tomcat5.0。
1.资源包内含有源码、数据库脚本、...4.本项目适合Java初学者，是一个JavaWEB入门级项目，后端技术栈为Servlet3.0，还适应于进行毕业设计和课题设计。 5.学技术，切忌急于求成，从基础学起，打好基础，祝你学习愉快。
【资源说明】 1、该资源内项目代码都是经过测试运行成功，功能正常的情况下才上传的，请放心下载使用。... Web容器： 支持Servlet 3.0规范的容器，如Apache Tomcat7。 数据库： MySQL8.0关系型数据库管理系统）.zip
来自Sun官方的Servlet规范文档，学习必备
不过还是写写，方便Ajax学习的后来者。 虽然js.html是一个纯静态的页面，但是以下的程序必须挂在Tomcat服务器上，才能做到Ajax交互，否则看不出效果的。 Eclipse for javaee注意把做好的工程挂在Tomcat上，才运行...
《JSP & Servlet学习笔记(第2版)》针对Servlet 3．0的新功能全面改版，无论章节架构还是范例程序代码，都做了全面更新，是作者多年来教学实践的经验总结，汇集了学员在教学过程中遇到的概念、操作、应用或认证考试上...
主要介绍了IDEA中HTML通过servlet3.0注解名提交表单到servlet类找不到页面的问题,本文通过场景描述及问题解析，给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下
本书是作者多年来教学实践经验的总结，汇集了教学过程中学生在学习JSP &Servlet;时遇到的概念、操作、应用或认证考试等问题及解决方案。 本书针对Servlet 3.0的新功能全面改版，无论是章节架构与范例程序代码，都...
本书是作者多年来教学实践经验的总结，汇集了教学过程中学生在学习JSP & Servlet时遇到的概念、操作、应用或认证考试等问题及解决方案。, 本书针对Servlet 3.0的新功能全面改版，无论是章节架构与范例程序代码，都做...
本书是作者多年来教学实践经验的总结，汇集了教学过程中学生在学习JSP & Servlet时遇到的概念、操作、应用或认证考试等问题及解决方案。 本书针对Servlet 3.0的新功能全面改版，无论是章节架构与范例程序代码，都...
本书是作者多年来教学实践经验的总结，汇集了教学过程中学生在学习JSP & Servlet时遇到的概念、操作、应用或认证考试等问题及解决方案。 本书针对Servlet 3.0的新功能全面改版，无论是章节架构与范例程序代码，都做...
本书是作者多年来教学实践经验的总结，汇集了教学过程中学生在学习JSP & Servlet时遇到的概念、操作、应用或认证考试等问题及解决方案。 本书针对Servlet 3.0的新功能全面改版，无论是章节架构与范例程序代码，都做...