4

我有一个使用 servlet 的简单服务器发送事件的运行实现。

protected void doGet(HttpServletRequest request, HttpServletResponse response) 
throws ServletException, IOException {
    // TODO Auto-generated method stub

    try
    {
        System.out.println("Server Sent Events");
        response.setContentType("text/event-stream");

        PrintWriter pw = response.getWriter();
        int i=0;
        pw.write("retry: 30000\n"); 
        System.out.println("----------------------");
        while(true)
        {
            i++;

            pw.write("data: "+ i + "\n\n");
            System.out.println("Data Sent : "+i);
            if(i>10)
                break;
        }

    }catch(Exception e){
        e.printStackTrace();
    }
}

我的客户端代码是

<!DOCTYPE html>
<html>
<body onload ="SSE()" >
<script>

    function SSE()
    {
        var source = new EventSource('GetDate');  
        source.onmessage=function(event)
        {
            document.getElementById("result").innerHTML+=event.data + "<br />";
        };
    }
</script>
<output id ="result"></output>

</body>
</html>

但是谁能解释一下这实际上是如何工作的？就像服务器如何一次性发送 11 个整数的块一样？是否有必要在此处冲洗或关闭 Printwriter。服务器是否每次都建立一个新的连接来发送数据

4

1 回答 1

2

响应流将内容写入 http 数据包的消息体。当您循环整数时，所有整数都一个接一个地添加到内容中。除非流上没有关闭刷新/关闭，否则您可以继续在流上写入，并且在您发送响应时，所有内容都将立即发送。

还有一些关于刷新和关闭的注意事项。你不需要 slufh，servlet 容器会为你刷新和关闭它。顺便说一句，关闭方式已经隐式调用了flush。调用flush通常只有当您在同一个流上有多个写入器并且您想要切换写入器（例如具有混合二进制/字符数据的文件），或者当您想要保持流指针打开的时间不确定（例如日志文件）。

于 2013-05-07T06:41:15.247 回答