SpringCloud Binder抽象

2023-11-24 15:44 更新

Spring Cloud Stream為Kafka和Rabbit MQ提供了Binder實(shí)現(xiàn)。Spring Cloud Stream還包括一個(gè)TestSupportBinder，它使通道保持不變，因此測(cè)試可以與通道直接交互并可靠地?cái)嘌运邮盏膬?nèi)容。您也可以使用可擴(kuò)展的API編寫自己的Binder。

Spring Cloud Stream使用Spring Boot進(jìn)行配置，而Binder抽象使Spring Cloud Stream應(yīng)用程序可以靈活地連接中間件。例如，部署者可以在運(yùn)行時(shí)動(dò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會(huì)使其從raw-sensor-data Kafka主題或綁定到該隊(duì)列的隊(duì)列中讀取raw-sensor-data RabbitMQ交換。

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


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

掃描二維碼

下載編程獅App

公眾號(hào)
微信公眾號(hào)

編程獅公眾號(hào)