java - Mule:如何跟踪不可删除和不可移动的文件

Question

我有一个目录，其中包含无法删除的文件，因为它们已被其他应用程序使用或具有只读属性。这意味着我不能像 Mule 作为自然文件跟踪系统那样移动或删除文件。为了在文件到达或更新时通过 Mule 处理这些文件而不从原始目录中删除/移动它们，我需要某种自定义跟踪。为此，我认为我需要添加一些规则并能够跟踪以下文件:

• 新文件
• 处理过的文件
• 更新文件

为此，我考虑在同一目录中创建一个日志文件，以按名称和修改日期跟踪每个文件，但我不确定这是否是正确的做法。我需要能够写入和读取此日志文件，并将其内容与目录中的当前文件进行比较，以确定哪些文件是新的或已更新的。这似乎有点太复杂了，需要我添加相当多的编程(可能是 groovy 脚本或覆盖某些方法)。

有没有其他更简单的方法可以在 Mule 上执行此操作？如果没有，我应该如何开始解决这个问题？我猜我可以编写一些 java 来与 File EndPoint 通信。

Answer 1

正如 Victor Romero 指出的那样，幂等过滤器可以解决问题。我尝试了两种类型的幂等过滤器，看看哪一种效果最好:Idempotent Message Filter和 Idempotent Secure Hash Message Filter .他们两个都完成了工作，但我最终使用幂等消息过滤器(无哈希)在简单文本文件存储中记录时间戳和文件名。

就在文件入站端点之后:

<idempotent-message-filter idExpression="#[message.inboundProperties.originalFilename+'-'+message.inboundProperties.timestamp]" storePrefix="prefix" doc:name="Idempotent Message">
    <simple-text-file-store name="uniqueProcessedMessages" directory="C:\yourDirectory"/>
</idempotent-message-filter>

只有出于我的流程目的的新文件或修改过的文件才会通过。然而，幂等安全哈希消息过滤器在识别不同文件方面应该做得更好。