Spring-Integration：使用公共root的多线程创建sftp目录失败

Question

我有多个线程通过Sftp.outboundAdapter上传sftp文件。每个线程都需要创建一个具有公共根目录的目录路径。我得到一个异常，告诉我共同的根存在：

org.springframework.messaging.MessageDeliveryException: Failed to transfer file
...
Caused by: org.springframework.core.NestedIOException: failed to create remote directory '/my/import/de3fb731-6a56-11e9-bfd2-0242ac140022'.; nested exception is 4: Eine Datei kann nicht erstellt werden, wenn sie bereits vorhanden ist. 
    at org.springframework.integration.sftp.session.SftpSession.mkdir(SftpSession.java:232)
    at org.springframework.integration.file.remote.RemoteFileUtils.makeDirectories(RemoteFileUtils.java:71)
    at org.springframework.integration.file.remote.RemoteFileTemplate.sendFileToRemoteDirectory(RemoteFileTemplate.java:545)
    at org.springframework.integration.file.remote.RemoteFileTemplate.doSend(RemoteFileTemplate.java:337)
    ... 150 common frames omitted
Caused by: com.jcraft.jsch.SftpException: Eine Datei kann nicht erstellt werden, wenn sie bereits vorhanden ist. 
    at com.jcraft.jsch.ChannelSftp.throwStatusError(ChannelSftp.java:2873)
    at com.jcraft.jsch.ChannelSftp.mkdir(ChannelSftp.java:2182)
    at org.springframework.integration.sftp.session.SftpSession.mkdir(SftpSession.java:229)
    ... 153 common frames omitted

我猜RemoteFileUtils#makeDirectories在确定pathsToCreate时存在竞争条件。两个线程都确定需要创建路径段，但是当两者都尝试创建它时，第二个线程失败。

一个可能的解决方法是提前创建公共路径，但这是笨拙的，因为在Sftp.outboundGateway中没有这样的命令，似乎我必须上传一个带有autoCreateDirectories的虚拟文件，然后删除虚拟文件。

有没有更好的方法来解决这个问题？将mkdirs命令添加到sftp出站网关是否有意义？当autoCreateDirectories为真时，是否应该有一个标志来忽略由于现有目录引起的错误？

Answer 1

一个可能的解决方法是提前创建公共路径，但这是笨拙的，因为Sftp.outboundGateway中没有这样的命令

您可以在初始化期间自己调用RemoteFileUtils.makeDirectories（通过SftpRemoteFileTemplate.execute(session -> ...)获取会话）。

但是，我同意该实用程序应该捕获并忽略该异常。请打开issue on GitHub。

欢迎捐款。