問題タブ [spring-integration]

クライアント側でDBをポーリングし、結果をHTTP経由でデータを収集するサーバーに送信しようとしています。残念ながら、最初のメッセージのみが配信されます。私は春の統合（1.0.3）が初めてです

構成の何が問題になっていますか?

クライアント構成:

サーバー構成:

編集:クライアントを再起動するたびに、サーバーは単一のメッセージを受信します。

解決済み: StorageService の署名を から変更する必要がありました

に

私は春の統合プロジェクト (1.0.2) に取り組んでおり、@Header アノテーションを機能させることができません。

これが私のサービスアクティベーターです：

エラーメッセージは次のとおりです。

私は何を間違っていますか？

春の統合を使用して、実行時間の長いアクションを切り離して、ユーザーへの応答を高速化しようとしています。

このリクエストにより、データベースに GPS 位置エントリが作成されます。逆ジオコーディング サービスによって、その GPS 位置のアドレスを取得する http 要求を実行したいと考えています。これには数秒かかることがあるので、後で/並行して実行したいと考えています。

Spring Integration はこれに最適ですが、私が抱えている問題は、並列実行中のサービスが高速化されている場合、ポジション エントリをデータベースに保存するときに競合が発生することです。

Spring Integration で永続オブジェクトを処理する方法に関するベスト プラクティスはありますか? メインのリクエストが処理されるまでオブジェクトをロックする必要がありますか?

アップデート：

基本的に、位置オブジェクト (疑似 Java コード) を操作する 2 つのメソッドがあります。

MVC コントローラーによって呼び出される Service クラスにあるもの:

それは、locationChannel にアタッチされた ServiceActivator によって呼び出される Service クラスにあります。

Message インターフェイスを実装して、サーバー側の HeaderValueRouter で使用するヘッダーをいくつか含めました。

これは 1 つの VM 内で機能します (2 つのエンドポイント間のフィルターを使用してテストされています)。

しかし、HttpOutboundGatway を介してメッセージを送信すると、フィールドが取り除かれます (HttpRequest には含まれません)。そのため、ルーティング情報はサーバー側で失われます。

ヘッダーを操作することは想定されていませんか?

編集：

バージョンは 1.0.3 です

私の構成の一部は次のとおりです。

次のメソッド シグネチャを持つスプリング統合スプリッターがあります。

メッセージ ペイロードは、String[] の ArrayList です。スプリッターはリスト内の各行を読み取り、リスト内のデータ項目にペイロードを設定する新しいメッセージを作成し、CorrelationId、SequenceNumber、および SequenceSize をヘッダーに追加して、最後にメッセージの ArrayList を返します。

問題は、個々のメッセージが次のチャネルに送信されるときに、CorrelationId、SequenceNumber、および SequenceSize がすべて新しい値で上書きされることです。それは予想される動作ですか、それとも何か不足していますか?

以下のコード スニペット:

Spring Integration 2.0 M6 の使用

メッセージ駆動型チャネルアダプタを使用してMQキューからメッセージを読み取りますが、これは開発で正常に機能しています。さて、最初の製品リリースの準備として、代わりにセキュリティで保護されたキューを読み取る必要があります。

私は何をする必要がありますか？

次のものがシステムプロパティとして設定されていることを確認する必要があると思いますが、どのような値を使用しますか？

jndiからconnectionFactoryを取得し、SSLCipherSuiteが設定されています。

クリアテキストのパスワードと、キーストアとトラストストアの両方を含むJKSファイルが提供されました

次に何をする必要がありますか？

Spring Integrations 2.0.0を使用しており、以下を構成しようとしています。

アプリケーションは、Spring統合駆動型バックエンドによって処理されるActiveMQJMSキューにオブジェクトを配置します。バックエンドは応答をこの特定のキューに配置してこのアプリケーションによってのみ消費されるため、送信アプリケーションは一時応答キューで応答を待機しています。メッセージはバックエンドで受信および処理され、応答は、JMS要求メッセージ（reply-to）で指定された一時応答キューに配置されます。バックエンドでは、応答が最終的に応答キューに配置される前に、メッセージは一連のサービスを介して実行されます。

質問：一時キューに応答を配置するようにSIを構成するにはどうすればよいですか？SIがこれを自動的に行う方法はありますか、それともDestinationResolverなどを使用する必要がありますか？jms-gatewayがこれに対する正しい解決策である可能性があることは理解しましたが、それを適切に配置する方法を完全に理解することはできませんでした。何か案は？

ここで基本認証を設定するためのこのシーケンスを見つけました：

スプリング構成を使用してこれをどのように達成できますか？背後にある理由は、スプリング統合HttpOutboundGatewayの認証を有効にする必要があるためです。このトピックで私が見つけた唯一の情報はこれです

• 問題は、スプリング構成をどのように行うかです。
• 次に、HttpClientをスプリング統合に注入するにはどうすればよいですか？

私は春の初心者で、学校のためのプロジェクトをしなければなりません。SpringBatchとIntegrationを使用してどのようなプロジェクトを実行できますか。ファイルをディレクトリに書き込んだり、カンマ区切りのファイルを書き込んだり、読み取ったり、変更したりできることは知っていますが、これらのテクノロジを組み合わせることができるシナリオを想像することはできません。

電子メールを読み取り、安らかな Web サービスを提供するコードを作成しようとしています。

gmail (オーバー ポップ) からメッセージを読み取る簡単なテスト ファイルがあります。ただし、 cxf-rf-frontend-jaxrs を pom.xml に追加すると、そのテスト ファイルが機能しなくなるようです。

これを解くことができる人はいますか？

ありがとう、コードなどは次のとおりです。

エラーは次のとおりです。

テストファイルは src/test/java/mail/GmailManualTester.java です

そして pom.xml は

編集: ~/.m2/.../cxf-rt-frontend-jaxrs-2.3.0.pom ファイルからすべての依存関係を取得し、除外として自分の pom.xml に入れました。原因が1つだけ見つかるまで、それらのオンとオフを切り替えました：

これを pom ファイルに入れると、メッセージを取得できます。コメントアウトすると、上記のエラーが発生します。ただし、今でもそれをさらに掘り下げる必要があります。それを除外すると、アプリの Web サービスが壊れる可能性があります。