彈簧整合去抖/重複刪除

Question

Spring集成中是否有一些組件可用於過濾指定時間範圍內的重複項？

我在尋找類似Debounce from ReactiveX

在我的項目，我發送有效載荷包含一個UUID，我想篩選出具有相同UUID的多個有效載荷，如果在10秒內。例如通過隊列發送 - 然後我只想讓最後一個通過，只要在接下來的10秒內沒有其他有效載荷具有相同的UUID。

Answer 1

感謝@Apokralipsa我能夠通過將以下聚合做到這一點：

<int:aggregator 
      input-channel="enrichedChannel" 
      output-channel="aggregatedChannel" 
      group-timeout-expression="size() ge 1 ? 10000 : -1" 
      send-partial-result-on-expiry="true" 
      expire-groups-upon-timeout="true" 
      correlation-strategy-expression="payload.id" 
      release-strategy-expression="false" /> 

Answer 2

您可以使用aggregator用於此目的。什麼，你需要設置爲

• 認識到被複制
• 釋放戰略考慮單個消息的消息是一個完成的組
• expire-groups-upon-completion到false，相關策略，讓本集團將不能因爲它是完成就被刪除併發送出去
• group-timeout到，例如，10秒
• 保持expire-groups-upon-timeout如true（它是如此默認情況下）

從參考文檔：

（expire-groups-upon-completion）設置爲真（默認爲false），完​​成組從消息存儲除去，允許具有相同相關性的後續消息，以形成一個新的組。默認行爲是將與完成組具有相同關聯性的消息發送到丟棄通道。