問題タブ [spring-integration]

私は spring-integration を初めて使用し、Spring Integration を使用して次のシナリオを実装する方法を理解したいと考えています。

次の要件を持つ複数のノード(クラスター内など)を持つ分散アプリケーションを作成しようとしています。

- TCP/IP を介した要求/応答ベースのメッセージングを実装する必要があります。-メッセージ ブローカー (ActiveMQ など) を使用したく
ありません。
・SI が提供する TCP インバウンドおよびアウトバウンドゲートウェイを使用する予定です。

SI が次のことを達成するのにどのように役立つかわかりません
- 同じサーバー側の TCP インバウンド ゲートウェイに複数のクライアントが接続している場合、要求/応答の相関関係はどのように機能しますか?
- TCP/IP 経由でメッセージを送信すると、メッセージ ヘッダーが取り除かれることを理解しています。回避策は何ですか?
- このアプローチは実際に実行可能ですか? :(

ありがとう
サンディップ

あるクエリの出力が別のクエリの入力として使用されるように変換される、連鎖/パイプライン化されたクエリをサポートするフレームワークをJavaで作成しようとしています。PyCascadingのようなものこれらのクエリは実行時に行われます。私はいくつかのフレームワークを調べ、Apache Camel ＆Spring Integrationがチェーンとルーティング（エンタープライズ統合パターン）の概念を提供していることに気づきました。私はApacheCamelがSpringIntegration（IMHO）よりも優れていることを発見しました。

フレームワークにApacheCamelを使用する必要がありますか、それともこれを実現するためのより良い方法がありますか？

私のクエリ構文は

統合の問題に最適なものを選択するために、統合フレームワークを参照しています。私が知りたいのは、サポートされているかどうかにかかわらず、複数のアプリケーション統合コンテキストでのトランザクション管理です。もしそうなら、どうやって？Pro Spring Integrationでは、明確な解決策が見つかりませんでした。

これが複数のアプリケーションに沿ってトランザクションを管理する方法を理解できませんでしたか?

これらのフレームワークの専門家は、これらのフレームワークを使用して、トランザクションが実行されているアプリケーションでエラーが発生した場合のトランザクション管理と回復をどのように行うことができるかを知るのに役立ちますか? たとえば、このシナリオを考えてみましょう: アプリケーション A はトランザクションを開始し、アプリケーション B と C を途中で使用し、最後に B と C の後に sth を実行してコミットします。このシナリオでアプリケーション c が失敗するか例外をスローした場合、B でトランザクションをロールバックする方法はありますか?とAとどのように？

統合の問題に最適なフレームワークを選択するために、統合フレームワークを参照しています。私が知りたいことの 1 つは、キャッシングと分散キャッシングです。たとえば、通信に Web サービスを使用する場合、サポートされているかどうかはわかりません。もしそうなら、どうやって？

in Pro Spring Integration CHAPTER 16 ■ SCALING YOUR SPRING INTEGRATION APPLICATION page 544 では、キャッシング戦略について話していますが、Spring-integration を使用してそれらを実装する方法については言及していません。また、彼らはどこかでメッセージキャッシングについて話しているのですが、複数のマシン間のエンティティのキ​​ャッシングソリューションはありますか?

Spring Integration - HTTP アダプターを使用しています。

今、私はそれをHTTPSにしたいと思っています。実装方法を教えてください。

ヘッダー/メッセージ値に基づいてSIでフローの実行を停止することは可能ですか？

ありがとう。

比較的リソースを効率的に使用する必要がある Spring Integration アプリケーションがあります。ポート > 1024 の localhost にバインドされた安らかな Web サービスを公開したいと考えています。現在、アプリケーションはコマンドラインから次のように実行されています。java -jar MyApp.jar

Tomcat のようなアプリケーション コンテナーを起動せずに Web サービスをホストする方法はありますか?

Update in the spring app は、Web サービスとして公開したいゲートウェイです。

私は春の統合+バッチアプリケーションを持っています。

統合は、受信チャネル アダプターでファイルを読み取り、バッチ ジョブを呼び出すために使用されます。jobRepository は org.springframework.batch.core.repository.support.JobRepositoryFactoryBean から定義されます。

トランザクションマネージャーは org.springframework.orm.jpa.JpaTransactionManager です。

アプリケーションが起動すると、理由はわかりませんが、この奇妙な種類の構成を読みました。

デフォルトでは、すべてのジョブメソッドが分離SERIALIZABLEで構成されているようですが、どこにも設定していません。デフォルトの分離レベルを ISOLATION_DEFAULT として設定する方法はありますか?

フィードを含むペイロードをクラスにマッピングする目的で、Spring Integration プロジェクトに Feed クラスを作成しました。フォーマット要件が異なるため、Spring 独自のアトム フィード メッセージ コンバーターを使用できません。

私が抱えている問題は、ペイロードを含む投稿を送信すると、ペイロードが私が書いたものではなく独自のフィード クラスに変換され続けることです。ここでの大きな問題は、Spring Atom メッセージ コンバーターと私の両方が "Feed" クラスを定義していることだと思います。

では、ペイロードを処理するときに独自の Feed クラスの代わりに、Spring に強制的に Feed クラスを使用させる方法はありますか?

どうもありがとう、R.

PS: request-payload-type を自分のクラス名に設定しようとしましたが、成功しませんでした。

私のゲートウェイには、メソッドがあります

アイデアは、Bean から commsTest を呼び出し、Spring 統合を使用して、通信をチェックするサービス アクティベーターに接続できるというものです。

私がそれをすると、receive is not supported, because no pollable reply channel has been configuredエラーが発生します。これは、パラメーターのないメソッドが「チャネルからメッセージをポーリングしようとしている」ことを意味するためであることに気付きました

これは 2 つの部分からなる質問です。

1. チャネルからメッセージをポーリングするとはどういう意味ですか。
2. 必要な機能を取得するにはどうすればよいですか。