为什么此EventSource重复触发消息和错误

Why is this EventSource repeatedly triggering message and error?

本文关键字：消息 错误 EventSource 为什么      更新时间：2023-09-26

客户端如下所示：

var es = new EventSource("http://localhost:8080");
es.addEventListener("message", function(e) {
    alert("e.data") //Alerts "" every couple seconds
})
es.addEventListener("error", function(e) {
    alert("error") //Also fires every couple of seconds
})
var post_request = new XMLHttpRequest();
post_request.open("POST", "http://localhost:8080");
post_request.setRequestHeader("Content-Type", "text/plain");
post_request.addEventListener("readystatechange", function() {
    if (post_request.readyState == 4 && post_request.status == 200) {
        alert(post_request.responseText); //This works
    }
})
post_request.send("This is a test")

处理POST请求的服务器端Node.js如下所示：

function process_request(request, response) {
    var request_body = []
    request.on("data", function(chunk) {
        request_body.push(chunk)
    }) 
    request.on("end", function() {
        request_body = Buffer.concat(request_body).toString()+"'n"
        response.writeHead(200, {"Access-Control-Allow-Origin": "*",
                                 "Content-Type": "text/event-stream",
                                 "Connection": "keep-alive"
                                });
        response.end("data: " + request_body + "'n"); 
    })
}

如果我从客户端发送POST请求数据，它会按预期返回response.end()，但es每隔几秒钟就会触发一个错误，此外每隔几秒钟还会触发一个message事件。然而，当触发message事件时，它会提醒""，我不知道为什么？有人能帮我弄清楚这种行为吗？

编辑：刚刚检查了message和error事件上的es.readyState。readyState是error上的0，所以看起来可能是断开连接的结果。为什么会发生这种反复的断开连接？为什么重复的连接和断开会导致重复的message事件？

正在处理用户的SSE请求，发回一些数据，然后关闭连接。客户端看到连接丢失，几秒钟后重新连接（此重新连接是SSE的一个功能）。

所以，相反，你永远不应该退出。这意味着您需要确保永远不会到达request.on("end", ...。

这里是node.js中我以前使用过的一个基本SSE服务器：

var http = require("http");
var port = parseInt( process.argv[2] || 8080 );
http.createServer(function(request,response){
  console.log("Client connected:" + request.url);
  response.writeHead(200, { "Content-Type": "text/event-stream" });
  var timer = setInterval(function(){
    var content = "data:" + new Date().toISOString() + "'n'n";
    response.write(content);
    }, 1000);
  request.connection.on("close", function(){
    response.end();
    clearInterval(timer);
    console.log("Client closed connection. Aborting.");
    });
  }).listen(port);
console.log("Server running at http://localhost:" + port);

也就是说，我们用setInterval来保持运转。唯一要侦听的事件是客户端关闭连接。

相关文章：