我有一个目录,其中包含无法删除的文件,因为它们已被其他应用程序使用或具有只读属性。这意味着我不能像 Mule 作为自然文件跟踪系统那样移动或删除文件。为了在文件到达或更新时通过 Mule 处理这些文件而不从原始目录中删除/移动它们,我需要某种自定义跟踪。为此,我认为我需要添加一些规则并能够跟踪以下文件:
- 新文件
- 处理过的文件
- 更新文件
为此,我考虑在同一目录中创建一个日志文件,以按名称和修改日期跟踪每个文件,但我不确定这是否是正确的做法。我需要能够写入和读取此日志文件,并将其内容与目录中的当前文件进行比较,以确定哪些文件是新的或已更新的。这似乎有点太复杂了,需要我添加相当多的编程(可能是 groovy 脚本或覆盖某些方法)。
有没有其他更简单的方法可以在 Mule 上执行此操作?如果没有,我应该如何开始解决这个问题?我猜我可以编写一些 java 来与 File EndPoint 通信。
最佳答案
正如 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>
只有出于我的流程目的的新文件或修改过的文件才会通过。然而,幂等安全哈希消息过滤器在识别不同文件方面应该做得更好。
关于java - Mule:如何跟踪不可删除和不可移动的文件,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/24311394/