Spring Integration
Spring Boot 為使用 Spring Integration 提供了多種便利,包括 spring-boot-starter-integration 啟動器。Spring Integration 提供了對訊息傳遞以及其他傳輸(如 HTTP、TCP 等)的抽象。如果 Spring Integration 在您的類路徑中可用,它將透過 @EnableIntegration 註解進行初始化。
Spring Integration 輪詢邏輯依賴於自動配置的 TaskScheduler。預設的 PollerMetadata(每秒輪詢無限數量的訊息)可以透過 spring.integration.poller.* 配置屬性進行自定義。
Spring Boot 還配置了一些功能,這些功能由其他 Spring Integration 模組的存在觸發。如果 spring-integration-jmx 也存在於類路徑中,訊息處理統計資訊將透過 JMX 釋出。如果 spring-integration-jdbc 可用,預設的資料庫模式可以在啟動時建立,如以下行所示
-
屬性
-
YAML
spring.integration.jdbc.initialize-schema=always
spring:
integration:
jdbc:
initialize-schema: "always"
如果 spring-integration-rsocket 可用,開發者可以使用 spring.rsocket.server.* 屬性配置 RSocket 伺服器,並讓它使用 IntegrationRSocketEndpoint 或 RSocketOutboundGateway 元件來處理傳入的 RSocket 訊息。此基礎設施可以處理 Spring Integration RSocket 通道介面卡和 @MessageMapping 處理程式(如果配置了 spring.integration.rsocket.server.message-mapping-enabled)。
Spring Boot 還可以使用配置屬性自動配置 ClientRSocketConnector
-
屬性
-
YAML
spring.integration.rsocket.client.host=example.org
spring.integration.rsocket.client.port=9898
# Connecting to a RSocket server over TCP
spring:
integration:
rsocket:
client:
host: "example.org"
port: 9898
-
屬性
-
YAML
spring.integration.rsocket.client.uri=ws://example.org
# Connecting to a RSocket Server over WebSocket
spring:
integration:
rsocket:
client:
uri: "ws://example.org"
有關更多詳細資訊,請參閱 IntegrationAutoConfiguration 和 IntegrationProperties 類。