Spring集成-以编程方式创建/拆除通道

Question

与在Spring config中静态地声明它们相反，是否有可能以编程方式创建/拆除Spring集成通道？

我的情况是这样的：

我有一个需要推送通知的webapp，所以我使用长轮询。那些长时间的轮询调用需要在服务器上阻塞，直到它们得到一个事件。

我所设想的（当然，对替代方案持开放态度）是每个会话的Spring Integration队列通道，每个会话都收听单个pubsub通道。因此，当服务器事件发生时，它将被发布到 pubsub，然后 pubsub 将通过管道向下传输到各个会话队列，在那里它们将被弹出并发送到正在轮询的客户端。

为了做到这一点，当创建会话时，我必须在pubsub通道上注册新的队列通道列表。当会话被销毁时，新队列也将被销毁。

这样的事情可能吗？

我不想让会话直接监听pubsub，因为有丢失消息的风险，所以我想在两者之间有一个队列来缓冲它们。

谢谢，罗伊

Answer 1

是的，您可以简单地实例化一个< code>QueueChannel并使其成为< code>BridgeHandler的< code>outputChannel。然后创建一个< code>EventDrivenConsumer，在构造函数中传递pubSub和桥处理程序。

调用使用者的 start（） 以使其订阅 pubSub，并在会话关闭时调用 stop（） 以取消订阅。

如果您不想手动连接这些组件，只需声明队列通道，并在一个小的应用程序上下文中桥接；使其成为您的主上下文的子上下文，它将自动订阅父上下文中的pubSub。调用context.destroy（）断开连接。