Spring云数据流聚合器示例

任何人都可以指出一些特定于String Cloud Data Flow（非Stream XD）的示例，介绍如何编写分离器和聚合器？Spring云数据流聚合器示例

特别是非平凡的拆分和消息的加入。任何不重要的复杂流的例子。你如何定义一个在分离之后聚合消息的流，如果有路由器，并且为生成的消息进行不同的处理，那么以后如何聚合？ PS：对不起，我会根据需要澄清。谢谢！

2017-01-16 ka2

有一个开箱即用的应用程序splitterhere可用。聚合器尚未添加到OOTB应用中，并且正在跟踪here。您可以根据this编写应用程序，欢迎您的贡献！

2017-01-17 04:08:12

谢谢！我已经阅读了所提供的链接，还有一些可能会有用，以防有人发现这个问题：[link] https://github.com/spring-cloud/spring-cloud-stream-app-starters它包含其他初学者。基于文档结束的生成器非常简单，使用@Agregator批注的方法，Message作为参数列表并返回单个Message结果...仍然没有回答复杂流的示例问题。 – ka2

我会将此标记为答案，因为它可以提供很好的参考，但是可以更好地发布更复杂的示例...... – ka2

Spring云数据流聚合器示例

回答

相关问题