入站通道适配器:控制远程文件获取

配置入站通道适配器时,应考虑两个属性。max-messages-per-poll,与其他轮询器一样,可用于限制每次轮询发出的消息数量(如果准备好的消息多于配置值)。max-fetch-size(自版本 5.0 起)可以限制一次从远程服务器检索的文件数量。

以下场景假定起始状态是本地目录为空

  • max-messages-per-poll=2max-fetch-size=1:适配器会获取一个文件,发出该文件,然后获取下一个文件,发出该文件,接着休眠直到下一次轮询。

  • max-messages-per-poll=2max-fetch-size=2:适配器会获取两个文件,然后逐个发出。

  • max-messages-per-poll=2max-fetch-size=4:适配器会获取最多四个文件(如果可用),并发出前两个(如果至少有两个)。接下来的两个文件将在下一次轮询时发出。

  • max-messages-per-poll=2max-fetch-size 未指定:适配器会获取所有远程文件,并发出前两个(如果至少有两个)。随后的文件将在后续的轮询中发出(每次两个)。当所有文件都被消费后,会再次尝试远程获取,以获取任何新文件。

当您部署应用程序的多个实例时,我们建议设置一个较小的 max-fetch-size,以避免一个实例“独占”所有文件,导致其他实例“饥饿”。

max-fetch-size 的另一个用途是,如果您想停止获取远程文件,但继续处理已获取的文件。在 MessageSource 上设置 maxFetchSize 属性(通过编程、JMX 或使用控制总线)可以有效地阻止适配器获取更多文件,但允许轮询器继续为之前已获取的文件发出消息。如果在属性更改时轮询器处于活动状态,则更改将在下一次轮询时生效。

从版本 5.1 开始,可以为同步器提供一个 Comparator<FTPFile>。这在限制使用 maxFetchSize 获取的文件数量时非常有用。

另请参阅通用FTP 入站通道适配器章节,了解有关 FileListFilter 配置的信息。