近年来，随着 Web 技术的不断发展和普及，实时数据的需求越来越大。SSE（Server-Sent Events），也称为 EventSource，是一种用于实时推送数据到前端的协议。相比 WebSocket，它更加轻量级，简单易用，不需要繁琐的握手过程。在本文中，我们将使用 Tornado 框架来实现 SSE 服务器，并提供完整的示例代码和详细的指导。在这之前，我们需要了解一些 SSE 的基础知识。
SSE 基础知识
SSE 是一种单向数据流的协议，常用于向客户端推送实时数据。它的工作方式基于 HTTP 1.1 协议，通过标准的 HTTP 连接进行长轮询，即客户端不断向服务器发送请求，服务器则只在有新数据时才响应客户端。SSE 通过一些特殊的 HTTP 头和事件流格式来传输数据。
SSE 的 HTTP 头
SSE 使用 text/event-stream 作为内容类型（Content-Type）返回数据。服务器也需要设置一些特殊的 HTTP 头以确保正确传输数据。
self.set_header("Content-Type", "text/event-stream")
self.set_header("Cache-Control", "no-cache")
self.set_header("Connection", "keep-alive")其中，Cache-Control 设置为 no-cache，禁止浏览器缓存 SSE 数据，Connection 设置为 keep-alive，保持连接不中断。
SSE 的事件流格式
SSE 通过事件流（Event Stream）来传输数据，每个事件包含一个字段和一个数据部分。事件可以是消息（message）或注释（comment）。消息包含一个事件名称（event）、字符数据（data）、标识符（id）和重试时间（retry），其中只有字符数据是必需的。注释以冒号（:）开头，可以用于调试或说明。以下是一个 SSE 事件流的示例：
data: This is a message id: 12345 event: message-type retry: 1000 : This is a comment
使用 Tornado 实现 SSE 服务器
在 Tornado 中实现 SSE 服务器也很简单，我们只需要继承 tornado.web.RequestHandler 类，用 self.write() 方法向客户端发送 SSE 事件流即可。以下是 Tornado SSE 服务器的示例代码：
-- -------------------- ---- -------
------ --------------
------ -----------
------ ----
----- ---------------------------------------
--- -----------------
------------------------------- --------------------
-------------------------------- -----------
----------------------------- -------------
----- --- ----------
------------------ -----------
----- -----
---- - ----- -- - ------- -- - - ----------------
----------------- - - ---- - -------
----- ------------
----- --------------------
-- -------- -- -----------
----------- - -------------------------
------ ------------
--
------------------------
---------------------------------------在上面的示例代码中，我们创建了一个名为 SSEHandler 的 SSE RequestHandler，并重写了它的 get() 方法。在 get() 方法中，我们通过 self.write() 方法不断向客户端发送 SSE 事件流，其中包含了一个消息事件，每秒钟发送一次。为了确保客户端能够正常接收事件流，我们设置了 retry 默认值为 10000，表示客户端在中断连接后等待 10 秒钟后重新连接。最后，我们在 __main__ 函数中创建了 Tornado 应用程序并监听在 8888 端口。
SSE 客户端的实现
最后，我们需要在客户端中实现 SSE 数据的接收和处理。在 Web 中，我们可以使用 JavaScript 的 EventSource 对象来实现这一目的。以下是一个基本的 SSE 客户端示例：
var source = new EventSource('/');
source.onmessage = function(event) {
console.log('Received a message: ' + event.data);
};在上面的代码中，我们通过创建 EventSource 对象并指定 URL 参数来连接到 SSE 服务器。一旦建立连接，当服务器向客户端推送新数据时，onmessage 事件回调函数将被触发，并将数据作为 event.data 属性返回。如果需要向服务器发送其他 HTTP 请求，可以使用 EventSource.readyState 属性进行判断。当值为 2 时，表示已建立连接。
总结
通过本文的介绍，我们可以看到使用 Tornado 实现 SSE 服务器非常简单，既可以用作实时聊天室、推送通知、实时监控等应用场景，也能在使用 WebSocket 不太合适的环境下提供可靠的实时数据流。同时，我们还学习了 SSE 的基础知识和实现方式，非常适合对 Web 开发感兴趣或者想了解新技术的程序员涉猎。
来源：JavaScript中文网 ，转载请注明来源 https://www.javascriptcn.com/post/6464d367968c7c53b05ac1f1