當與微服務結合使用時，事件流開啟了令人興奮的機會——事件驅動架構就是一個常見的例子。 Spring 簡化了事件的生成、處理和消費，提供了幾個有用的抽象。
流式傳輸資料表示事件的持續流動。一個例子可能是股票行情。每次股票價格發生變化時，都會建立一個新事件。之所以稱為“流式傳輸資料”，是因為有成千上萬個事件導致資料的持續流。
任何事件驅動系統的基石都是訊息處理。連線到訊息平臺、路由訊息、轉換訊息、處理訊息。藉助 Spring，您可以快速解決這些整合挑戰。
Spring Cloud Stream 在使用 Apache Kafka、RabbitMQ、Azure Event Hub 等時提高了您的生產力，提供了三個關鍵抽象來簡化您的程式碼。“繫結器”與外部訊息傳遞系統整合。“繫結”彌合了訊息傳遞系統和您的程式碼之間的差距。“訊息”提供您的程式碼用於傳送和接收資料的結構。
Spring Cloud Stream 還提供對配置、內容轉換、錯誤處理、配置管理、消費者組、分割槽、監控和執行狀況檢查的支援。
Spring [Cloud] Stream 和 Spring 解決方案幫助我們為命令式和反應式需求提供一個有凝聚力的解決方案。
@SpringBootApplication
public class Application {
public static void main(String[] args) {
SpringApplication.run(Application.class, args);}
@Bean
public Function<String, String> uppercase() {
return value -> value.toUpperCase();}
}
透過 Spring AMQP 和 Spring for Apache Kafka 專案，您可以將核心 Spring 概念應用於基於 Kafka 或 RabbitMQ 的訊息傳遞解決方案的開發。
兩者都包含“模板”作為高階訊息處理抽象，並支援具有“偵聽器容器”的訊息驅動的 POJO。
