在现代 Web 应用中，实时通信已经成为了必要的功能。实时通信可以用于聊天应用程序、分布式游戏、股票交易应用程序等等。在这篇文章中，我们将探讨如何在 Flask Web 应用程序中使用 Server-Sent Events（SSE）进行实时通信。
什么是 Server-Sent Events？
Server-Sent Events 允许 Web 服务器向客户端发送事件流。这意味着服务器可以主动通知客户端，而不必等待客户端发出请求。SSE 基于 HTTP 协议和纯文本数据格式，因此它非常容易实现和部署。另外，SSE 支持自动重连，如果连接出现问题，客户端会自动重连，保证了通信的可靠性。
在 Flask 中使用 Server-Sent Events
在 Flask 中使用 SSE，我们需要使用 Flask-SSE 这个扩展。Flask-SSE 最初由 Flask-SocketIO（一个 WebSocket 扩展）的作者创建，因此它与 Flask-SocketIO 兼容。
安装 Flask-SSE
首先，我们需要安装 Flask-SSE 扩展。可以使用 pip 进行安装：
pip install flask-sse
示例应用程序
接下来，我们将创建一个简单的 Flask 应用程序，用于演示如何使用 Server-Sent Events 进行实时通信。我们的应用将会包含两个页面：一个用于发送消息的表单页面，另一个用于接收消息的 SSE 流页面。
表单页面
我们将使用以下 HTML 代码来创建一个包含消息发送表单的页面：
-- -------------------- ---- -------
--------- -----
------
------
------------ --- ------------
-------
------
----- ------------- ---------------
------ ----------- -------------- ------------------ ---- ----------- --
------- ---------------------------
-------
-------
-------这段 HTML 代码创建了一个包含文本输入框和“发送”按钮的表单。表单将使用 POST 方法提交到 /send 路由。
SSE 页面
我们将使用以下 HTML 代码来创建一个 SSE 流页面：
-- -------------------- ---- -------
--------- -----
------
------
------------ --- ------------
-------
------
---- -------------------
--------
--- ------ - --- -----------------------
--- ------- - -----------------------------------
---------------- - --------------- -
----------------- -- ---------- - -------
-
---------
-------
-------这段 HTML 代码创建了一个 <div> 元素，用于显示接收到的消息。使用 JavaScript 创建了一个 EventSource 对象，将其连接到 /stream 路由。当接收到消息时，它会通过 onmessage 回调函数来更新 <div> 元素的内容。
Flask 应用程序
我们将使用以下 Flask 应用程序代码来处理表单提交和 SSE 流请求：
-- -------------------- ---- -------
---- ----- ------ ------ ---------------- -------- --------
---- --------- ------ ---
--- - ---------------
----------------------- - -------------------
--------------------------- ---------------------
---------------
--- --------
------ -----------------------------
------------------- -----------------
--- -------
------- - -----------------------
----------------------- --------- -------------------
------ --- ---
---------------------
--- ---------
--- -----------
------ - ------------
----------------------------
--- ------- -- ----------------
----- ------- ----------------------
------ -------------------- -----------------------------这段代码注册了 sse 蓝图，配置了 Redis 数据库，创建了三个路由：一个用于渲染表单页面，一个用于接收表单提交，并发布消息到 messages 频道上，最后一个用于创建 SSE 流，订阅 messages 频道，将消息发送给客户端。
在这个例子中，我们使用了 Redis 作为消息代理。Flask-SSE 内置了 Redis 支持，这使得它非常容易将 SSE 集成到现有的 Flask/Redis 应用程序中。
运行应用程序
完成应用程序代码后，我们可以运行应用程序：
export FLASK_APP=app.py export FLASK_ENV=development flask run
访问 http://localhost:5000/ 能够看到表单页面。在输入框中输入一些文本，点击“发送”按钮，然后转到 SSE 页面，可以看到接收到的消息。
总结
本文介绍了如何在 Flask Web 应用程序中使用 Server-Sent Events 进行实时通信。我们使用了 Flask-SSE 扩展，将 SSE 集成到了一个简单的应用程序中。希望本文对你有所帮助，让你了解了实时通信技术，并能够通过 Flask-SSE 扩展快速开始使用 SSE。
来源：JavaScript中文网 ，转载请注明来源 https://www.javascriptcn.com/post/651f98d695b1f8cacd722cb2