Spring boot SSE（服务器发送事件）：如何动态发送响应答案

【问题标题】：Spring boot SSE (Server sent events): how to send response dynamicallySpring boot SSE（服务器发送事件）：如何动态发送响应
【发布时间】：2020-01-11 05:36:41
【问题描述】：

我是 SSE（服务器发送事件）的新手。我找到了一种在 Spring Boot 中使用 SSE 发送响应的方法。我能够每 20 秒发送一次响应。我用下面的代码来做同样的事情。

public Flux<UserDto> fetchUserEvent() {
        return Flux.interval(Duration.ofSeconds(20)).map(intr -> generateUserEvent()).flatMapIterable(x -> x);
    }

generateUserEvent() - verify if new user added in DB. If it found user data, will return the same or will return empty object (new UserDto())

但问题是，此方法每 20 秒调用一次。

但是，我的要求是每 20 秒向客户端发送一次空响应，并在新用户添加到数据库时发送响应。

我怎样才能实现我的目标？或者我在概念上完全错误。

【问题讨论】：

标签： spring-boot spring-webflux server-sent-events

【解决方案1】：

您应该创建一个事件发布者和侦听器，以便在注册新用户时向发射器发送事件。

由于您使用的是 spring-boot 并且可能是休眠的，因此您可以在此处查看有关如何拦截休眠事件的示例。

Hibernate interceptor or listener with Spring Boot and Spring Data JPA

我会个人不使用通量并在春季制定一个预定的方法来将那些空的 ping 响应发送到发射器。这方面的例子可以在这里找到：https://www.roytuts.com/server-sent-events-spring-push-notifications/

一般春季活动的更多信息可以在这里找到： https://www.baeldung.com/spring-events

【讨论】：