Apache Camel：具有属性和属性占位符的RecipientList不起作用-Java 学习之路

我正在尝试使用Camel Java DSL将文件路由到SFTP服务器，如下所示：

.recipientList(simple("sftp://{{hostname}}:{{port}}/" + exchangeProperty(destinationDir) + "?username={{username}}&preferredAuthentications=publickey&privateKeyFile={{pkfilelocation}}&privateKeyPassphrase={{pkPassphrase}}"))

但是当消息到达此 endpoints 时，Camel会抛出以下异常：

org.apache.camel.component.file.GenericFileOperationFailedException: Cannot change directory to: exchangeProperty{destinationDir}
    at org.apache.camel.component.file.remote.SftpOperations.doChangeDirectory(SftpOperations.java:596)
    at org.apache.camel.component.file.remote.SftpOperations.changeCurrentDirectory(SftpOperations.java:584)
    at org.apache.camel.component.file.remote.SftpOperations.storeFile(SftpOperations.java:830)
    at org.apache.camel.component.file.GenericFileProducer.writeFile(GenericFileProducer.java:277)
    at org.apache.camel.component.file.GenericFileProducer.processExchange(GenericFileProducer.java:165)
    at org.apache.camel.component.file.remote.RemoteFileProducer.process(RemoteFileProducer.java:58)
    at org.apache.camel.util.AsyncProcessorConverterHelper$ProcessorToAsyncProcessorBridge.process(AsyncProcessorConverterHelper.java:61)
    at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:110)
    at org.apache.camel.builder.NoErrorHandlerBuilder$1.process(NoErrorHandlerBuilder.java:40)
    at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:198)
    at org.apache.camel.processor.MulticastProcessor.doProcessSequential(MulticastProcessor.java:695)
    at org.apache.camel.processor.MulticastProcessor.doProcessSequential(MulticastProcessor.java:623)
    at org.apache.camel.processor.MulticastProcessor.process(MulticastProcessor.java:247)
    at org.apache.camel.processor.RecipientList.sendToRecipientList(RecipientList.java:172)
    at org.apache.camel.processor.RecipientList.process(RecipientList.java:132)
    at org.apache.camel.processor.Pipeline.process(Pipeline.java:120)
    at org.apache.camel.processor.Pipeline.process(Pipeline.java:83)
    at org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:77)
    at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:110)
    at org.apache.camel.builder.NoErrorHandlerBuilder$1.process(NoErrorHandlerBuilder.java:40)
    at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:198)
    at org.apache.camel.processor.Pipeline.process(Pipeline.java:120)
    at org.apache.camel.processor.Pipeline.process(Pipeline.java:83)
    at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:198)
    at org.apache.camel.component.direct.DirectProducer.process(DirectProducer.java:62)
    at org.apache.camel.processor.SendProcessor.process(SendProcessor.java:145)
    at org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:77)
    at org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:541)
    at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:198)
    at org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:541)
    at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:198)
    at org.apache.camel.processor.MulticastProcessor.doProcessSequential(MulticastProcessor.java:695)
    at org.apache.camel.processor.MulticastProcessor.doProcessSequential(MulticastProcessor.java:623)
    at org.apache.camel.processor.MulticastProcessor.process(MulticastProcessor.java:247)
    at org.apache.camel.processor.Splitter.process(Splitter.java:114)
    at org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:77)
    at org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:541)
    at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:198)
    at org.apache.camel.processor.Pipeline.process(Pipeline.java:120)
    at org.apache.camel.processor.Pipeline.process(Pipeline.java:83)
    at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:198)
    at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:97)
    at org.apache.camel.component.jms.EndpointMessageListener.onMessage(EndpointMessageListener.java:112)
    at org.springframework.jms.listener.AbstractMessageListenerContainer.doInvokeListener(AbstractMessageListenerContainer.java:721)
    at org.springframework.jms.listener.AbstractMessageListenerContainer.invokeListener(AbstractMessageListenerContainer.java:681)
    at org.springframework.jms.listener.AbstractMessageListenerContainer.doExecuteListener(AbstractMessageListenerContainer.java:651)
    at org.springframework.jms.listener.AbstractPollingMessageListenerContainer.doReceiveAndExecute(AbstractPollingMessageListenerContainer.java:317)
    at org.springframework.jms.listener.AbstractPollingMessageListenerContainer.receiveAndExecute(AbstractPollingMessageListenerContainer.java:255)
    at org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.invokeListener(DefaultMessageListenerContainer.java:1166)
    at org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.executeOngoingLoop(DefaultMessageListenerContainer.java:1158)
    at org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.run(DefaultMessageListenerContainer.java:1055)
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
    at java.lang.Thread.run(Thread.java:748)
Caused by: 2: No such file
    at com.jcraft.jsch.ChannelSftp.throwStatusError(ChannelSftp.java:2873)
    at com.jcraft.jsch.ChannelSftp._realpath(ChannelSftp.java:2367)
    at com.jcraft.jsch.ChannelSftp.cd(ChannelSftp.java:342)
    at org.apache.camel.component.file.remote.SftpOperations.doChangeDirectory(SftpOperations.java:594)
    ... 53 more

我可以看到在stacktrace中打印的交换机上设置的destinationDir属性 is . 如果我更换

exchangeProperty（destinationDir）

在具有实际目标目录（tmp / destination / dir1 /）的路由中，它工作正常 . 问题是，我需要目标目录是动态的 . 我尝试在路线（> 2.16.0）和路线中的 ${property.destinationDir} 中使用 ${exchangeProperty.destinationDir} 而不是无济于事 . "non-exchange"属性占位符也可以解决 .

When debugging the Camel SFTP library, I can see that at SftpOperations.class:594, path is set to exchangeProperty. This is not getting replaced and this is why it's failing.

注意：我在{}后面有 / （而不在destinationDir属性中），否则，Camel SFTP组件会抛出一个异常，说明主机未定义 .

有没有人有任何建议如何让 property 占位符和交换属性与SFTP动态工作？我试过D（“..”）也没有运气 .

Camelv 2.19.0

1 回答

我尝试过很多变种.toD，.inOnly，.to，.recipientList等没有运气 . 对于那些遭受同样挫折的人，我确实为此找到了一个简单的解决方法：

.process(new Processor() {
    @Override
    public void process(Exchange exchange) throws Exception {
        exchange.setProperty("myHackProperty", String.format("sftp://{{hostname}}:{{port}}/%s)", exchange.getProperty("dest‌‌inationDir")) 
    }
}

.recipientList(exchangeProperty("myHackProperty"))

简单的手动动态字符串替换奇迹般有效 . 有时骆驼编码的最佳方法是避免骆驼:)

回复于 2024-04-24T01:39:01+08:00

Apache Camel：具有属性和属性占位符的RecipientList不起作用

1 回答

相关问题