构建spring集成通道，因为spring websocket不支持非STOMP客户端的消息传递

Question

1. 移动客户端发送->“嗨，我的账单付了吗？”通过WebSocket.
2. websocket服务器接收此消息并通过redis pub/sub将其传递给websocket客户端服务。
3. 因为websocket服务器和websocket客户端通过Redi pub/sub连接。它们可以交换消息。
4. WebSocket客户端将通过socket连接到人工代理系统，并通过“嗨，我的账单付了吗？”。
5. 响应（“是的，是付费的。”）将再次发布到websocket服务器。
6. WebSocket服务器将把它发送回特定的用户目标。

由于业务原因，我们希望为这个用例保留2个服务。Websocket客户端可以连接到客户代理系统，并与我们的业务逻辑解耦。我们的移动应用程序将与我们自己的websocket服务器对话。这使我们可以灵活地添加更多的定制，并独立于特定的供应商。

这是我的变通方法

null

Answer 1

请参见Java DSL动态和运行时集成流。

您可以按需注册和销毁子流。

保留对动态注册的流id的引用，并在上下文中调用remove()。