Apache camel组播(ftps&file)生成空文件

Question

.to("ftps:....").to("file:...")

.to("ftps:...").to("file:..."))

camelContext.addRoutes(new RouteBuilder() {
 def void configure() {
  from("file:///home/xyz/?fileName=file.txt&charset=utf-8&noop=true")
   .multicast()
   .to("ftps://localhost:21/files?username=anonymous&password=anonymous&binary=true&fileName=file.txt&passiveMode=true&fileExist=Fail")
   .to("file://${directory}?fileName=\${file:name}-\${date:now:yyyyMMddHHmmssSSS}")
 }
})

我期望多播应该在没有数据丢失的情况下向两个endpoint写入相同的内容。

Answer 1

看为什么我的留言是空的？。文件使用者返回inputstream，它被第一个endpoint使用，因此对于第二个endpoint为空。您需要启用流缓存，或者在组播之前将body转换为一些可重用的对象（例如string)。

启用流缓存：

from("file:///home/xyz/?fileName=file.txt&charset=utf-8&noop=true")
    .streamCaching()
    .multicast()
    ...

转换正文：

from("file:///home/xyz/?fileName=file.txt&charset=utf-8&noop=true")
    .convertBodyTo(String.class)
    .multicast()
    ...