入站通道介面卡：輪詢多個伺服器和目錄

從版本 5.0.7 開始，可以使用 RotatingServerAdvice；當將其配置為輪詢器通知時，入站介面卡可以輪詢多個伺服器和目錄。正常配置通知並將其新增到輪詢器的通知鏈中。DelegatingSessionFactory 用於選擇伺服器，有關更多資訊，請參閱委派會話工廠。通知配置包含一個 RotationPolicy.KeyDirectory 物件列表。

示例

@Bean
public RotatingServerAdvice advice() {
    List<RotationPolicy.KeyDirectory> keyDirectories = new ArrayList<>();
    keyDirectories.add(new RotationPolicy.KeyDirectory("one", "foo"));
    keyDirectories.add(new RotationPolicy.KeyDirectory("one", "bar"));
    keyDirectories.add(new RotationPolicy.KeyDirectory("two", "baz"));
    keyDirectories.add(new RotationPolicy.KeyDirectory("two", "qux"));
    keyDirectories.add(new RotationPolicy.KeyDirectory("three", "fiz"));
    keyDirectories.add(new RotationPolicy.KeyDirectory("three", "buz"));
    return new RotatingServerAdvice(delegatingSf(), keyDirectories);
}

此通知將輪詢伺服器 one 上的目錄 foo，直到沒有新檔案存在，然後移動到伺服器 two 上的目錄 bar，然後是目錄 baz 等。

此預設行為可以透過 fair 建構函式引數進行修改

fair

@Bean
public RotatingServerAdvice advice() {
    ...
    return new RotatingServerAdvice(delegatingSf(), keyDirectories, true);
}

在這種情況下，無論上次輪詢是否返回了檔案，通知都將移動到下一個伺服器/目錄。

或者，您可以提供自己的 RotationPolicy 以根據需要重新配置訊息源

policy

public interface RotationPolicy {

    void beforeReceive(MessageSource<?> source);

    void afterReceive(boolean messageReceived, MessageSource<?> source);

}

和

custom

@Bean
public RotatingServerAdvice advice() {
    return new RotatingServerAdvice(myRotationPolicy());
}

local-filename-generator-expression 屬性（同步器上的 localFilenameGeneratorExpression）現在可以包含 #remoteDirectory 變數。這允許從不同目錄檢索的檔案下載到本地類似的目錄中

@Bean
public IntegrationFlow flow() {
    return IntegrationFlow.from(Ftp.inboundAdapter(sf())
                    .filter(new FtpPersistentAcceptOnceFileListFilter(new SimpleMetadataStore(), "rotate"))
                    .localDirectory(new File(tmpDir))
                    .localFilenameExpression("#remoteDirectory + T(java.io.File).separator + #root")
                    .remoteDirectory("."),
                e -> e.poller(Pollers.fixedDelay(1).advice(advice())))
            .channel(MessageChannels.queue("files"))
            .get();
}

使用此通知時，請勿在輪詢器上配置 TaskExecutor；有關更多資訊，請參閱訊息源的條件輪詢器。