为幂等的file2组件跳过重复

Question

我在集群环境中使用camel，并希望在我的文件使用者endpoint上使用readlock，这样只有一个服务器尝试处理每个文件。唯一的集群安全readlock是幂等readlock，但是这需要在文件URI上设置一个idempotentRepository。

我在路由中使用一个幂等使用者，它将任何重复的文件移动到错误文件夹，并将错误记录到特定的文件中。这使用指定的JDBCMessageIdRepository来存储幂等键。

是否有一种html" target="_blank">方法可以将幂等消费者的重复处理逻辑与幂等readlock一起使用？或者如何将文件组件中的idempotentRepository设置为不跳过重复项，以便由路由中的幂等使用者拾取它们？

Answer 1

如果您使用相同的幂等存储库密钥进行锁定和消费，那么您将无法尝试处理同一个文件两次--幂等使用者的检查将发生在read Lock的检查之后，因此您的文件将在使用者检查它是否存在之前被跳过。另外，我认为您可能会遇到使用者和读锁本身的问题，因为使用者可能会报告您的文件已存在，因为读锁将在使用者进行检查之前在数据库中插入该行。

我能想到的最快的解决方案是为幂等使用者和读锁使用不同的键-这样它们之间就不会有任何冲突-并且通过将ReadLockRemoveonCommit设置为true使读锁在提交时移除键。这样，读锁将不允许并发处理文件，而是使用幂等使用者的密钥来检查文件以前是否被处理过。