Camel端点URI是否需URL编码？并行处理pollEnrich异常排查

首先得说，你碰到的这个情况确实和线程安全直接相关，而且问题根源出在手动URL编码的时机上，和Camel 2.21.5的并行处理机制结合后就触发了这个bug。

咱们先拆解下你的路由代码：

from("direct:start") 
  .split(getFilesToProcess()).parallelProcessing().threads(3, 3) 
  .pollEnrich("file:///data/inbox?fileName="+encode("${body.fileName}")+"&move="+encode("../.done/${in.header.CamelFileName.substring(0,6)}/${date:now:yyyyMM}/${file:onlyname}")) 
  .to("direct:processFile");

为什么会出现文件混淆？ #

Camel里的${body.fileName}这类表达式，是在路由真正执行、每个线程处理自己的消息时才会动态解析的。但你这里的操作是提前把"${body.fileName}"这个字符串字面量拿去做了URL编码——注意，这时候编码的根本不是实际的文件名，而是表达式本身！

在并行处理的场景下，这个编码后的URI模板会被多个线程共享缓存。当多个线程同时触发表达式解析时，就会出现上下文污染：线程A的${body.fileName}还没解析完，线程B就覆盖了上下文里的变量，最终导致读取到错误的文件名，出现混淆、重复读取的情况。

而当你移除手动编码后，Camel会自动处理URI参数的编码逻辑，而且是每个线程在解析完自己的表达式值之后再编码，完全是线程隔离的，自然就不会有问题了。

怎么解决？ #

方案一：用Camel原生的自动编码（推荐） #

直接去掉所有手动的encode()调用，Camel的File组件会自动负责参数的编码，这是官方设计的标准用法，既能保证正确性，也能避免线程安全问题。修改后的路由：

from("direct:start") 
  .split(getFilesToProcess()).parallelProcessing().threads(3, 3) 
  .pollEnrich("file:///data/inbox?fileName=${body.fileName}&move=../.done/${in.header.CamelFileName.substring(0,6)}/${date:now:yyyyMM}/${file:onlyname}") 
  .to("direct:processFile");

方案二：如果必须手动编码（不推荐） #

用Camel Simple表达式内置的.urlEncode函数，让编码操作在每个线程的上下文里执行，确保线程安全：

from("direct:start") 
  .split(getFilesToProcess()).parallelProcessing().threads(3, 3) 
  .pollEnrich().simple("file:///data/inbox?fileName=${body.fileName.urlEncode}&move=../.done/${in.header.CamelFileName.substring(0,6)}/${date:now:yyyyMM}/${file:onlyname.urlEncode}")
  .to("direct:processFile");

这个函数会在解析出实际的文件名/路径后再做编码，完全是针对当前线程的消息上下文操作，不会互相干扰。

额外建议 #

Camel 2.21.5是2018年的老版本了，虽然这个问题主要是编码时机错误导致的，但老版本可能存在一些并行场景下的上下文泄漏问题。如果项目允许，建议升级到较新的LTS版本（比如2.25.x或者更高），能获得更好的稳定性和线程安全保障。

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