6.1 和 6.2 之間的更改

新元件

Debezium 入站通道介面卡

基於 Debezium Engine 的變更資料捕獲 (CDC) 通道介面卡,允許捕獲資料庫變更事件,將其轉換為訊息並將其流式傳輸到出站通道。有關更多資訊,請參閱 Debezium 支援

一般變更

  • <poller> 的 XML 配置和 @Poller 註解現在支援 ISO 8601 持續時間格式,用於 fixed-delayfixed-rateinitial-delay 選項。有關更多資訊,請參閱 輪詢消費者

  • Java、Groovy 和 Kotlin DSL 現在在 IntegrationFlowDefinition 中具有上下文特定的方法,帶有單個 Consumer 引數,用於透過一個構建器和可讀選項配置端點及其處理器。例如,請參閱 Java DSL 章 中的 transformWith()splitWith()

  • 已引入一個新的全域性屬性 spring.integration.endpoints.defaultTimeout,用於覆蓋應用程式中所有端點的預設 30 秒超時。有關更多資訊,請參閱 全域性屬性

  • Java DSL 提供的 @MessagingGatewayGatewayEndpointSpec 現在公開了 MessagingGatewaySupport 的內部 MethodInvocationGateway 擴充套件的 errorOnTimeout 屬性。有關更多資訊,請參閱 沒有響應到達時的閘道器行為

  • LockRegistry 提供了模板式 API,用於在鎖定狀態下執行提供的任務。有關更多資訊,請參閱 分散式鎖

  • 輪詢端點的預設觸發器現在是具有 1 秒固定延遲週期的 PeriodicTrigger 例項;以前,預設值為 10 毫秒。有關更多資訊,請參閱 輪詢消費者

WebSockets 變更

  • 對於伺服器和客戶端 WebSocket 容器,傳送緩衝區溢位策略現在可以在 IntegrationWebSocketContainer 中配置,並透過 XML 中的 send-buffer-overflow-strategy 進行配置。此策略決定了當會話的出站訊息緩衝區達到配置限制時的行為。有關更多資訊,請參閱 WebSockets 支援

Apache Kafka 支援變更

KafkaMessageSource 現在從消費者屬性中提取 ErrorHandlingDeserializer 配置,並重新丟擲從失敗記錄頭中提取的 DeserializationException。有關更多資訊,請參閱 Kafka 入站通道介面卡

JDBC 支援變更

JdbcMessageStoreJdbcChannelMessageStoreJdbcMetadataStoreDefaultLockRepository 實現了 SmartLifecycle,並在 start() 方法中對其各自的表執行 SELECT COUNT 查詢,以確保所需表(根據提供的 L ] ] 字首)存在於目標資料庫中。PostgresChannelMessageStoreQueryProvider 現在為輪詢查詢提供了單個 DELETE...RETURNING 語句。為此,ChannelMessageStoreQueryProvider 公開了一個 isSingleStatementForPoll 選項,該選項由 JdbcChannelMessageStore 查詢。有關更多資訊,請參閱 JDBC 訊息儲存

MongoDB 支援變更

AbstractConfigurableMongoDbMessageStore 中引入了一個新選項 setCreateIndexes(boolean),用於停用自動索引建立。有關示例,請參閱 MongoDB 訊息儲存

遠端檔案支援變更

引入了 FtpLastModifiedFileListFilterSftpLastModifiedFileListFilterSmbLastModifiedFileListFilter,以允許分別根據 FTPSFTPSMB 的最後修改策略進行檔案過濾。有關更多資訊,請參閱 FTP 入站通道介面卡SFTP 入站通道介面卡SMB 入站通道介面卡

SFTP 支援變更

引入了新的 DefaultSftpSessionFactory.createSftpClient(…​) 方法,以支援在被覆蓋時使用自定義 SftpClient。有關更多資訊,請參閱 SFTP 會話工廠

安全支援變更

spring-integration-security 模組中的最後一個類 SecurityContextPropagationChannelInterceptor 已被棄用,取而代之的是已移至 spring-security-messaging 模組的類似類。有關更多資訊,請參閱 Spring Integration 中的安全性

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