spring-xd - 是否可以使用 Spring XD JOIN 多个流？

Question

我需要定义来自多个源的多个流，然后将它们合并为一个。在阅读了 Spring XD 的整个文档后，我没有找到任何可以执行连接的预定义模块(例如基于滑动窗口)。有什么解决办法吗？谢谢。

Answer 1

可以使用named channels来做到这一点。例如，您可以创建多个输出到队列的流，以及使用队列作为源的“加入”流:

xd:>stream create s1 --definition "http --port=9000 > queue:join" --deploy
xd:>stream create s2 --definition "http --port=9001 > queue:join" --deploy
xd:>stream create join --definition "queue:join > file" --deploy

上面的内容将发布到 http://somehost.example.com:9000或端口http://somehost.example.com:9001到一个文件。