Cli*_*ote 3 java struts2 comet long-polling
我想在 java web 应用程序中实现长轮询。基本上，当用户登录时，我希望他能够连接到通知服务。我想在新通知发生时从服务器向他推送新通知，并且我希望他实时查看这些通知。（如此短的轮询或定期检查来自客户端的服务器还不够好）。
我怎样才能做到这一点？本质上，我想要一种从服务器推送字符串消息的方法，并让客户端立即接收它。
我听说一些参考资料说这可以使用来自服务器的“http 块传输”标头来完成。但是如何在客户端上设置呢？
虽然我回答晚了，但我会继续并包括我的答案。如果您使用的是 HTML 5，请尝试使用HTML 5 - 服务器发送事件(SSE) 和HTML 5 - Web Workers。请注意，截至目前，MS IE 不支持 SSE。
在 Struts2 端，可能有一个标准动作来处理请求。
另请参阅此问题。您还可以在此处查看当前的兼容性。有一个演示在这里，在这里我们可以看到所取得的定期请求（网络监控），并给出了什么可以做一个好主意。
另请注意，URL（事件源）只能分配一次。
更新：从我另外查看的内容（请参阅此处和此处），SSE 实际上维护连接以便从服务器接收定期更新。因此，服务器也可以有一个“无限循环”，它会一直持续到客户端终止，然后尝试重新连接，在这种情况下，服务器可以再次重新发送事件。
确定客户端错过了哪些事件应在必要时由实现处理。
这是一个演示 SSE 并保持连接的链接。根据规范，我们还应该能够在标头中发送“Last-Event-ID”。但是还没有找到一个使用它的例子！
更新 2：一个使用 HttpServletResponse 维护连接并返回响应的示例，另一个使用 s2 流结果重复轮询操作并返回响应。关于没有保持连接时的轮询频率，chrome 似乎是 3 秒，而 Firefox 则要大得多。
1.) SSE.java
public class SSE extends ActionSupport {
public String handleSSE() {
HttpServletResponse response = ServletActionContext.getResponse();
response.setContentType("text/event-stream");
response.setCharacterEncoding("UTF-8");
System.out.println("Inside handleSSE()+suscribe "+Thread.currentThread().getName());
int timeout = 15*1000;
long start = System.currentTimeMillis();
long end = System.currentTimeMillis();
while((end - start) < timeout) {
try {
PrintWriter printWriter = response.getWriter();
printWriter.println( "data: "+new Date().toString() );
printWriter.println(); // note the additional line being written to the stream..
printWriter.flush();
} catch (IOException e) {
e.printStackTrace();
}
try {
Thread.currentThread().sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
end = System.currentTimeMillis();
}
System.out.println("Exiting handleSSE()-suscribe"+Thread.currentThread().getName());
return SUCCESS;
}
}
2.) SSES2.java
public class SSES2 extends ActionSupport {
private InputStream sseStream;
public InputStream getSseStream() {
return sseStream;
}
public String handleSSES2() {
System.out.println("Inside handleSSES2() ");
String result = "data: "+new Date().toString() + "\n\n";
sseStream = new ByteArrayInputStream(result.getBytes() );
System.out.println("Exiting handleSSES2() ");
return SUCCESS;
}
}
3.) struts.xml
<struts>
<include file="strutsBase.xml"/>
</struts>
4.) strutsBase.xml
<struts>
<!-- Configuration for the default package. -->
<package name="strutsBase" extends="struts-default" >
<!-- Default interceptor stack. -->
<default-interceptor-ref name="basicStack"/>
<action name="suscribe" class="com.example.struts2.sse.action.SSE" method="handleSSE">
<result name="success">/view/empty.txt</result>
<!-- we don't need the full stack here -->
</action>
<action name="suscribeStateless" class="com.example.struts2.sse.action.SSES2" method="handleSSES2">
<result name="success" type="stream">
<param name="contentType">text/event-stream</param>
<param name="inputName">sseStream</param>
</result>
</action>
</package>
</struts>
sse.html
<!doctype html>
<meta charset="utf-8">
<title>EventSource demo</title>
<h1>new EventSource() for S2</h1>
<p><output id="result">OUTPUT VALUE</output></p>
<script>
(function(global, window, document) {
'use strict';
function main() {
window.addEventListener('DOMContentLoaded', contentLoaded);
}
function contentLoaded() {
var result = document.getElementById('result');
var stream = new EventSource('suscribe.action');
stream.addEventListener('message', function(event) {
var data = event.data;
result.value = data;
});
}
main();
})(this, window, window.document);
</script>
<!--
Also See :
http://server-sent-events-demo.herokuapp.com/
-->
sseAction.html
Same as sse.html except that EventSource url is 'suscribeStateless.action' instead of suscribe.action