使用 Server-sent Events(SSE) 对后台性能监控数据进行实时推送

在开发 web 应用程序时,性能监控非常重要。可以使用各种工具和库来监控服务端和客户端的性能,但是对于实时监控,常用的解决方案是使用 SSE。

什么是 Server-sent Events(SSE)?

SSE(Server-sent Events,服务器推送事件)是 HTTP 的一部分,是用于在客户端和服务器之间进行实时通信的简单而强大的 API。与 WebSocket 不同,SSE 可以使用普通的 HTTP 服务器推送实时数据。SSE 还支持自动重连和事件 ID。

SSE API 的核心是 EventSource 对象。它允许客户端对事件源(服务器端)进行监听,并在接收到事件时执行回调函数。

如何实现 SSE

实现 SSE 的步骤非常简单:

  1. 在服务器端设置一个响应,该响应将使用 text/event-stream 格式输出响应数据。例如,使用 Node.js 可以这样实现:

    res.writeHead(200, {
      "Content-Type": "text/event-stream",
      "Cache-Control": "no-cache",
      "Connection": "keep-alive"
    });
    
    res.write("retry: 10000\n");
    
    setInterval(() => {
      const data = { ... }; // get the data to send
      res.write(`data: ${JSON.stringify(data)}\n\n`);
    }, 1000);

    上面的示例使用了 setInterval 定期发送数据,实际上,数据可以来自于性能监控工具或其他来源。

  2. 在客户端使用 EventSource 对象监听服务器端推送的数据,例如,在浏览器上可以这样实现:

    const source = new EventSource("/path/to/sse");
    
    source.onmessage = (event) => {
      const data = JSON.parse(event.data); // parse the incoming data
      // do something with the data
    };

收到的数据将通过 onmessage 事件返回。在响应主体中,数据的格式通常是 JSON 或 CSV,但这不是必需的。

当客户端与服务器之间的连接丢失致使浏览器端 EventSource 对象自动关闭时,EventSource 会重新建立一个连接,我们可以保证 SSE 的实时性。

SSE 的优缺点

虽然 SSE 是一种实现实时性很好的解决方案,但它并不是适用于所有的场景:

优点

  • 实现简单:与其他实时通信解决方案相比,SSE 实现起来非常简单。
  • 轻量级:SSE 在每次连接过程中,只需要单向的带有数据的消息,相比于Websocket,可以减轻服务器的压力
  • 自动重连:连接关闭时,客户端需要做一些额外的工作才能重新建立连接。在 SSE 中,这个过程是自动发生的,这意味着客户端不必主动重新建立连接。
  • 兼容性:由于 SSE 基于 HTTP 协议,因此它适用于任何支持 HTTP 的客户端或服务器,而无需浏览器扩展或插件。

缺点

  • 只能从服务器到客户端单向传输:SSE 只支持单向的服务器到客户端的数据传输,而客户端到服务器的通信需要使用其他解决方案。
  • 浏览器支持限制:虽然 SSE 是基于 HTTP 的协议,但并非所有浏览器都支持 SSE,尤其是 IE 浏览器在某些情况下无法正常运作。
  • 不适用于大型数据:由于 SSE 不支持压缩,因此发送大量数据时可能会耗费更多的带宽和更长的时间。

总结

使用 SSE 可以轻松实现实时性很好的性能监控。虽然 SSE 有一些限制,但在某些特定场景下,它是一种很好的选择。

以上就是关于使用 Server-sent Events(SSE) 对后台性能监控数据进行实时推送的详细介绍。希望这篇文章对您有所帮助。

如果您想要更好的理解 SSE 的实现,可以参考以下示例代码:

Server-side Code:

const http = require("http");

http.createServer((req, res) => {
  if (req.url === "/events") {
    res.writeHead(200, {
      "Content-Type": "text/event-stream",
      "Cache-Control": "no-cache",
      "Connection": "keep-alive"
    });

    res.write("retry: 10000\n");

    setInterval(() => {
      const data = { ... };
      res.write(`data: ${JSON.stringify(data)}\n\n`);
    }, 1000);
  } else {
    res.writeHead(200, { "Content-Type": "text/plain" });
    res.write("Hello World!");
    res.end();
  }
}).listen(3000);

console.log("Server started on http://localhost:3000");

Client-side Code:

const source = new EventSource("/events");

source.onmessage = (event) => {
  const data = JSON.parse(event.data);
  console.log(data);
};

来源:JavaScript中文网 ,转载请注明来源 本文地址:https://www.javascriptcn.com/post/659df8fbadd4f0e0ff7190e3


纠错反馈