什么是 SSE
SSE (Server-Sent Events) 是一种基于 HTTP 协议的服务器发送事件技术，可以实现服务器向客户端推送实时数据的功能。相较于 WebSocket，SSE 更加轻量级，易于实现和部署。
负载均衡问题
一般情况下，我们采用负载均衡技术将流量分发到多台服务器上，以提高系统的可靠性和性能。在使用 SSE 时，如果服务器采用了负载均衡技术，可能会出现以下问题：
- 客户端与服务器端建立长连接，会话持续时间较长，流量和连接数分布不均，导致某些服务器压力过大，造成服务不可用或响应极慢。
- 服务器在推送数据时，由于客户端与不同服务器建立的连接是不同的，如果服务器不同步推送数据，将导致客户端接收到的数据不一致。
解决方案
针对上述问题，我们可以采用以下方案：
1. 采用 sticky session 避免连接分配不均
sticky session 指的是客户端与同一服务器端建立长连接，在一定时间内保持会话。通过该技术，可以避免连接数和流量分布不均，减少服务器端的压力。在负载均衡策略中，如果采用轮询或者随机算法，可能会将客户端连接分配到不同的服务器上，这时我们可以通过配置负载均衡器的 sticky session 参数，将客户端连接分配到同一服务器上。
2. 同步推送数据
为了避免客户端接收到的数据不一致，我们需要采取同步推送数据的方式。一种常用的方式是将服务器端的数据推送至一个中心节点（例如 Redis），所有服务器都从该节点获取数据，并推送给客户端。
具体实现方式如下：
首先，我们需要在中心节点上开启一个发布/订阅（Pub/Sub）通道：
-- -------------------- ---- -------
----- ----- - -----------------
----- ------ - ---------------------
----- ------------ - --------------
------------------ -------- -- -
------------------ -- --------
---
------------------ -------- ----- -
------------------ ------ - - -----
---
----- ---------- - ----- ---- -- -
------------------- -------------
----------------------------- ---------------------
------------------------------ ------------
--------------------------- --------------
----- -------- - ----- -------- -- -
--------------------- - ------- -- ------- - - ---------
---------------------------------
---------------- - - ------------------- - --------
--
-------------------------------
-------------------- ----------
--------------- -- -- -
------------------- ----------------
---------------------------------
-------------------------------- ----------
----------
---
--在 SSE 事件处理器中，我们订阅了指定的 redis 发布/订阅通道，并监听通道上的消息。当中心节点发布消息时，所有服务器都会收到通知，从而实现数据的同步推送。在客户端与服务器端建立连接时，我们只需要将该通道的名称返回给客户端，客户端即可与服务器端共用该通道。
-- -------------------- ---- -------
----- ----- - -----------------
----- ------ - ---------------------
----- ------------ - --------------
------------------ -------- -- -
------------------ -- --------
---
------------------ -------- ----- -
------------------ ------ - - -----
---
----- ---------- - ----- ---- -- -
------------------- -------------
----------------------------- ---------------------
------------------------------ ------------
--------------------------- --------------
----- -------- - ----- -------- -- -
--------------------- - ------- -- ------- - - ---------
---------------------------------
---------------- - - ------------------- - --------
--
-------------------------------
-------------------- ----------
--------------- -- -- -
------------------- ----------------
---------------------------------
-------------------------------- ----------
----------
---
----------------- ---------
---------------- - - ------------ - --------
--在客户端代码中，我们首先与服务器端建立 SSE 连接，并在连接建立后向服务器端发送一个特殊事件 "sync"，该事件包含一个数据字段，其值为中心节点的 redis 发布/订阅通道的名称。
-- -------------------- ---- -------
----- ------ - --- --------------------
------------- - ------- -- -
----------------------- ----------
------------------------------- ------- -- -
--------------------- ---- ------ - - ------------
----- ------- - -----------
----- ------------ - --- ------------------- - ---------
---------------------- - ------- -- -
--------------------- -------- - - ------------
--
---
--
---------------- - ------- -- -
--------------------- -------- - - ------------
--当服务器端接收到该事件后，将 redis 发布/订阅通道的名称返回给客户端，客户端根据该名称新建一个 SSE 连接，并监听该通道上的消息。
总结
通过采用 sticky session 和同步推送数据的方式，可以有效解决 SSE 在使用负载均衡时遇到的问题。在实际开发中，还需要注意机器性能、网络状况等因素，以保证系统的稳定性和可靠性。
来源：JavaScript中文网 ，转载请注明来源 https://www.javascriptcn.com/post/647989d7968c7c53b0588d28