java - 如何在微服务的多个实例之间维护 SseEmitters 列表？

Question

语言:Spring Boot，JS

概述 :我正在我的应用程序中实现服务器发送事件功能，该功能将部署在云代工厂中，
其中基于队列中的新消息(我已在我的微服务中订阅)，我将向我的客户端/浏览器(使用 EventSource)发送一些更新。
为此，我在我的服务器端维护一个 SseEmitters 列表(用于维护所有 Activity 的 SseEmitter)。一旦我从队列中收到一条新消息，基于 id(队列消息中的一个字段)，我会将消息发送到相应的客户端。

问题 : 当我通过创建 来扩展我的应用程序时，上述方案将如何工作多个实例 其中。由于只有一个实例会收到新的队列消息， 可能会发生。活跃的 SseEmitter 在该特定情况下未维护，我该如何解决？

Answer 1

为了解决这个问题，可以观察以下方法。
DNS 概念
如果您考虑一下，知道您的用户(SSE Emitter)在哪里，就像知道某个网站在哪里一样。您可以使用 DNS-look-alike 协议(protocol)来确定您的用户在哪里。协议(protocol)如下:

当用户登陆您的任何实例时，将用户与该实例相关联。关联可以通过使用外部组件来完成，例如Redis 或 Hazelcast 等分布式 map 解决方案。

每当用户从 SSE 断开连接时，删除关联。有时没有使用 Spring SSEEmiter 正确注册断开连接，因此可以在 sendig 消息失败时进行解除关联。

其他方(微服务)可以轻松查询 Redis/Hazelcast 以确定用户是哪个实例。

消息路由概念
如果您使用消息中间件在微服务之间进行通信，则可以使用 AMQP 协议(protocol)提供的路由功能。协议(protocol)如下:

每个 SSE 实例创建 他们自己的队列开机

用户登陆任何 SSE 实例，实例添加交换队列绑定(bind)，路由键 = 用户 uid

每当用户从 SSE 断开连接时，删除关联。有时没有使用 Spring SSEEmiter 正确注册断开连接，因此可以在 sendig 消息失败时进行解除关联。

其他方(微服务)需要向交换机发送消息并定义路由 key 。 AMQP 代理根据路由键确定哪个队列应该接收消息。

在像 RabbitMQ 这样的现代 AMQP 代理上，绑定(bind)不是资源密集型的。
您的问题很老，如果您现在还没有弄清楚，希望这会有所帮助。