首页 > 解决方案 > 如何在 Apache Camel 中窃听时检查文件是否存在

问题描述

我有一个用 Apache Camel 编写的项目,其中我从一条路由获取消息并将其发送到另一条路由进行窃听:

from("URI").bean(random1)
.wireTap("direct:wiretap")
.recipientList.method(random2, "random2Method");

from("direct:wiretap").routeId("WireTap")
.setProperty("filename", dynamicValueExpression)
.to("file://log-directory-name?fileName=/${date:now:yyyMMdd}/property[filename]")

这段代码工作得很好,它成功地窃听了文件。

这里的问题是如果有另一个具有相同文件名的文件,则此代码会覆盖该文件。我想要实现的是检查文件是否已经存在,如果存在则重命名当前文件(不是现有文件),然后窃听它。

我检查了 Camel 文档,发现我认为我可能会使用类似 fileExist=Move 属性和自定义文件策略的东西(我可能在这里错了)。但我不确定它究竟是如何工作的。

所以我的问题是:

  1. 真的有可能实现我想要实现的目标吗?
  2. 如果是,那么有人可以告诉我怎么做吗?

标签: javafile-ioapache-camel

解决方案


可能有几种方法可以做到这一点。其中之一是使用处理器,该处理器使用您的动态属性计算文件名:

from("direct:wiretap")
    .routeId("WireTap")
    .process(e -> {
        String fileName = (String) e.getProperty("filename");
        if (new File(fileName).exists()) {
            //Compute alternative name
            e.getIn().setHeader("CamelFileName", 
                                fileName + UUID.randomUUID().toString());
        } else {
            e.getIn().setHeader("CamelFileName", fileName);
        }
    })
    .to("file://log-directory-name");

推荐阅读