我目前正在编写一个Comet应用程序,该应用程序要求我在持久连接上一次发送数据块。但是,在关闭连接之前,我无法将消息刷新到客户端。有什么原因导致PrintWriter.flush()方法的行为不像我认为的那样吗?
这是我的Tomcat Comet实现:
public void event(CometEvent event) throws IOException, ServletException {
HttpServletRequest request = event.getHttpServletRequest();
HttpServletResponse response = event.getHttpServletResponse();
if (event.getEventType() == EventType.BEGIN) {
request.setAttribute("org.apache.tomcat.comet.timeout", 300 * 1000);
PrintWriter out = response.getWriter();
out.println("BEGIN!");
out.flush();
System.out.println("EventType.BEGIN");
} else if (event.getEventType() == EventType.READ) {
InputStream is = request.getInputStream();
byte[] buf = new byte[512];
do {
int n = is.read(buf); //can throw an IOException
if (n > 0) {
System.out.println("Read " + n + " bytes: " + new String(buf, 0, n)
+ " for session: " + request.getSession(true).getId());
} else if (n < 0) {
return;
}
} while (is.available() > 0);
System.out.println("subtype: "+event.getEventSubType());
System.out.println("EventType.READ");
} else if (event.getEventType() == EventType.END) {
PrintWriter out = response.getWriter();
out.println("END!");
out.close();
System.out.println("checkError: "+out.checkError());
System.out.println(event.getEventSubType());
System.out.println("EventType.END");
//eventWorker.enqueue(new EndEvent(request, response));
} else if (event.getEventType() == EventType.ERROR) {
PrintWriter out = response.getWriter();
out.println("ERROR!");
out.flush();
System.out.println("checkError: "+out.checkError());
System.out.println("subtype: "+event.getEventSubType());
//response.getWriter().close();
System.out.println("EventType.ERROR");
} else {
(new ServletException("EXCEPTION")).printStackTrace();
}
}所以在这里我试着发送消息“开始!”然后保持连接打开,这样我就可以发送更多的数据。但是,消息似乎要等到连接关闭后才会通过。
这是我的ajax代码:$.post('comet',function(data) { alert(data);});
运行此代码后,Firebug告诉我这是响应头: Server: Apache-Coyote/1.1 Transfer-Encoding: chunked Date: Mon,13 Jul 200921:16:29 GMT
这让我想到我的浏览器收到了一些数据,但是我如何在连接关闭之前更新页面上的数据呢?
发布于 2009-07-14 15:36:29
因此,浏览器似乎一直在接收数据,但由于连接没有关闭,JavaScript认为数据仍在发送中。这就是我的jQuery回调函数没有被调用的原因。
查看W3C AJAX教程时,我注意到XMLHttpRequest对象有不同的就绪状态。
var xmlhttp;
if (window.XMLHttpRequest)
{
// code for IE7+, Firefox, Chrome, Opera, Safari
xmlhttp=new XMLHttpRequest();
}
else if (window.ActiveXObject)
{
// code for IE6, IE5
xmlhttp=new ActiveXObject("Microsoft.XMLHTTP");
}
else
{
alert("Your browser does not support XMLHTTP!");
}
xmlhttp.onreadystatechange=function()
{
if(xmlhttp.readyState==3) {
alert('process '+xmlhttp.responseText);
}
if(xmlhttp.readyState==4) {
alert('ready '+xmlhttp.responseText);
}
}
xmlhttp.open("GET","comet",true);
xmlhttp.send(null);传统上,人们只处理第四个readyState,这意味着传输已经完成。然而,在我的例子中,我需要在传输结束之前读取数据。因此,我需要代码来处理第三个readyState。
发布于 2009-07-13 21:40:52
我记得servlet有一个问题,如果您的页面被重定向(比如转到错误页面),那么当前的响应缓冲区(在本例中是writer )就会被丢弃,而不会被写入。
发布于 2009-07-14 01:34:37
我并不是真的理解其中的笑点。
所以,一旦出现错误并且连接关闭,我就会看到我之前尝试发送的所有消息。
那是什么意思?此外,您可能希望查看available()的api。我不认为它做的是你想的那样。
https://stackoverflow.com/questions/1122133
复制相似问题