SpringCloud Binder抽象

2023-11-24 15:44 更新

Spring Cloud Stream為Kafka和Rabbit MQ提供了Binder實現(xiàn)。Spring Cloud Stream還包括一個TestSupportBinder，它使通道保持不變，因此測試可以與通道直接交互并可靠地斷言所接收的內(nèi)容。您也可以使用可擴展的API編寫自己的Binder。

Spring Cloud Stream使用Spring Boot進行配置，而Binder抽象使Spring Cloud Stream應(yīng)用程序可以靈活地連接中間件。例如，部署者可以在運行時動態(tài)選擇通道連接到的目的地（例如Kafka主題或RabbitMQ交換）。可以通過外部配置屬性以及Spring Boot支持的任何形式（包括應(yīng)用程序參數(shù)，環(huán)境變量以及application.yml或application.properties文件）提供這種配置。在“ 介紹Spring Cloud Stream”的接收器示例中，將spring.cloud.stream.bindings.input.destination應(yīng)用程序?qū)傩栽O(shè)置為raw-sensor-data會使其從raw-sensor-data Kafka主題或綁定到該隊列的隊列中讀取raw-sensor-data RabbitMQ交換。

Spring Cloud Stream自動檢測并使用在類路徑上找到的活頁夾。您可以使用具有相同代碼的不同類型的中間件。為此，在構(gòu)建時包括一個不同的活頁夾。對于更復(fù)雜的用例，您還可以在應(yīng)用程序中打包多個活頁夾，并在運行時選擇活頁夾（甚至為不同的通道使用不同的活頁夾）。


以上內(nèi)容是否對您有幫助：
在線筆記
App下載
App下載

掃描二維碼

下載編程獅App

公眾號
微信公眾號

編程獅公眾號