繫結器抽象

Spring Cloud Stream 為 KafkaRabbit MQ 提供了繫結器實現。該框架還包含一個測試繫結器,用於將您的應用程式作為 Spring Cloud Stream 應用程式進行整合測試。更多詳情請參閱 [測試] 部分。

繫結器抽象也是框架的擴充套件點之一,這意味著您可以在 Spring Cloud Stream 之上實現自己的繫結器。在 《如何從零開始建立 Spring Cloud Stream 繫結器》 一文中,一位社群成員詳細記錄了實現自定義繫結器所需的一系列步驟,並提供了一個示例。這些步驟也在 實現自定義繫結器 部分中有所強調。

Spring Cloud Stream 使用 Spring Boot 進行配置,而繫結器抽象使得 Spring Cloud Stream 應用程式在連線中介軟體時具有靈活性。例如,部署人員可以在執行時動態選擇外部目標(如 Kafka 主題或 RabbitMQ 交換機)與訊息處理程式輸入和輸出(如函式的輸入引數及其返回引數)之間的對映。此類配置可以透過外部配置屬性提供,並且可以採用 Spring Boot 支援的任何形式(包括應用程式引數、環境變數以及 application.ymlapplication.properties 檔案)。在 Spring Cloud Stream 簡介 部分的 sink 示例中,將 spring.cloud.stream.bindings.input.destination 應用程式屬性設定為 raw-sensor-data 會使其從 raw-sensor-data Kafka 主題或繫結到 raw-sensor-data RabbitMQ 交換機的佇列中讀取。

Spring Cloud Stream 會自動檢測並使用類路徑上找到的繫結器。您可以使用相同的程式碼處理不同型別的中介軟體。為此,請在構建時包含不同的繫結器。對於更復雜的用例,您還可以將多個繫結器與您的應用程式一起打包,並在執行時讓它選擇繫結器(甚至為不同的繫結使用不同的繫結器)。

© . This site is unofficial and not affiliated with VMware.