春の統合FTP InboundChannelAdapterがネットワークリセット後に終了する

Question

FTPからdownloadファイルへのユースケースがあり、ネットワーク再設定後にftpインバウンドアダプタが動作しなくなるという奇妙な動作があります。

ローカルへ

1. 開始アプリケーション
2. アプリケーションは、FTPサーバからファイルをダウンロードするために開始し
4. 定義されたローカルディレクトリに表示されてfilename.writingファイルがあるネットワークのリセットをシミュレートするために、（ネットワークケーブルを抜きます状況）
5. アプリケーションはファイルをダウンロードすることをやめます（ネットワーク接続はありません）。
6. ネットワークケーブルを接続します。
7. ダウンロードが再開またはリセットされないため、アプリケーションは依然として..続きます。
8. この問題を特定するためには、まったくLOGはありません。

ありがとうございます！

UPDATE

この問題は以下のコードは、FTP読み取りクライアント上WORKING例でタイムアウトdefSession.setConnectTimeout(Integer.valueOf(env.getProperty("ftp.timeout.connect")));

とを追加することで固定してください。ここで

は、コードスニペットです：

@Bean 
    public DefaultFtpSessionFactory ftpSessionFactory() { 
     DefaultFtpSessionFactory defSession = new DefaultFtpSessionFactory(); 
     defSession.setUsername(env.getProperty("ftp.username")); 
     defSession.setPassword(env.getProperty("ftp.password")); 
     defSession.setPort(21); 
     defSession.setHost(env.getProperty("ftp.host")); 

     defSession.setClientMode(FTPClient.PASSIVE_LOCAL_DATA_CONNECTION_MODE); 
     defSession.setControlEncoding("UTF-8"); 

     return defSession; 
    } 

    @Bean 
    PollableChannel ftpChannel() { 
     return new QueueChannel(Integer.valueOf(env.getProperty("ftp.channel.size"))); 
    } 

    @Bean 
    public FtpInboundFileSynchronizer ftpInboundFileSynchronizer() { 
     FtpInboundFileSynchronizer ftpInboundFileSynchronizer = new FtpInboundFileSynchronizer(ftpSessionFactory()); 
     ftpInboundFileSynchronizer.setDeleteRemoteFiles(Boolean.valueOf(env.getProperty("ftp.directory.delete"))); 

     FtpRegexPatternFileListFilter ftpRegexPatternFileListFilter = new FtpRegexPatternFileListFilter(pattern); 
     ftpInboundFileSynchronizer.setFilter(ftpRegexPatternFileListFilter); 
     ftpInboundFileSynchronizer.setRemoteDirectory(env.getProperty("ftp.directory.remote")); 

     return ftpInboundFileSynchronizer; 
    } 

    @Bean 
    @InboundChannelAdapter(value = "ftpChannel") 
    public FtpInboundFileSynchronizingMessageSource ftpInboundFileSynchronizingMessageSource() { 
     FtpInboundFileSynchronizingMessageSource ftpInboundFileSynchronizingMessageSource = new FtpInboundFileSynchronizingMessageSource(ftpInboundFileSynchronizer()); 
     ftpInboundFileSynchronizingMessageSource.setLoggingEnabled(true); 
     ftpInboundFileSynchronizingMessageSource.setCountsEnabled(true); 
     ftpInboundFileSynchronizingMessageSource.setAutoCreateLocalDirectory(true); 
     ftpInboundFileSynchronizingMessageSource.setLocalDirectory(new File(env.getProperty("ftp.directory.local"))); 

     return ftpInboundFileSynchronizingMessageSource; 
    } 

    @Bean(name = PollerMetadata.DEFAULT_POLLER) 
    public PollerMetadata defaultPoller() { 
     PollerMetadata pollerMetadata = new PollerMetadata(); 
     pollerMetadata.setErrorHandler(t -> log.error("Failed to retrieve data from FTP: {}", t.getMessage(), t)); 
     pollerMetadata.setTrigger(new PeriodicTrigger(60, TimeUnit.SECONDS)); 
     return pollerMetadata; 
    } 

Answer 1

ほとんどのスレッドが読み取りにぶら下がっている - あなたは、コンピュータ上の実際のアダプタからケーブルを引く場合は、ネットワークスタックは、Javaプロセスに通知しなければなりませんソケットは消えていますが、ダウンストリームルータからケーブルを引き出すと、信号がない可能性があります。 jstackはスレッドが何をしているかを表示します。

セッションファクトリでタイムアウトを設定する必要があります。the documentationおよびFtpClient javadocsを参照してください。dataTimeoutが読み取りに使用されます。