Spring云流支持动态路由消息
我想创建一个公共项目（使用spring cloud stream），根据消息内容动态地将消息路由到不同的（消费者）项目。（rabbitmq作为消息代理）
spring cloud stream支持吗？如果没有，有什么建议的方法来实现这一点？thx公司
共有1个答案
您可以通过将spring.cloud.stream.dynamic目的地属性设置为目的地名称列表（如果您事先知道名称）或将其保持为空来实现这一点。BinderAware ChannelResolver负责为这些动态目的地动态创建/绑定出站通道。
有一个现成的路由器应用程序可以做类似的事情。
-
我已经实现了如下所示的示例Spring Dynamic Destination 在rabbitmq中，它动态地创建一个交换，但没有提供绑定或路由密钥的选项。我的要求是用路由密钥向这个动态创建的exchange发送消息。我需要如何实现这一点来设置路由密钥？
-
next.js（app router） 在 ssg（output: "export"） 模式下 我的动态路由 /app/live/[id]/page.tsx 可以类似 react-router 那样动态获取么 id 么（useParams），而不是用 generateStaticParams 去生成，因为可能会有数万乃至数 10 万个 id
-
我们正在将我们的工作和数据流从Spring XD迁移到Kubernetes上的Spring cloud数据流。 Spring cloud数据流有商业支持吗？任何链接都有帮助。
-
我正在使用Spring Cloud Stream，希望以编程方式创建和绑定通道。我的用例是，在应用程序启动期间，我收到要订阅的Kafka主题的动态列表。然后如何为每个主题创建频道？
-
Spring的云流是否也支持Kafka式的动觉再平衡？最近有人promise要解决这个问题https://github.com/spring-projects/spring-integration-aws/issues/99 谢谢
-
我正在尝试在最新版本的 Spring Cloud 流中使用基于内容的路由。根据这份文件 - 这是我用StreamListener编写的代码 通过使用该条件，可以将消息路由到两个不同的函数。 我正试图用如下的功能接口方法来消费消息。 如何在函数中实现类似的基于内容的路由？蒂亚。 其他细节- Spring引导版本 - 2.3.12.发布 Spring云版 - Hoxton.SR11