在当今互联网时代，实时通信已经成为了人们极为关注的话题之一。尤其是随着社交媒体和在线游戏越来越流行，实时聊天已经成为了越来越多网站和APP的必备功能。本文将介绍如何使用 Server-Sent Events 和 Ruby on Rails 实现实时聊天功能。
什么是 Server-Sent Events
Server-Sent Events（简称SSE）是一种允许服务器推送数据到客户端的HTML5标准。与 WebSocket 不同，SSE 是一种单向通信，服务器向客户端发送数据，而客户端只能接收数据，不能向服务器发送请求。
SSE 的优点在于它比 WebSocket 更容易实现，并且浏览器兼容性更好。SSE 可以通过简单的 HTTP 请求和响应来实现，而且可以充分利用HTTP协议的缓存机制，减少网络带宽的消耗。
使用 Rails 实现 SSE
在 Rails 中实现 SSE 需要使用 Action Controller 中的 ActionController::Live 模块。ActionController::Live 可以让我们创建一个长连接（long-polling）来实现 SSE，服务器向客户端持续发送数据。下面是一个简单的例子：
-- -------------------- ---- -------
----- -------------- - ---------------------
------- ----------------------
--- -----
-------------------------------- - -------------------
----- ---- --
------- - ------------
------ ------------
---------------------------- ------------------------
---
----- -
---
------
---------------------
---
---这个例子中的 ChatController 控制器实现了一个实时聊天功能。当客户端连接到 /chat 路径时，服务器就开始向客户端不断发送数据。每秒钟服务器检查一次数据库是否有新的聊天消息，如果有就把消息以 JSON 格式发送到客户端。
注意到 response.stream.write 函数使用 data: 前缀指示这是一个数据消息。而 SSE 的每条数据消息需要以两个换行符（\n\n）结尾表示消息的结束。另外，Content-Type 需要设置为 text/event-stream。
在前端，客户端通过 EventSource 对象连接到 SSE 服务端：
const source = new EventSource('/chat');
source.onmessage = function(event) {
const message = JSON.parse(event.data);
// process message
};这样，服务器端和客户端就可以通过 SSE 实现实时聊天功能。
避免阻塞的影响
在上面的例子中，服务器不得不在循环中不断检查是否有新消息，这会导致服务器阻塞，无法处理其他请求。为了避免这种阻塞的影响，我们可以使用后台线程来监控消息队列：
-- -------------------- ---- -------
----- -------------- - ---------------------
------- ----------------------
--- -----
-------------------------------- - -------------------
----- - ---------
---------- --
---- --
------- - ---------
---------------------------- ------------------------
---
---
-------------------------------------------------- -- ------
----------------------- ---------- - ------ ---------- -------------
---
----- ---- --
-------------------------------------------------- -- ------
----------------------------------- -- ------- ---- --------
----- -- -------
---
---
---
------
---------------------
---
---这个例子中，我们把消息的检查和发送拆分成两个步骤：一个线程监控消息队列，另一个线程等待 PostgreSQL 数据库的通知，收到通知后将消息加入队列中。
这种方式可以避免服务器阻塞，提高服务的稳定性和性能。同时，这也是一种常见的实现 Web Push 的方式。
结论
本文介绍了使用 Server-Sent Events 和 Ruby on Rails 实现实时聊天功能的方法。我们了解了 SSE 的基本原理和使用 ActionController::Live 创建 SSE 的过程，并介绍了如何避免阻塞的影响。实时聊天是一个非常有用的功能，也是一个挑战性较高的技术问题。通过本文的学习，相信读者可以更好地理解 SSE 的使用方法，并对实时通信领域有更深入的理解和认识。
来源：JavaScript中文网 ，转载请注明来源 https://www.javascriptcn.com/post/6732fa640bc820c5823fd32c