SFTP 会话工厂
从版本 3.0 开始,默认情况下不再缓存会话。 请参阅 SFTP 会话缓存。 |
在配置 SFTP 适配器之前,必须配置 SFTP 会话工厂。 您可以使用常规 bean 定义配置 SFTP 会话工厂,如下例所示:
<beans:bean id="sftpSessionFactory"
class="org.springframework.integration.sftp.session.DefaultSftpSessionFactory">
<beans:property name="host" value="localhost"/>
<beans:property name="privateKey" value="classpath:META-INF/keys/sftpTest"/>
<beans:property name="privateKeyPassphrase" value="springIntegration"/>
<beans:property name="port" value="22"/>
<beans:property name="user" value="kermit"/>
</beans:bean>
每次适配器从其SessionFactory
,则会创建一个新的 SFTP 会话。
实际上,SFTP Session Factory 依赖于 Apache MINA SSHD 库来提供 SFTP 功能。
但是, Spring 集成还支持 SFTP 会话的缓存。 有关更多信息,请参阅 SFTP 会话缓存。
这DefaultSftpSessionFactory 可以使用外部配置或扩展的SshClient .
例如,org.eclipse.jgit.internal.transport.sshd.JGitSshClient 扩展名从org.eclipse.jgit:org.eclipse.jgit.ssh.apache 库可用于提供对 HTTP/SOCKS 代理的支持。 |
这 使用此功能时,必须将 session factory 包装在缓存 session factory 中,如下所述,以便在作完成时不会物理关闭连接。 如果重置缓存,则仅当最后一个通道关闭时,会话才会断开连接。 如果在新作获取会话时断开连接,则会刷新连接。 |
现在您需要做的就是将此 SFTP 会话工厂注入到您的适配器中。
为 SFTP 会话工厂提供值的更实用的方法是使用 Spring 的属性占位符支持。 |
从版本 6.1.3 开始,DefaultSftpSessionFactory
引入了createSftpClient(…)
支持自定义SftpClient
.
请参阅下面的示例,了解如何覆盖createSftpChannelSubsystem()
method 添加到您的自定义SftpClient
例如,添加一些自定义RequestHandler
对于 SFTP 子系统请求和回复:
@Override
protected ChannelSubsystem createSftpChannelSubsystem(ClientSession clientSession) {
ChannelSubsystem sftpChannelSubsystem = super.createSftpChannelSubsystem(clientSession);
sftpChannelSubsystem.addRequestHandler((channel, request, wantReply, buffer) -> ...);
return sftpChannelSubsystem;
}
配置属性
以下列表描述了DefaultSftpSessionFactory
.
isSharedSession
(constructor argument)::当true
、单个SftpClient
用于所有请求的SftpSession
实例。
它默认为false
.
sftpVersionSelector
::一SftpVersionSelector
instance 进行 SFTP 协议选择。
默认值为SftpVersionSelector.CURRENT
.
host
::要连接到的主机的 URL。
必填。
hostConfig
::一org.apache.sshd.client.config.hosts.HostConfigEntry
实例作为 user/host/port 选项的替代项。
可以使用代理跳转属性进行配置。
port
::应通过其建立 SFTP 连接的端口。
如果未指定,此值默认为22
.
如果指定,则此属性必须为正数。
user
::要使用的远程用户。
必填。
knownHostsResource
::一org.springframework.core.io.Resource
用于主机密钥存储库。
资源的内容必须与 OpenSSH 的格式相同known_hosts
文件,并且是必需的,如果allowUnknownKeys
为 false。
password
::用于对远程主机进行身份验证的密码。
如果未提供密码,则privateKey
property 是必需的。
privateKey
::一org.springframework.core.io.Resource
该 ID 表示用于对远程主机进行身份验证的私有密钥的位置。
如果privateKey
未提供,则password
property 是必需的。
privateKeyPassphrase
::私钥的密码。
如果您将userInfo
,privateKeyPassphrase
不允许。
密码是从该对象获取的。
自选。
timeout
::timeout 属性用作套接字超时参数,以及默认连接超时。
默认为30 seconds
.
设置为0
表示无超时;自null
- 无限等待。
allowUnknownKeys
::设置为true
以允许连接到具有未知(或更改)密钥的主机。
它的默认值是 'false'。
如果false
,则预填充的knownHosts
file 是必需的。
userInteraction
::A 定制org.apache.sshd.client.auth.keyboard.UserInteraction
在身份验证期间使用。
从版本 6.4 开始,DefaultSftpSessionFactory
公开一个Consumer<SshClient>
configurer 属性来进一步自定义内部SshClient
.
例如,以下是更改客户端的默认 NIO 工作线程数量和数据包大小的方法:
sftpSessionFactory.setSshClientConfigurer((sshClient) -> {
sshClient.setNioWorkers(27);
PropertyResolverUtils.updateProperty(sshClient, CoreModuleProperties.MAX_PACKET_SIZE.getName(), 48 * 1024);
});