領先一步
VMware 提供培訓和認證,以加速您的進展。
了解更多我們很高興宣布 Spring Cloud Stream Horsham (3.0.0.RELEASE) 版本系列的發佈,此版本作為 Spring Cloud Hoxton.RELEASE(即將推出)的一部分提供,並基於 Spring Boot 2.2.x 和 Spring Cloud Function 3.0.0.RELEASE 建構,後者也剛發佈。
Spring Cloud Stream Horsham.RELEASE 模組可在 Maven Central 儲存庫中使用。
如這些文章(解密與簡化、函數式與反應式、Stream 與 Spring Integration 和 事件路由)在本公告之前提及的,此版本的核心主題是函數!
從歷史上看,Spring Cloud Stream 公開了基於註解的配置模型,該模型要求使用者了解並提供大量樣板資訊,而這些資訊本可以很容易地推斷出來。您可以在這裡閱讀更多詳細資訊,但隨著此版本和後續 Spring Cloud Functions 的發佈,情況已不再如此。
Stream 應用程式只是一個 boot 應用程式!
@SpringBootApplication
public class SampleApplication {
@Bean
public Function<String, String> uppercase() {
return value -> value.toUpperCase();
}
}
是的,以上是一個功能完整的 Spring Cloud Stream 應用程式
大多數值得注意的功能與增強都是為了強調我們對函數式程式設計模型的承諾;
路由函數 - 有效地對應於 @StreamListener
註解的 condition
屬性提供的同等功能(及更多)。有關更多詳細資訊,請參閱事件路由。
具有函數的多個綁定(多個訊息處理器)- 有關更多詳細資訊,請參閱單一應用程式中的多個函數。
函數arity(具有多個輸入/輸出的函數 - 可以訂閱或針對多個目標的單一函數)- 有關更多詳細資訊,請參閱具有多個輸入和輸出引數的函數。
對反應式程式設計的原生支援 - 自 v3.0.0 起,我們不再發佈 spring-cloud-stream-reactive 模組,而是依賴 spring cloud function 提供的原生反應式支援。為了向後相容性,您仍然可以從以前的版本引入 spring-cloud-stream-reactive。
Schema Registry 模組已遷移到一個獨立專案
如需更多資訊,您也應該查看更新後的使用者指南。
Kafka Streams binder 現在支援一流的基於函數的程式設計模型,使用該模型,您現在可以基於 java.util.function 支援來編寫 Kafka Streams 應用程式。這進一步減少了應用程式需要編寫的樣板程式碼,並使開發人員能夠專注於手頭的業務邏輯。有關更多詳細資訊,請造訪函數式樣式部分以取得更多詳細資訊。Soby Chako(Spring Cloud Stream Kafka binder 的負責人)計劃撰寫一系列專文,介紹所有新功能。
與往常一樣,我們歡迎回饋和貢獻,因此請透過 Stackoverflow 或 GitHub 和/或 Gitter 與我們聯繫