此版本仍在开发中,尚未被视为稳定版本。对于最新的稳定版本,请使用 Spring Integration 6.3.4! |
此版本仍在开发中,尚未被视为稳定版本。对于最新的稳定版本,请使用 Spring Integration 6.3.4! |
在配置入站通道适配器时,应考虑两个属性。与所有 Poller 一样,可用于限制每次轮询时发出的消息数(如果已准备好超过配置的值)。 (自版本 5.0 起)可以限制一次从远程服务器检索的文件数。max-messages-per-poll
max-fetch-size
以下场景假定起始状态为空的本地目录:
-
max-messages-per-poll=2
and:适配器获取一个文件,发出它,获取下一个文件,发出它,然后休眠直到下一次轮询。max-fetch-size=1
-
max-messages-per-poll=2
和 ):适配器获取这两个文件,然后发出每个文件。max-fetch-size=2
-
max-messages-per-poll=2
和:适配器最多获取四个文件(如果可用)并发出前两个文件(如果至少有两个)。 接下来的两个文件将在下一次轮询时发出。max-fetch-size=4
-
max-messages-per-poll=2
和 not specified:适配器获取所有远程文件并发出前两个(如果至少有两个)。 后续文件将在后续轮询时发出(一次两个)。 当所有文件都被消耗时,将再次尝试远程获取以获取任何新文件。max-fetch-size
当您部署应用程序的多个实例时,我们建议使用小型 ,以避免一个实例“抓取”所有文件并耗尽其他实例。max-fetch-size |
当您部署应用程序的多个实例时,我们建议使用小型 ,以避免一个实例“抓取”所有文件并耗尽其他实例。max-fetch-size |
另一个用途是,如果您想停止获取远程文件,但继续处理已获取的文件。
在(以编程方式、使用 JMX 或控制总线)上设置该属性可以有效地阻止适配器获取更多文件,但允许 Poller 继续为以前获取的文件发出消息。
如果在更改属性时 poller 处于活动状态,则更改将在下一次轮询时生效。max-fetch-size
maxFetchSize
MessageSource
从版本 5.1 开始,可以为同步器提供 .
这在限制使用 获取的文件数量时非常有用。Comparator<FTPFile>
maxFetchSize