在Spring Boot应用程序中发出有关资源更新的服务器发送事件

Question

我不熟悉服务器发送的事件。我正在使用React前端的Spring Boot应用程序。

在这里，我们有一个要求，如果同时多个用户在UI中打开一个资源，那么应用需要通知所有这些用户，以防其中一个用户正在更新同一资源。

在这方面，我正在搜索一篇相关文章，以便将服务器发送事件与我的Spring Boot应用程序集成，我发现：https://betterprogramming.pub/server-sent-events-on-react-and-spring-webflux-5f532b04633.

由此，我了解到，我必须向现有的Spring Boot应用程序添加web flux依赖项，并公开一个用于发出事件的endpoint。

但是在我的应用程序中，资源的更新正在使用终结点：/api/resource1完成，并且事件将从具有另一个终结点的应用程序中发出：/api/end-point-2如下：

负责更新对象的主要资源终结点如下所示：

 @RestController
    public class ResourceController {
    
        @CrossOrigin(allowedHeaders = "*")
        @GetMapping(value = "/api/resource1/")
        public MyObj updateMyObj(MyObj myObj) {
           ...
           return myRepository.save(myObj);
        }
    }

负责发出事件的其他endpoint将如下所示：

@RestController
public class ResourceController { //THIS IS GOING TO NOTIFY THE CLIENTS AT 1 SEC INTERVAL

    @CrossOrigin(allowedHeaders = "*")
    @GetMapping(value = "/api/end-point-2/", produces = MediaType.TEXT_EVENT_STREAM_VALUE)
    public Flux<MyObj> getMyObj() {
    
        return Flux.interval(Duration.ofSeconds(1))
                .map(it ->  <NOT ABLE TO UNDERSTAND WHAT SHOULD I WRITE HERE>);

    }
}

在这里，我无法理解，第一终端中的更新将如何传达给第二终端以通知客户端。

有人能帮忙吗？谢了。

Answer 1

我面临着非常相似的问题。看起来FluxSink可能有助于存储发出的事件。

然后，您可以使用ApplicationEventPublisher发布保存的实体或适当的信息:< code>MyObjSavedEvent。

另一方面，此解决方案需要在体系结构结构上进行更多更改，并且似乎非常适合 CQRS 和事件溯源方法，我们将事件存储在事件存储中。

我还在研究可能的解决方案。如果我发现有用的东西，我会告诉你的。