Spring Cloud Stream
Spring Cloud Stream 提高了您在使用 Apache Kafka、RabbitMQ、Azure Event Hub 等時的生產力,提供了三個關鍵抽象概念來簡化您的程式碼。「繫結器」與外部訊息傳遞系統整合。「繫結」彌合了訊息傳遞系統和您的程式碼之間的差距。「訊息」提供了您的程式碼用於發送和接收資料的結構。
Spring Cloud Stream 還提供對佈建、內容轉換、錯誤處理、組態管理、消費者群組、分割、監控和健康檢查的支援。
當與微服務結合使用時,事件串流開啟了令人興奮的機會——事件驅動架構就是一個常見的例子。Spring 簡化了事件的生產、處理和消費,並提供了幾個有用的抽象概念。
串流資料代表事件的持續流動。一個例子可能是股票行情。每次股票價格變動時,都會建立一個新事件。它被稱為「串流資料」,因為有成千上萬個事件導致持續的資料流。
任何事件驅動系統的基礎都是訊息處理。連接到訊息平台、路由訊息、轉換訊息、處理訊息。使用 Spring,您可以快速解決這些整合挑戰。
Spring Cloud Stream 提高了您在使用 Apache Kafka、RabbitMQ、Azure Event Hub 等時的生產力,提供了三個關鍵抽象概念來簡化您的程式碼。「繫結器」與外部訊息傳遞系統整合。「繫結」彌合了訊息傳遞系統和您的程式碼之間的差距。「訊息」提供了您的程式碼用於發送和接收資料的結構。
Spring Cloud Stream 還提供對佈建、內容轉換、錯誤處理、組態管理、消費者群組、分割、監控和健康檢查的支援。
@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。