使用SSE在多个客户端之间共享可观测数据可以吗？

Question

我有一个服务（ServiceA），客户端可以订阅endpoint，订阅后，该服务使用服务器发送的事件连续产生数据。

如果这很重要的话，我将使用ProjectReactor和Java。

这可能很重要，所以我将解释这个endpoint的作用。每隔15秒，它从另一个服务（ServiceB）获取数据，检查15秒前获取的数据是否有更改，如果有，它将使用此数据生成一个新事件，如果没有更改，它将不发送任何内容（因此发送给客户端的负载尽可能小）。

现在，这个应用程序可以一次连接多个客户端，它们都要求相同的数据，而不是由用户过滤等。

这种可观察到的输出在多个客户端之间共享是明智的吗？

当然，这将为我们节省大量对ServiceB的不必要调用，但我想知道这种方法是否有反迹象——这是我第一次在后端编写反应式程序（来自RxJS），我不知道这是否会导致任何并发问题或任何其他类型的问题。

我可以看到的另一个好处是，一个新的客户端连接将立即从ServiceB接收到最后一次数据（每次调用通常需要大约4秒才能检索到此数据）。

我还想知道，是否只有在有一些订户的情况下，这个可观察对象才调用服务B，即，在至少有一个订户之前，调用该服务，如果没有订户，则停止调用该服务，当新订户订阅时，再次调用它，但首先向客户端获取最后获取的数据（无论数据有多旧或陈旧）。

Answer 1

您的SSE源可以使用以下模式完全共享：

source.publish().refCount();

请注意，您需要存储该调用的返回值，并将相同的实例返回给后续调用方，以便共享发生。

一旦所有订户取消订阅，refCount也将取消对原始源的订阅。在此之后，第一个进入的订阅者将触发对源代码的新订阅，您应该制作该订阅，以便它获取最新数据并每隔15秒重新初始化轮询周期。