如何让一个 Redis 客户端等待所有其他 Redis 客户端响应？

Question

我有一个 Redis 服务器和多个 Redis 客户端。每个 Redis 客户端都是一个 WebSocket+HTTP 服务器，其中包括管理 WebSocket 连接。这些 WebSocket+HTTP 服务器隐藏在负载均衡器后面。

WebSocket+HTTP 服务器提供GET /health HTTP 端点。我希望这个端点能够提供整个集群中当前 WebSocket 连接的总数。

当点击GET /health时，显然负载均衡器只会将请求分派给一个WebSocket+HTTP服务器实例。

如何让一个 WebSocket+HTTP 服务器实例向所有其他实例询问它们当前管理的 WebSocket 连接数？

---

我想到了以下步骤：

1. 实例使用CLIENT LIST 了解当前有多少Redis 客户端（例如n）；
2. 然后实例将WEBSOCKET_CONNECTION_COUNT_REQUEST 发布到 Redis（假设所有 Redis 客户端都订阅了此事件）；
3. 实例最终等待nWEBSOCKET_CONNECTION_COUNT_RESPONSEs，汇总计数，并通过HTTP返回。

您对上述方法有何看法？是不是有点太绕了？我觉得我可能有点过度设计......

---

我最初认为实例可以INCR/DECR Redis 存储中的计数，但我不确定如何处理被杀死的实例（因为计数应该相应减少）。我认为临时解决方案会更好。不过仍然对想法持开放态度。

Answer 1

我会使用一个排序集，其中成员是 WS 服务器 ID，分数是他们最后一次“ping”的时间戳。

通过使用其 id 更新已排序集，让每个 WS 定期“ping”（例如每 10 秒）。您可以使用 Lua 脚本从服务器获取时间并设置成员的分数以使一切变得美好和原子：

redis.replicate_commands()
local t = redis.call('TIME')
return redis.call('ZADD', KEYS[1], tonumber(t[0]), ARGV[1])

因此，如果您的排序集被称为“wsservers”并且 WS 的 id 是 foo，您可以在加载脚本后使用 EVALSHA <script-sha1> 1 wsservers foo 调用它。

要返回计数，您只需在最后一个周期（即 11 秒）的已排序集上设置一个范围并计算结果。您还可以利用这个机会来修剪旧的死服务器。当然，Lua 脚本是我的首选方法，这两项任务都无需实际将原始 WS 成员发送到调用客户端：

local t = redis.call('TIME')
local live = redis.call('ZRANGE', KEYS[1], tonumber(t[0])-11, '+inf')
redis.call('ZREMRANGEBYSCORE', KEYS[1], '-inf', tonumber(t[0])-11)
return #live