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

從 5.0.7 版本開始，RotatingServerAdvice 可用；當配置為輪詢器 advice 時，入站介面卡可以輪詢多個伺服器和目錄。配置 advice 並將其正常新增到輪詢器的 advice 鏈中。DelegatingSessionFactory 用於選擇伺服器，詳情請參見Delegating Session Factory。該 advice 的配置包含一個 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);
}

此 advice 將輪詢伺服器 one 上的目錄 foo，直到沒有新檔案為止，然後轉移到伺服器 two 上的目錄 bar，接著是目錄 baz，依此類推。

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

fair

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

在這種情況下，無論上次輪詢是否返回檔案，該 advice 都將移至下一個伺服器/目錄。

或者，您可以提供自己的 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 屬性（在 synchronizer 上是 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();
}

使用此 advice 時，請勿在 poller 上配置 TaskExecutor；更多資訊請參見訊息源的條件輪詢器。