是否可以使用Spring XD加入多个流？

Question

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

Answer 1

可以使用命名通道执行此操作.例如,您可以创建输出到队列的多个流,以及使用队列作为源的"连接"流:

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的内容写入文件.