6.1 和 6.2 之間的更改
新元件
Debezium 入站通道介面卡
基於 Debezium Engine 的變更資料捕獲 (CDC) 通道介面卡,允許捕獲資料庫變更事件,將其轉換為訊息並將其流式傳輸到出站通道。有關更多資訊,請參閱 Debezium 支援。
一般變更
-
<poller>的 XML 配置和@Poller註解現在支援 ISO 8601 持續時間格式,用於fixed-delay、fixed-rate和initial-delay選項。有關更多資訊,請參閱 輪詢消費者。 -
Java、Groovy 和 Kotlin DSL 現在在
IntegrationFlowDefinition中具有上下文特定的方法,帶有單個Consumer引數,用於透過一個構建器和可讀選項配置端點及其處理器。例如,請參閱 Java DSL 章 中的transformWith()、splitWith()。 -
已引入一個新的全域性屬性
spring.integration.endpoints.defaultTimeout,用於覆蓋應用程式中所有端點的預設 30 秒超時。有關更多資訊,請參閱 全域性屬性。 -
Java DSL 提供的
@MessagingGateway和GatewayEndpointSpec現在公開了MessagingGatewaySupport的內部MethodInvocationGateway擴充套件的errorOnTimeout屬性。有關更多資訊,請參閱 沒有響應到達時的閘道器行為。 -
LockRegistry提供了模板式 API,用於在鎖定狀態下執行提供的任務。有關更多資訊,請參閱 分散式鎖。 -
輪詢端點的預設觸發器現在是具有 1 秒固定延遲週期的
PeriodicTrigger例項;以前,預設值為 10 毫秒。有關更多資訊,請參閱 輪詢消費者。
WebSockets 變更
-
對於伺服器和客戶端 WebSocket 容器,傳送緩衝區溢位策略現在可以在
IntegrationWebSocketContainer中配置,並透過 XML 中的send-buffer-overflow-strategy進行配置。此策略決定了當會話的出站訊息緩衝區達到配置限制時的行為。有關更多資訊,請參閱 WebSockets 支援。
Apache Kafka 支援變更
KafkaMessageSource 現在從消費者屬性中提取 ErrorHandlingDeserializer 配置,並重新丟擲從失敗記錄頭中提取的 DeserializationException。有關更多資訊,請參閱 Kafka 入站通道介面卡。
JDBC 支援變更
JdbcMessageStore、JdbcChannelMessageStore、JdbcMetadataStore 和 DefaultLockRepository 實現了 SmartLifecycle,並在 start() 方法中對其各自的表執行 SELECT COUNT 查詢,以確保所需表(根據提供的 L ] ] 字首)存在於目標資料庫中。PostgresChannelMessageStoreQueryProvider 現在為輪詢查詢提供了單個 DELETE...RETURNING 語句。為此,ChannelMessageStoreQueryProvider 公開了一個 isSingleStatementForPoll 選項,該選項由 JdbcChannelMessageStore 查詢。有關更多資訊,請參閱 JDBC 訊息儲存。
MongoDB 支援變更
在 AbstractConfigurableMongoDbMessageStore 中引入了一個新選項 setCreateIndexes(boolean),用於停用自動索引建立。有關示例,請參閱 MongoDB 訊息儲存。
遠端檔案支援變更
引入了 FtpLastModifiedFileListFilter、SftpLastModifiedFileListFilter 和 SmbLastModifiedFileListFilter,以允許分別根據 FTP、SFTP 和 SMB 的最後修改策略進行檔案過濾。有關更多資訊,請參閱 FTP 入站通道介面卡、SFTP 入站通道介面卡 和 SMB 入站通道介面卡。
SFTP 支援變更
引入了新的 DefaultSftpSessionFactory.createSftpClient(…) 方法,以支援在被覆蓋時使用自定義 SftpClient。有關更多資訊,請參閱 SFTP 會話工廠。
安全支援變更
spring-integration-security 模組中的最後一個類 SecurityContextPropagationChannelInterceptor 已被棄用,取而代之的是已移至 spring-security-messaging 模組的類似類。有關更多資訊,請參閱 Spring Integration 中的安全性。