|
此版本仍在开发中，尚不被认为是稳定的。对于最新的稳定版本，请使用 Spring Integration 6.5.1！ |
FTP 出站网关
FTP 出站网关提供一组有限的命令来与远程 FTP 或 FTPS 服务器交互。 支持的命令包括：
-
ls（列出文件） -
nlst（列出文件名） -
get（检索文件） -
mget（检索文件） -
rm（删除文件） -
mv（移动/重命名文件） -
put（发送文件） -
mput（发送多个文件）
使用ls命令
ls列出远程文件并支持以下选项：
-
-1：检索文件名列表。 默认值是检索FileInfo对象。 -
-a：包括所有文件（包括以“.”开头的文件） -
-f：不对列表进行排序 -
-dirs：包括目录（默认情况下排除目录） -
-links：包括符号链接（默认情况下排除符号链接） -
-R：递归列出远程目录
此外，还提供了文件名过滤，其方式与inbound-channel-adapter.
请参阅 FTP 入站通道适配器。
由ls作是文件名列表或FileInfo对象。
这些对象提供修改时间、权限和其他详细信息等信息。
远程目录ls命令在file_remoteDirectory页眉。
使用递归选项 （-R）、fileName包括任何子目录元素，表示文件的相对路径（相对于远程目录）。
如果-dirs选项，则每个递归目录也作为列表中的元素返回。
在这种情况下，建议您不要使用-1选项，因为您将无法区分文件和目录，您可以使用FileInfo对象。
从 4.3 版开始，FtpSession支持null对于list()和listNames()方法。
因此，您可以省略expression属性。
为方便起见，Java 配置有两个构造函数，它们没有expression论点。
或LS,NLST,PUT和MPUT命令null根据 FTP 协议，被视为客户端工作目录。
所有其他命令必须与expression根据请求消息评估远程路径。
您可以使用FTPClient.changeWorkingDirectory()函数扩展DefaultFtpSessionFactory并实现postProcessClientAfterConnect()回调。
使用nlst命令
版本 5 引入了对nlst命令。
nlst列出远程文件名，仅支持一个选项：
-
-f：不对列表进行排序
由nlst作是文件名的列表。
远程目录nlst命令在file_remoteDirectory页眉。
与-1选项的ls命令，它使用LIST命令，则nlst命令发送一个NLST命令发送到目标 FTP 服务器。
当服务器不支持LIST（例如，由于安全限制）。
结果nlst作是名称，没有其他细节。
因此，框架无法确定实体是否是目录，例如执行过滤或递归列表。
使用get命令
get检索远程文件。
它支持以下选项：
-
-P：保留远程文件的时间戳。 -
-stream：将远程文件检索为流。 -
-D：传输成功后删除远程文件。 如果忽略传输，则不会删除远程文件，因为FileExistsMode是IGNORE并且本地文件已经存在。
这file_remoteDirectory标头提供远程目录名称，而file_remoteFileheader 提供文件名。
由get作是一个File表示检索到的文件的对象或InputStream当您使用-stream选择。
这-stream选项允许将文件检索为流。
对于文本文件，一个常见的用例是将此作与文件拆分器或流转换器相结合。
当将远程文件作为流使用时，您负责关闭Session在流被消耗后。
为方便起见，该Session在closeableResource标头，您可以使用方便的方法访问它IntegrationMessageHeaderAccessor以下示例显示如何使用方便方法：
Closeable closeable = new IntegrationMessageHeaderAccessor(message).getCloseableResource();
if (closeable != null) {
closeable.close();
}以下示例演示如何将文件作为流使用：
<int-ftp:outbound-gateway session-factory="ftpSessionFactory"
request-channel="inboundGetStream"
command="get"
command-options="-stream"
expression="payload"
remote-directory="ftpTarget"
reply-channel="stream" />
<int-file:splitter input-channel="stream" output-channel="lines" />如果您在自定义组件中使用输入流，则必须关闭Session. 您可以在自定义代码中执行此作，也可以通过将消息副本路由到service-activator并使用 SpEL，如以下示例所示： |
<int:service-activator input-channel="closeSession"
expression="headers['closeableResource'].close()" />使用mget命令
mget根据模式检索多个远程文件，并支持以下选项：
-
-P：保留远程文件的时间戳。 -
-R：递归检索整个目录树。 -
-x：如果没有与模式匹配的文件，则抛出异常（否则返回空列表）。 -
-D：传输成功后删除每个远程文件。如果忽略传输，则不会删除远程文件，因为FileExistsMode是IGNORE并且本地文件已经存在。
由mget作是一个List<File>对象（即List之File对象，每个对象代表一个检索到的文件）。
从 5.0 版开始，如果FileExistsMode是IGNORE，则输出消息的有效负载不再包含由于文件已存在而未获取的文件。
以前，该列表包含所有文件，包括那些已经存在的文件。 |
用于确定远程路径的表达式应产生以- 例如somedir/将获取somedir.
从 5.0 版本开始，递归mget，结合新的FileExistsMode.REPLACE_IF_MODIFIEDmode，可用于在本地定期同步整个远程目录树。
此模式将本地文件的上次修改时间戳替换为远程时间戳，无论-P（保留时间戳）选项。
|
使用递归 （
-R)该模式将被忽略，并被假定。
默认情况下，检索整个远程树。
但是，可以通过提供 如果过滤了子目录，则不会对该子目录执行其他遍历。 这 通常，您可以使用 |
持久文件列表过滤器现在具有布尔属性forRecursion.
将此属性设置为true，也设置alwaysAcceptDirectories，这意味着出站网关上的递归作 （ls和mget） 现在每次都会遍历完整的目录树。
这是为了解决未检测到目录树深处更改的问题。
另外forRecursion=true导致文件的完整路径用作元数据存储键;这解决了如果具有相同名称的文件多次出现在不同目录中，则过滤器无法正常工作的问题。
重要提示：这意味着对于顶级目录下的文件，将找不到持久元数据存储中的现有密钥。
因此，该属性是false默认情况下;这可能会在将来的版本中更改。
从 5.0 版开始，FtpSimplePatternFileListFilter和FtpRegexPatternFileListFilter可以通过将alwaysAcceptDirectories属性设置为true. 这样做允许简单模式的递归，如以下示例所示：
<bean id="starDotTxtFilter"
class="org.springframework.integration.ftp.filters.FtpSimplePatternFileListFilter">
<constructor-arg value="*.txt" />
<property name="alwaysAcceptDirectories" value="true" />
</bean>
<bean id="dotStarDotTxtFilter"
class="org.springframework.integration.ftp.filters.FtpRegexPatternFileListFilter">
<constructor-arg value="^.*\.txt$" />
<property name="alwaysAcceptDirectories" value="true" />
</bean>定义了前面示例中的过滤器后，可以通过将filter网关上的属性。
也可以看看出站网关部分成功 （mget和mput).
使用put命令
这put命令将文件发送到远程服务器。消息的有效负载可以是java.io.File一个byte[]或String. 一个remote-filename-generator（或表达式）用于命名远程文件。其他可用属性包括remote-directory,temporary-remote-directory，以及他们的*-expression等价物：use-temporary-file-name和auto-create-directory. 有关更多信息，请参阅架构文档。
由put作是一个String表示传输后服务器上文件的完整路径。
5.2 版引入了chmod属性，该属性在上传后更改远程文件权限。
您可以使用传统的 Unix 八进制格式（例如600仅允许文件所有者读写）。
使用 java 配置适配器时，您可以使用setChmod(0600).
仅当您的 FTP 服务器支持SITE CHMOD子命令。
使用mput命令
这mput将多个文件发送到服务器，并且仅支持一个选项：
-
-R：递归的。 发送目录及其子目录中的所有文件（可能已过滤）。
消息有效负载必须是java.io.File（或String） 表示本地目录。
从 5.1 版本开始，集合File或String也受支持。
此命令支持与put命令.
此外，可以使用以下选项之一过滤本地目录中的文件mput-pattern,mput-regex,mput-filter或mput-filter-expression.
过滤器与递归一起工作，只要子目录本身通过过滤器即可。
未通过过滤器的子目录不会递归。
由mput作是一个List<String>对象（即List传输产生的远程文件路径）。
也可以看看出站网关部分成功 （mget和mput).
5.2 版引入了chmod属性，允许您在上传后更改远程文件权限。
您可以使用传统的 Unix 八进制格式（例如600仅允许文件所有者读写）。
使用 Java 配置适配器时，您可以使用setChmodOctal("600")或setChmod(0600).
仅当您的 FTP 服务器支持SITE CHMOD子命令。
使用rm命令
这rm命令删除文件。
这rm命令没有选项。
由rm作是Boolean.TRUE如果删除成功或Boolean.FALSE否则。
这file_remoteDirectoryheader 提供远程目录，而file_remoteFileheader 提供文件名。
使用mv命令
这mv命令移动文件。
这mv命令没有选项。
这expression属性定义“from”路径，而rename-expression属性定义“to”路径。
默认情况下，rename-expression是headers['file_renameTo'].
此表达式的计算结果不得为 null 或空String.
如有必要，将创建任何必要的远程目录。
结果消息的有效负载为Boolean.TRUE.
这file_remoteDirectoryheader 提供原始远程目录，并且file_remoteFileheader 提供文件名。
新路径位于file_renameTo页眉。
从 5.5.6 版本开始，remoteDirectoryExpression可用于mv为了方便起见，命令。
如果“from”文件不是完整的文件路径，则remoteDirectoryExpression用作远程目录。
这同样适用于“to”文件，例如，如果任务只是重命名某个目录中的远程文件。
有关 FTP 出站网关命令的其他信息
这get和mget命令支持local-filename-generator-expression属性。
它定义了一个 SpEL 表达式，用于在传输期间生成本地文件的名称。
评估上下文的根对象是请求消息。
这remoteFileName变量，这对于mget，也可以使用 - 例如local-filename-generator-expression="#remoteFileName.toUpperCase() + headers.something".
这get和mget命令支持local-directory-expression属性。
它定义了一个 SpEL 表达式，用于在传输期间生成本地目录的名称。
评估上下文的根对象是请求消息 but。
这remoteDirectory变量，这对于mget，也可用 — 例如：local-directory-expression="'/tmp/local/' + #remoteDirectory.toUpperCase() + headers.something".
此属性与local-directory属性。
对于所有命令，网关的“expression”属性提供命令作用的路径。
对于mget命令，则表达式的计算结果可能为 ''，表示检索所有文件，或 'somedirectory/'，依此类推。
以下示例显示了为ls命令：
<int-ftp:outbound-gateway id="gateway1"
session-factory="ftpSessionFactory"
request-channel="inbound1"
command="ls"
command-options="-1"
expression="payload"
reply-channel="toSplitter"/>发送到toSplitterchannel 是String每个对象都包含文件名。
如果command-options属性被省略，它FileInfo对象。 它使用空格分隔的选项，例如command-options="-1 -dirs -links".
从 4.2 版开始，GET,MGET,PUT和MPUT命令支持FileExistsMode属性 （mode使用命名空间支持时）。这会影响本地文件存在时的行为（GET和MGET） 或远程文件存在 （PUT和MPUT). 支持的模式包括REPLACE,APPEND,FAIL和IGNORE. 为了向后兼容，默认模式PUT和MPUT作是REPLACE. 为GET和MGET作，默认值为FAIL.
从 5.0 版开始，setWorkingDirExpression() (working-dir-expression在 XML 中）选项在FtpOutboundGateway (<int-ftp:outbound-gateway>在 XML 中）。它允许您在运行时更改客户端工作目录。根据请求消息评估表达式。每次网关作后都会恢复以前的工作目录。
使用 Java 配置进行配置
以下 Spring Boot 应用程序显示了如何使用 Java 配置配置出站网关的示例：
@SpringBootApplication
public class FtpJavaApplication {
public static void main(String[] args) {
new SpringApplicationBuilder(FtpJavaApplication.class)
.web(false)
.run(args);
}
@Bean
public SessionFactory<FTPFile> ftpSessionFactory() {
DefaultFtpSessionFactory sf = new DefaultFtpSessionFactory();
sf.setHost("localhost");
sf.setPort(port);
sf.setUsername("foo");
sf.setPassword("foo");
sf.setTestSession(true);
return new CachingSessionFactory<FTPFile>(sf);
}
@Bean
@ServiceActivator(inputChannel = "ftpChannel")
public MessageHandler handler() {
FtpOutboundGateway ftpOutboundGateway =
new FtpOutboundGateway(ftpSessionFactory(), "ls", "'my_remote_dir/'");
ftpOutboundGateway.setOutputChannelName("lsReplyChannel");
return ftpOutboundGateway;
}
}使用 Java DSL 进行配置
以下 Spring Boot 应用程序显示了如何使用 Java DSL 配置出站网关的示例：
@SpringBootApplication
public class FtpJavaApplication {
public static void main(String[] args) {
new SpringApplicationBuilder(FtpJavaApplication.class)
.web(false)
.run(args);
}
@Bean
public SessionFactory<FTPFile> ftpSessionFactory() {
DefaultFtpSessionFactory sf = new DefaultFtpSessionFactory();
sf.setHost("localhost");
sf.setPort(port);
sf.setUsername("foo");
sf.setPassword("foo");
sf.setTestSession(true);
return new CachingSessionFactory<FTPFile>(sf);
}
@Bean
public FtpOutboundGatewaySpec ftpOutboundGateway() {
return Ftp.outboundGateway(ftpSessionFactory(),
AbstractRemoteFileOutboundGateway.Command.MGET, "payload")
.options(AbstractRemoteFileOutboundGateway.Option.RECURSIVE)
.regexFileNameFilter("(subFtpSource|.*1.txt)")
.localDirectoryExpression("'localDirectory/' + #remoteDirectory")
.localFilenameExpression("#remoteFileName.replaceFirst('ftpSource', 'localTarget')");
}
@Bean
public IntegrationFlow ftpMGetFlow(AbstractRemoteFileOutboundGateway<FTPFile> ftpOutboundGateway) {
return f -> f
.handle(ftpOutboundGateway)
.channel(c -> c.queue("remoteFileOutputChannel"));
}
}出站网关部分成功 （mget和mput)
对多个文件执行作时（使用mget和mput），在传输一个或多个文件后一段时间可能会发生异常。在这种情况下（从版本 4.2 开始），一个PartialSuccessException被扔了。以及通常的MessagingException属性 （failedMessage和cause），则此异常具有两个附加属性：
-
partialResults：成功传输结果。 -
derivedInput：从请求消息生成的文件列表（例如，要为mput).
这些属性允许您确定哪些文件已成功传输，哪些文件未成功传输。
在递归的情况下mput这PartialSuccessException可能已经嵌套PartialSuccessException事件。
请考虑以下目录结构：
root/
|- file1.txt
|- subdir/
| - file2.txt
| - file3.txt
|- zoo.txt如果异常发生在file3.txt这PartialSuccessException由网关抛出derivedInput之file1.txt,subdir和zoo.txt和partialResults之file1.txt.
其cause是另一个PartialSuccessException跟derivedInput之file2.txt和file3.txt和partialResults之file2.txt.