标签：long-polling java struts2 comet
我想在java Web应用程序中实现长轮询.基本上,当用户登录时,我希望他被挂钩到通知服务中.我希望在服务器发生时向他推出新的通知,我希望他能够实时查看这些通知. (如此短的轮询或定期从客户端检查服务器是不够的).
我怎样才能做到这一点？本质上,我想要一种方法从服务器推送一个字符串消息,并让客户端立即接收它.
我听过一些引用,可以使用服务器的“http chunk transfer”标头来完成.但是如何在客户端设置？
解决方法:
虽然我迟到了,但我会继续说明我的答案.如果您使用的是HTML 5,
尝试使用HTML 5 – Server Sent Events(SSE)和HTML 5 – Web Workers.
请注意,MS IE目前不支持SSE.
在Struts2上,可能有一个标准操作来处理请求.
另见question.
您还可以查看当前的兼容性here.
有一个演示here,我们可以看到周期性的请求(在网络监视器中)并且可以很好地了解可以做什么.
另请注意,URL(事件源)只能分配一次.
更新：从我周围的内容(参见here和here),SSE实际上维护一个连接,以便从服务器接收定期更新.因此,服务器也可以具有“无限循环”,直到客户端终止然后尝试重新连接,在这种情况下服务器可以再次重新发送事件.
如果或在必要时,确定客户遗漏哪些事件应由实施方案处理.
这是demos SSE with a connection being maintained的链接.
根据spec,我们还应该能够在标题中发送“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
标签：long-polling,java,struts2,comet 来源： https://codeday.me/bug/20190831/1776410.html
本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享； 2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关； 3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关； 4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除； 5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。