如何在Apache Camel 2.20.2中配置带公钥认证的SCP路由？

我之前在Camel的ETL流程里也折腾过SCP的配置，刚好能给你一些实用的实操建议。针对你的需求——只通过私钥存储位置和已知主机文件完成配置，下面是具体的实现步骤和示例：

1. 确保依赖正确 #

Camel的SCP组件底层依赖JSch库，如果你用Maven管理项目，需要在pom.xml中添加对应2.20.2版本的依赖：

<dependency>
    <groupId>org.apache.camel</groupId>
    <artifactId>camel-scp</artifactId>
    <version>2.20.2</version>
</dependency>

2. 两种配置方式 #

方式一：直接在Endpoint中指定参数 #

这是最简单的方式，直接在SCP的URI里带上私钥和已知主机文件的路径，不需要额外的工厂配置。示例Java DSL路由如下：

from("file:/path/to/processed/files?delete=true") // 读取处理后的文件，处理完成后删除源文件
    .to("scp://remote_user@remote_host:/target/directory"
        + "?privateKeyFile=/home/camel_user/.ssh/id_rsa"
        + "&knownHostsFile=/home/camel_user/.ssh/known_hosts");

参数说明：

• privateKeyFile：指定你的私钥文件绝对路径
• knownHostsFile：指定OpenSSH格式的known_hosts文件路径，用于验证远程主机身份，避免中间人攻击

方式二：使用JSchSessionFactory（更灵活） #

如果需要复用SCP配置，或者有更多定制化需求，可以创建JSchSessionFactory实例并绑定到Camel的注册表中，然后在Endpoint中引用它。

Java DSL示例：

// 创建并配置JSchSessionFactory
JschSessionFactory sessionFactory = new JschSessionFactory();
sessionFactory.setPrivateKeyFile("/home/camel_user/.ssh/id_rsa");
sessionFactory.setKnownHostsFile("/home/camel_user/.ssh/known_hosts");

// 将工厂注册到Camel的注册表中
getContext().getRegistry().bind("scpSessionFactory", sessionFactory);

// 定义路由
from("file:/path/to/processed/files?delete=true")
    .to("scp://remote_user@remote_host:/target/directory?sessionFactory=#scpSessionFactory");

Spring XML配置示例：

<bean id="scpSessionFactory" class="org.apache.camel.component.scp.JschSessionFactory">
    <property name="privateKeyFile" value="/home/camel_user/.ssh/id_rsa"/>
    <property name="knownHostsFile" value="/home/camel_user/.ssh/known_hosts"/>
</bean>

<camelContext xmlns="http://camel.apache.org/schema/spring">
    <route>
        <from uri="file:/path/to/processed/files?delete=true"/>
        <to uri="scp://remote_user@remote_host:/target/directory?sessionFactory=#scpSessionFactory"/>
    </route>
</camelContext>

3. 关键注意事项 #

• 私钥文件权限：一定要确保Camel运行用户对私钥文件有读取权限，且私钥文件的权限必须设置为600（仅所有者可读可写），否则JSch会拒绝使用该私钥。
• known_hosts格式：文件必须是OpenSSH生成的标准格式，如果没有这个文件，你可以手动用ssh命令连接一次远程主机，系统会自动生成该文件。
• 加密私钥处理：如果你的私钥设置了密码（passphrase），可以在Endpoint参数中添加privateKeyPassphrase=your_passphrase，或者调用sessionFactory.setPrivateKeyPassphrase("your_passphrase")来配置。

按照上面的步骤配置后，你的Camel路由就能自动使用指定的私钥和已知主机文件完成SCP文件传输，完全不需要手动输入密码。

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