3

我想在 Java Web 应用程序中实现长轮询。基本上，当用户登录时，我希望他被连接到通知服务中。我想在服务器发生新通知时向他推送新通知，并且我希望他实时看到这些通知。（如此短的轮询或从客户端定期检查服务器还不够好）。

我怎样才能做到这一点？本质上，我想要一种从服务器推送字符串消息并让客户端立即接收它的方法。

我听说过一些参考资料说这可以使用来自服务器的“http 块传输”标头来完成。但是如何在客户端上设置呢？

4

2 回答 2

6

虽然我回答迟了，但我会继续并包括我的答案。如果您使用的是 HTML 5，请尝试使用HTML 5 - Server Sent Events (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
于 2013-11-10T14:40:14.920 回答
1

如果可以的话，我会推荐使用像 Atmosphere 这样的现有库。Atmosphere 会自动尝试更现代的东西，但如果需要，会退回到长轮询。手动进行长时间轮询可能有点棘手。有一些未记录的东西，例如一些代理或负载平衡器需要某些配置设置或填充以使用长轮询。

于 2013-11-10T15:30:38.440 回答