問題タブ [spring-integration-sftp]

以下の構成で spring-integration-sftp を使用して SFTP の場所から読み書きする方法を知っています。

タグlocal-directory要素を削除してみましたが、春はそれを許可していません。ローカルディレクトリにファイルを作成せずにファイルを読み書きする方法はありますか?

大文字と小文字を区別せずに複数のファイル拡張子タイプを指定する方法はありますか?

SFTP ディレクトリがあり、ファイルを読み取り、さらに処理するためにファイルを ServiceActivator に送信します。いつでも、ハンドラーを使用してそれらを並行して処理する必要があります。

これが私の SPring Integration Java DSL フローです。

更新: ここに私の ThreadPoolExecutor があります:

以下の構成をテストして、service-activator を使用してサービス クラス メソッドに InputStream を渡す方法を探していますが、service-activator が呼び出されなかったようです。間違っている点はありますか？

サービス クラスで、InputStream パラメータを持つメソッドが作成されます。

ファイルをリモートパスからローカルにプールし、いくつかのジョブを処理してから、ローカルファイルとリモートファイルの両方を削除するようにSpring SFTPを構成しました。

以下の構成は正常に動作しますが、ローカル ファイルの削除を除き、ローカル ファイルを削除するための構成が見つかりませんでした。delete-remote-files="true"

ここでは、ファイルがリモートからローカルに転送されたときに、サービス アクティベーターが呼び出されます。

Service Activator がジョブを完了したときにローカル ファイルを削除するように構成するにはどうすればよいですか?

編集: リモートとローカルの両方からのペイロードの削除は、以下の変更で解決されます:

リモートサーバーからファイルをポーリングするようにSpring統合SFTPアプリケーションを構成しました.1つを実行している場合、同じアプリケーションが3回実行されている場合、ファイルをより速く処理するために正常に動作しています.そのような場合、同じファイルが2つのアプリケーションによってポーリングされ、結果重複した結果で。どうすればこれを回避できますか? Spring統合で利用可能なファイルロックはありますか?

構成部分については、このSOを調べることができます

こんにちはアルテム/ゲイリー/友人、

PROD 上のアプリケーション サーバーに耳を展開する必要があるという要件があります。ソリューション フローは SI フローの JMS メッセージ リスナーから始まり、フレームワーク全体が SI ベースであり、遅延アグリゲーター JDBC アウトバウンド アダプターを使用しています。デプロイの前に、アプリケーション サーバーで EAR のデプロイを開始できるように、SI フローでアクティブなライブ スレッドがないことを確認する必要があります (すべてのチャネルで処理が完了し、間にライブ メッセージがないことを意味します)。制御バスを使用してメッセージ リスナーを停止しましたが、メッセージ処理が完了して終了し、フローにライブ SI メッセージが存在しないことも確認する必要があります。

助けてください。

ありがとうラム

SFTP 統合を使用して Spring を正常にセットアップし、SFTP サーバーをポーリングしてファイルをプルダウンしています。

私が知りたいのは、ダウンロードが完了したら、各ファイルでタスクを起動することは可能ですか? ファイルシステム監視の道をたどりたくありません-これのためにSpring SFTPに組み込まれているものはありますか?

ドキュメントを見ると、Channels で実現できるようです。

これは私のレシーバーチャンネルが現在どのように見えるかです:

カスタマーインターセプターなどを起動するために何をする必要があるのか​​ わかりません。

編集：Springのドキュメントから、次のように書かれています：

また、SFTP インバウンド チャネル アダプターはポーリング コンシューマーであるため、ポーラー (グローバル デフォルトまたはローカル サブ要素のいずれか) を構成する必要があることを理解することも重要です。ファイルがローカル ディレクトリに転送されると、ペイロード タイプが java.io.File のメッセージが生成され、channel 属性で識別されるチャネルに送信されます。

これを実装する方法がわかりません-そして例が見つかりません。