問題タブ [spring-batch-admin]

以下は、Spring バッチ リモート チャンクの構成です。ステップがリモートではなくローカルで実行されています。rabbitmq でメッセージが表示されません。

構成をこれに変更しました。一度に 1 つのメッセージをキューに入れ、複数のメッセージを処理しません (リスナーの同時実行数と同じ数のメッセージを処理する必要があります)。

一度に 1 つのメッセージしかキューに表示されません。メッセージ = ${import.exchanges.commit.interval} を送信する必要があり、すべてが同時リスナーによって取得され、並行して処理される必要があります。

ネストされたジョブがあり、メインジョブは多くの子ジョブを呼び出し、それらは再び他の子ジョブを呼び出します。ステップの実行を分割するために、春のバッチリモートパーティショニングを使用しています。

spring batch admin を使用してメイン ジョブを停止しても、ジョブは停止しません。すべてのジョブが実行され続けます。

すべての内部ジョブを停止し、再起動時に停止した場所から内部ジョブを開始する必要があります。

それはネストされたジョブのためですか？ネスティングレベルの制限はありますか? それともリモートパーティショニングが原因ですか？

ファイルからアイテムを読み取って処理する春のバッチセットアップ（リモートパーティショニング）があります。

入力ファイルが存在しない場合は、リモートサーバーからコピーしたい。そのため、Spring Integration sftp 送信ゲートウェイを使用してリモート サーバーからファイルをダウンロードしようとしているという点で、ステップ リスナーを追加しました。

私はこのテストケースを参照しています

https://github.com/spring-projects/spring-integration/blob/master/spring-integration-sftp/src/test/java/org/springframework/integration/sftp/outbound/SftpOutboundTests.java

https://github.com/spring-projects/spring-integration/blob/master/spring-integration-sftp/src/test/java/org/springframework/integration/sftp/outbound/SftpServerOutboundTests-context.xml

以下は私の構成です、

何も機能していないように見えるので、私は何か間違ったことをしていますか？

また、int-sftp:outbound-gateway に scope="step" を含めることはできますか? 追加しようとすると、STS でエラーが発生します。

ログ

DEBUG レベルが有効になっているログを次に示します。

完全なログはこちら

http://pastebin.com/4KDBGqCH

アップデート：

以下は、ユースケース全体ではなく、単純なテストです。

テストジョブ

sftp 送信ゲートウェイ構成

テストタスクレット

ログ：

バッチ処理に春のバッチリモートパーティショニングを使用しています。春のバッチ管理を使用してジョブを起動しています。

インバウンド ゲートウェイのコンシューマ コンカレンシー ステップを 10 に設定しましたが、並行して実行されるパーティションの最大数は 8 です。

後で消費者の同時実行数を 15 に増やしたいと考えています。

以下は私の構成です、

2つの問題があり、

i) 同時実行数を 10 に設定しましたが、実行中のスレッドの最大数は 8 です。

ii)

他のプロセスが実行されると遅いものもあれば速いものもあるので、ステップの実行が公平に分散されるようにします。つまり、より高速なサーバーが実行を完了した場合、キュー内の残りの実行はそれらに移動する必要があります。ラウンド ロビン方式で配布しないでください。

私はrabbitmqに、運賃を分配するためのプリフェッチカウント設定とackモードがあることを知っています。Spring 統合の場合、プリフェッチ カウントはデフォルトで 1 であり、ack モードはデフォルトで AUTO です。しかし、他のサーバーが長時間稼働しているにもかかわらず、一部のサーバーはさらに多くのパーティションを実行し続けています。アイドル状態のサーバーがないことが理想的です。

アップデート：

私が今観察したもう 1 つのことは、(リモート パーティショニングを使用して分散されていない) 分割を使用して並列に実行されるいくつかのステップでも、最大 8 並列で実行されることです。スレッド プール制限の問題のように見えますが、ご覧のとおり、taskExecutor のプール サイズは 50 に設定されています。

spring-batch/spring-batch-admin に同時実行ステップ数を制限するものはありますか?

2 回目の更新:

また、並列処理アイテムで実行されているスレッドが 8 つ以上ある場合、Spring バッチ管理は読み込まれません。ハングするだけです。同時実行数を減らすと、Spring Batch Admin が読み込まれます。あるサーバーで同時実行数を 4 に設定し、別のサーバーで 8 を設定してテストしたところ、Spring バッチ管理者はそれをロードしません。8 つのスレッドが実行されているサーバーの URL を使用していますが、4 つのスレッドが実行されているサーバーで動作します。

Spring バッチ管理マネージャーには、以下の jobLauncher 構成があり、

プールサイズは6ですが、上記の問題と関係がありますか?

または、実行中のスレッド数を 8 に制限する tomcat 7 には何かありますか?

バックグラウンド -

単一の Weblogic ドメインの同じクラスターに .war として 2 つの Spring バッチ アプリケーションをデプロイしようとしています。それぞれに、以下のように servlet.xml で構成された Spring バッチ管理コンソールがあります。

そのMavenプロジェクトとspring-batch-admin-manager 1.2.2が依存関係として取り込まれています。

問題 -
両方を同時に実行するのに苦労しています。現時点では、両方を同時に実行することはできません。一方が既に実行されているときに他方を開始しようとすると、次のエラーが発生します –</p>

私が理解している限り、問題は spring-batch-admin にあります。両方のアプリケーションが構成から同じ Bean を初期化しようとしているため、このエラーが発生しますが、これを防ぐ方法がわかりません。

ネットでstackoverflowやさまざまなフォーラムを検索してみましたが、問題の解決策が見つかりませんでした。誰でも助けてもらえますか？

Web アプリケーションの Spring Batch 管理コンソールに Basic 認証を追加したいと考えています。ローカルのTomcatでそうしようとしたとき、すべて問題ありませんでした。認証は正しく機能しています。また、クライアントにアプリをデプロイしたとき、WebSphere 7 Basic Auth のテストおよび統合環境は機能しています。

しかし、クライアントの Pre および Live 環境で問題が発生します。WebSpheres 7 もありますが、基本認証が機能していません。Batch 管理コンソールにログインできますが、アプリから認証の詳細について尋ねられません。

私の web.xml conf:

これは私の構成の問題ですか、クライアントには WS で正しく構成されていないものがあります。私は Pre および Live WS にアクセスできないことを認めなければなりません。make for us 別の組織を展開します。しかし、構成チェックを依頼することはできますが、何を依頼すればよいかわかりません。

テストおよび統合環境では https が構成されていませんが、Pre および Live SSL では有効になっているため、手掛かりがあります。HTTPS は Basic 認証をカットできますか。情報？HTTPS を構成して Tomcat を起動すると、基本認証もローカルで機能します。

どんなヒントにもとても感謝します！