Apache Camel,FTP消费者：如何获取前一条路由的头参数？

Question

我有几条骆驼路由，在从DB读取数据时，我在Exchange对象中设置了一个头，其中一条路由的名称为FILE_NAME。作为下一步，这条路由将进一步转到我的FTP路由，文件应该在那里下载。问题是FTP路由没有接收到我正在使用的contentEnricher的前一条路由的头。这是官方行为：http://camel.apache.org/content-enricher.html。但是，可以动态构造FTPendpoint的“filename”参数以下载特定文件。

我的FTP路由看起来是这样的，现在有示意数据：

from("direct:myRoute")   
.pollEnrich("ftp://foo@localhost/public/reports?password=secret&binary=true&fileName=data.txt") 
.to("mock:result");

编辑1：

感谢我的文章，但我需要回到同一点，因为我可以从Java DSL访问头值，也可以从pollrelch（）中的简单表达式访问头值，但不能在to（）中访问头值。进程（Exchange Exchange）打印正确的头值，sftp使用者的PollRelch从sftp服务器获取文件，但${header.file_name_only}或${in.header.file_name_only}都不会在to（）中访问它。因此创建的文件将命名为“value of obnumber”_。您能看一下下面的代码片段中有什么不正确的地方吗？

from("direct:SFTP").routeId("SFTP")
        .log("### SFTP")
        .process(new Processor() {
                public void process(Exchange exchange) throws Exception {
                        LOGGER.info("### Process SFTP " +
                            "FILE_NAME_ONLY = " + exchange.getIn().getHeader("FILE_NAME_ONLY" ) +
                            " FILE_PATH = " + exchange.getIn().getHeader("FILE_PATH") +
                            " AGG = " + exchange.getIn().getHeader("AGG"));
                 }
        })
        .choice()
            .when(header("FILE_NAME_ONLY").isEqualTo(""))
                .log("### SFTP FILE_NAME_ONLY is null!")
                .endChoice()
            .otherwise()
                .log("### SFTP FILE_NAME_ONLY is NOT null!")
                .pollEnrich().simple("sftp:" + ftpUid + "@" + ftpHost + "/" + ftpBasePath + "/${header.FILE_PATH}?password=" + 
                                    ftpPwd + "&binary=true&fileName=${header.FILE_NAME_ONLY}")
                .to("file:extract?fileName=" + obNumber + "_${header.FILE_NAME_ONLY}")
        .end();

解决方案：

null

两个有用的例子：

• http://www.systemmobile.com/？p=427“[...]要确定路由中每个点之后的目的endpoint，我们需要使用动态路由器。[...]”
• http://camel.apache.org/dynamic-router.html

Answer 1

手册（http://camel.apache.org/content-enricher.html）说：

从Camel2.16开始，relch和pollrelch都支持动态endpoint，该endpoint使用表达式计算uri，从而允许使用来自当前交换的数据。

您只需使用Camel2.16或更新版本即可。

.to("file:?fileName=extract/" + obNumber + "_${header.FILE_NAME_ONLY}")

.recipientList(simple("file:?fileName=extract/" + obNumber + "_${header.FILE_NAME_ONLY}"))

或者试试这个：

.setHeader("CamelFileName").simple("extract/"+obNumber+"_${header.FILE_NAME_ONLY}")
.to("file:")