Apache Camel toD()端点动态文件移动失效问题求助

问题 #

开发基于Spring Boot的微服务，使用Apache Camel通过SFTP与外部系统集成，尝试在入站和出站方法中将文件移动至不同文件夹。相关代码如下：

String fiscalIncomingFolder = "C:/Jones/EIATesting/StorageEIA/incoming"
String fiscalProcessingFolder = "C:/Jones/EIATesting/StorageEIA/fiscal_processing"

from("direct:fiscalFolder")
      .toD("file://" + fiscalIncomingFolder + "/" +"${header.fileNameToFiscalIncoming}?move="+fiscalProcessingFolder + "/${header.fileId}.r"+"&readLock=rename")

Exchange中的Header信息：

header.fileNameToFiscalIncoming = 9f0fd432-ca8e-4f17-8ecc-e278c4c1399c.s
header.fileId = abcd1234

目标是将incoming文件夹中的<uuid.s>文件移动至processing文件夹并重命名为<fileId>.r。代码执行无异常，但文件未移动。日志显示的端点详情：

2024-06-21 20:47:18,496 DEBUG [Camel (camel-1) thread #1 - JmsConsumer[RECEIVED_FISCAL_FILE]] o.a.c.p.SendDynamicProcessor [SendDynamicProcessor.java:143] Optimising toD via SendDynamicAware component: file to use static uri: file://C:/Jones/EIATesting/StorageEIA/incoming/9f0fd432-ca8e-4f17-8ecc-e278c4c1399c.s?move=C:/Jones/EIATesting/StorageEIA/fiscal_processing/${header.fileId}.r&readLock=rename

怀疑是move参数中的文件路径编码问题导致故障，求解决方法。

解决方案 #

1. 修复move参数的表达式解析问题 #

从日志能看到${header.fileId}没被正确解析，还以占位符形式留在URI里，这是直接拼接字符串时Camel表达式没被识别导致的。可以用两种方式调整：

方式一：用Camel统一表达式语法构建URI

把文件夹路径也放到Exchange Header里，用toD的表达式语法完整拼接，确保变量被正确解析：

// 先把文件夹路径存入Header
from("direct:fiscalFolder")
    .setHeader("fiscalIncomingFolder", constant(fiscalIncomingFolder))
    .setHeader("fiscalProcessingFolder", constant(fiscalProcessingFolder))
    .toD("file://${header.fiscalIncomingFolder}/${header.fileNameToFiscalIncoming}?move=${header.fiscalProcessingFolder}/${header.fileId}.r&readLock=rename")

方式二：对move路径做URL编码

如果要保留字符串拼接的写法，得对move参数里的路径做URL编码，避免特殊字符干扰：

import java.net.URLEncoder;

String encodedMovePath = URLEncoder.encode(fiscalProcessingFolder + "/${header.fileId}.r", "UTF-8");
from("direct:fiscalFolder")
    .toD("file://" + fiscalIncomingFolder + "/" + "${header.fileNameToFiscalIncoming}?move=" + encodedMovePath + "&readLock=rename")

2. 改用标准的文件移动路由写法 #

当前用toD指向源文件的方式不符合Camel file组件的常规用法，to操作默认是覆盖文件而非移动。建议用from监听源文件，再通过move参数处理：

from("file://" + fiscalIncomingFolder + "?fileName=${header.fileNameToFiscalIncoming}&readLock=rename&move=" + fiscalProcessingFolder + "/${file:name.noext}.r")
    .to("direct:fiscalFolder")

这种写法里，from负责读取指定文件，move参数会自动把读取后的文件移到目标路径并重命名。

3. 检查权限与文件夹存在性 #

• 确认微服务进程对incoming和fiscal_processing文件夹有读写权限
• 确保fiscal_processing文件夹存在，可添加mkdir=true让Camel自动创建目标文件夹：

.toD("file://" + fiscalIncomingFolder + "/" + "${header.fileNameToFiscalIncoming}?move=" + encodedMovePath + "&readLock=rename&mkdir=true")

内容的提问来源于stack exchange，提问作者Jones