Spring 云流支持动态路由消息

Question

我想创建一个公共项目（使用 spring 云流）以根据消息内容动态地将消息路由到不同的（消费者）项目。 （rabbitmq 作为消息代理）

spring云流支持吗？如果没有，有什么建议的方法可以实现吗？谢谢

Answer 1

您可以通过将 spring.cloud.stream.dynamicDestinations 属性 设置为目的地名称列表（如果您事先知道该名称）或将其保留为空来实现。 BinderAwareChannelResolver 动态地处理 creating/binding 这些动态目标的出站通道。

有一个开箱即用的 router application 可以做类似的事情。