如何异步处理 SSE 事件？

Question

理想情况下，我希望能够做这样的事情

Request request = new Request("http://someendpoint")
request.onMessage(payload -> System.out.println(payload))
request.onError(error -> error.printStackTrace())
request.onClose(() -> System.out.println("closed"))
request.onConnect(isReconnect -> System.out.println("connected"))

显然不必完全像那样，只是认为这有助于解释我正在尝试做的事情。

我看到泽西岛对此有某种支持。我想找到一个替代方案，但如果没有其他选择，我会使用它。

Answer 1

SSE 在 JavaEE 8 到 javax.ws.rs.sse 包中的 JAX-RS 2.1 中可用。与同步或异步的请求和响应不同，SSE 本质上是异步的。

要了解 SSE 的演示，请查看 David Delabassee 的 video。您的代码（仅在客户端）看起来像这样：

Client client = ClientBuilder.newClient();
WebTarget target = client.target("http://someendpoint");

SseEventSource eventSource = SseEventSource.target(target)
                                           .reconnectingEvery(5, TimeUnit.SECONDS)
                                           .build();
eventSource.register(payload -> System.out.println(payload),   // Consumer<InboundSseEvent>
                     error -> error.printStackTrace(),         // Consumer<Throwable>
                     () -> System.out.println("no more events"));
eventSource.open();
// and eventually
eventSource.close();

没有用于（重新）连接和关闭的内置处理程序，但您可以自定义一些东西以获得相同的效果。

JAX-RS 2.1 实现（至少）：

Jersey 2.26，包含在 Glassfish 5 和 Payara 5 alpha/snapshot/pre-release.
RESTEasy 4.0.0.Beta1（不到一个月前发布）据报道可在 Wildfly 10 及更高版本上运行，但我认为只有 Wildfly 12 将实现完整的 JavaEE 8（公告随着时间...)。

如何异步处理 SSE 事件？

How can I asynchronously handle SSE events?

java

jakarta-ee

jax-rs

server-sent-events

java-ee-8