Spring集成和反应WebSockets

Question

Spring integration提供了非反应的入站/出站WebSocket适配器，简单地说，它通过内部容器将会话与id相关联，您对消息进行一些处理，在出站时，它检查消息头是否有会话id，并通过该会话发送。

现在，Spring通过org.springframework.web.reactive.socket.WebSocketSession和其他类提供了反应性WebSocket支持，我想知道在反应性WebSocket堆栈的通道适配器方面也有类似的支持。

如果没有，是否有任何共同的模式/实践，如何将反应性WS与spring-integration消息流集成在一起？

Answer 1

这个特性还没有被调用，所以我们还没有想过这件事。

拜托，看看我的沙箱。这是我就目前的情况所能提出的最好的建议。

我们只是遵循标准的Spring WebFlux建议来实现WebSockets解决方案。因此，我们有一个WebSocketHandler实现，它具有适当的URL映射。实现只需将session.receive()中的flux转发到动态注册的IntegrationFlow中。然后，该流转换为用于会话.send()的反应性发布服务器。

但是，不确定session.send()是否可以独立地在下游使用（需要播放），但是您可以在示例中看到我如何将WebSocketSession传播到MessageHeaders中，以便在集成流中给予它访问权。