Spring統合フィードインバウンドチャネルアダプタ重複エントリ

Question

私はSpring Integrationを使用して、インバウンドチャネルアダプタを使用してRSSフィードを消費し、フィードをデータベーステーブルに書き込みます。

プロセスの停止/開始時にエントリが重複しないように、PropertiesPersistingMetadataStoreを有効にしました。二次的な対策として、データベーステーブルでは、フィードID /フィードエントリのリンク列全体に固有の制約もあります。

これは問題なく動作しているようですが、同じRSSフィードアイテムを再度挿入しようとしているDB例外エラーが発生していることがあります（すべてではありません）。

これらの重複エラーはどのような条件で発生しますか？

Answer 1

PropertiesPersistingMetadataStoreは、通常のアプリケーションシャットダウン時（Beanがアプリケーションコンテキストによってdestroy()になったとき）にのみその状態を維持します。

しかし、それはをあなたのフローの中で持続した後に呼び出すことができるので、Flushableを実装します。

dbトランザクションがコミット後の式@metadataStore.flush()でコミットした後に、transaction synchronizationを使用してストアをフラッシュできます。

また、Redisなどのより堅牢な永続ストアを使用することもできます。これは、各更新時に持続します。