支持动态路由消息的Spring云流

Question

我希望创建一个公共项目(使用spring云流)，根据消息内容动态地将消息路由到不同的(使用者)项目。(rabbitmq作为消息代理)

春云流支持它吗？如果没有，是否有建议的方法来实现这一点？thx

Answer 1

您可以通过将spring.cloud.stream.dynamicDestinations属性设置为目标名称列表(如果事先知道名称)或将其保持为空来实现这一点。BinderAwareChannelResolver负责为这些动态目的地动态创建/绑定出站通道。

有一个现成的router 应用程序可以做类似的事情。

Answer 2

您可以在主题名称中使用StreamBridge，spring云将在运行时自动将其与目的地绑定。

@Autowired
private final StreamBridge streamBridge;
  
public void sendDynamically(Message message, String topicName) {
    streamBridge.send(route, topicName);
}

目的地