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雲數據流聚合器示例

回答

相關問題