使用Xamarin消费Spring SSE

Question

我有一个spring boot后端，我想为它实现一个SSEendpoint。我想使用基于Xamarin表单的应用程序使用这个endpoint。

我设法为双方实现了一些例子，但是，我没有在应用程序上收到任何消息。

对于后端部分，我实现了以下示例:

    @RequestMapping(value = "/event-stream", method = RequestMethod.GET)
    public ResponseEntity<ResponseBodyEmitter> streamEvents() {
        ResponseBodyEmitter emitter = new ResponseBodyEmitter();
        executor.execute(() -> {
            try {
                for (int i = 0; i < 30; i++) {
                    Thread.sleep(2000);
                    var msg = new ResponseTestObject("this is a message from " + new Date(), i);
                    emitter.send(msg, MediaType.APPLICATION_JSON);
                }
                emitter.complete();
            } catch (Exception ex) {
                emitter.completeWithError(ex);
            }
        });
        return new ResponseEntity<>(emitter, HttpStatus.OK);
    }
    @AllArgsConstructor
    public static class ResponseTestObject {
        public String message;
        public int id;
    }

注意：我特意以达到默认30秒超时的方式实现它。使用postman调用此方法，它将加载所述30秒并同时显示所有已发送的消息：

{
    "message": "this is a message from Thu May 05 11:36:25 CEST 2022",
    "id": 0
}{
    "message": "this is a message from Thu May 05 11:36:27 CEST 2022",
    "id": 1
}
[...]
{
    "message": "this is a message from Thu May 05 11:36:51 CEST 2022",
    "id": 13
}{
    "message": "this is a message from Thu May 05 11:36:53 CEST 2022",
    "id": 14
}

在我的应用程序部分，我使用了ServiceStack ServerEventsClient：

EventClient = new ServerEventsClient(BackendConnector.BACKEND_HOST + "/events/") {
    OnMessage = OnMessage,
    OnException = (ex) => {
        Console.WriteLine("OnException: " + ex.Message);
    }
};
// another REST backend connection is made previously in the app and I use its session cookie for authentication
EventClient.ServiceClient.SetCookie(BackendConnector.SESSION_COOKIE_VALUE, BackendConnector.BackendSessionCookieId);
EventClient.Start();

启动客户端后，我让它定期发布如下状态：

Console.WriteLine("SSE " + EventClient.Status);

我能看到的是以下内容：

1. 后端的“订阅”有效。我可以看到请求，它确实开始运行后端线程
2. 状态日志显示，进入“开始”一段时间后，状态变为“开始”
3. 开始状态将保持这种状态，直到达到30的超时。然后它重新连接，循环继续
4. OnMessage方法永远不会被调用，即使在超时之后也不会，就像我在postman中看到的那样

补充说明：我还有一个使用 SseEmitter 的服务器端测试实现。在这种情况下，我也可以在“订阅”期间看到应用程序请求，但它会在某个时候超时，并且客户端状态永远不会离开“正在启动”

我的第一个问题显然是：我错过了什么，我永远不会收到消息？

我的第二个问题是：为什么它首先会超时？根据留档，它会发送周期性心跳。我需要在Spring侧采用不同的方法吗？或者我需要为心跳实现一个单独的endpoint？

谢谢你的帮助！

编辑：

遵循@mythz答案并接受在这里使用ServiceStack不是一个好主意，我遵循了以下示例，并使用标准的HttpClient和StreamReader实现了一种简单的方法：https://makolyte.com/event-driven-dotnet-how-to-consume-an-sse-endpoint-with-httpclient/

但是，这导致了我之前使用postman或浏览器时遇到的相同问题。所有消息都在30年代超时后批量发送。因此，我还更改了后端部分并使用Spring Web通量代替：

public Flux<ServerSentEvent<String>> streamEvents() {
        return Flux.interval(Duration.ofSeconds(1))
                .map(sequence -> {
                    var msg = new ResponseTestObject("this is a message from " + new Date(), Math.toIntExact(sequence));
                    ObjectMapper mapper = new ObjectMapper();
                    try {
                        return ServerSentEvent.<String>builder()
                                .id(String.valueOf(sequence))
                                .event("periodic-event")
                                .data(mapper.writeValueAsString(msg))
                                .build();
                    } catch (JsonProcessingException e) {
                        return null;
                    }
                });
}

Answer 1

我强烈建议您不要将ServiceStack的ServerEventsClient与ServiceStack的Server Events Feature之外的任何内容结合起来，这是其所有类型化的Server Events客户端都设计用于使用的功能。

例如。为了启用断开的网络连接和自动重试连接功能，客户端会发回周期性的心跳。这只是ServiceStack实现中的一个功能，因为SSE标准中没有这样的概念。

这只是一个例子，基本上C#服务器事件客户端中的每个高级都使用ServiceStack服务器功能，这些功能在任何其他第三方实现中都不存在。