問題タブ [spring-integration]

Spring統合とJBossjBPMの違いは何ですか？

ありがとうございました。

関連する技術

• ラバ
• アパッチ CXF

与えられた

単純な POJO (物議を醸す頭字語ですが、スマート POJO としましょう):

達成する必要がある

コードに触れずにWebserviceSmartPojoとして公開します (変更、変更、新しいインターフェースの追加、JAX-WS アノテーションなどなし)。目標は、Mule 設定のみを使用することです。SmartPojoSmartPojoInterface

Spring Integration で簡単に実行できます。Mule でそれを実現する方法についてご意見をいただければ幸いです。(「cxf:inbound-endpoint」は「method-entry-point-resolver」で構成する必要があり、何らかの方法で WSDL を提供する必要があるようです..または別の方向ですか?)

ありがとうございました

次のようなワークフローが必要です。

あれは：

• リクエストが到着し、FIFO キューに入る
• 次に、同一のワーカーがキューからタスクを取得します
• 任意の時点で、ワーカーは 1 つのタスクのみを実行できます
• ワーカーが空いていて保留キューが空でない場合、ワーカーはすぐに別のタスクを取得する必要があります
• タスクが完了すると、ワーカーは結果をResponse Channel

QueueChannelSpring Integration に があることは知っていますが、これらのチャネルにはポーリングが必要です (これは最適ではないようです)。特に、ワ​​ーカーが忙しくできるのであれば、ワーカーには忙しくしてもらいたいです。

また、キューを完全に回避し、単純にタスクをすべてのワーカーにラウンドロビンさせることも検討しましたが、一部のタスクは他のタスクよりも速く完了する可能性があるため、待機列を 1 つにすることをお勧めします。さらに、残りのジョブ数 (キューから取得できる) と、すべてまたは特定のジョブをキャンセルする機能についての洞察が必要です。

ポーリングを回避しながら、このメッセージ キューイング/作業分散パターンを実装するにはどうすればよいですか?

編集: Message Dispatcher パターンを探しているようです-Spring/Spring Integration を使用してこれを実装するにはどうすればよいですか?

キューをの先頭に配線しようとしていますが、トリガーさMessageChannelれたときに実行時に実行できるように、プログラムで配線する必要があります。osgi:listenerこれまでのところ私は持っています：

関連するさまざまなクラスを調べて、私は次のことを思いつきました。

しかし、私はそれをすべてまとめることはできません。私は何が欠けていますか？

次のメソッドがあり、JAXBElement<> 構文を明示的に表示する必要がないようにしたいと考えています。メソッドが生の MessageResponse オブジェクトを受け入れるように見えるが、実際には以下に示すように同じように機能するような注釈はありますか? それがどれほど明確だったかわからないので、これを言います：私はいくつかの構文糖衣を探しています:)

この構成は正常に機能しますが、15秒ごとにポーリングすることになっているinbound-channel-adapterが継続的に実行されています。誰かが私が間違っていることを知っていますか？

次のシナリオでは、ベストプラクティスに関するアドバイスとヒントを探しています。

分散（主にJavaベース）システムで：

• 多くの（異なる）クライアントアプリケーション（Webアプリ、コマンドラインツール、REST API）
• 中央のJMSメッセージブローカー（現在はActiveMQの使用を支持しています）
• 複数のスタンドアロン処理ノード（複数のリモートマシンで実行され、JMSメッセージペイロードで指定されたさまざまなタイプの高価な操作を計算します）

Spring Integrationフレームワークによって提供されるJMSサポートをどのように適用して、クライアントをワーカーノードから切り離すのが最適でしょうか。リファレンスドキュメントといくつかの最初の実験を読むと、JMSインバウンドアダプターの構成では本質的にサブスクライバーを使用する必要があるように見えますが、分離されたシナリオでは存在しません。

ちょっとした注意：通信はJMSテキストメッセージを介して行う必要があります（将来の拡張性のためにJSONデータ構造を使用）。

spring-integrationのメッセージシリアライゼーションのサポートを検討しています。これは、さまざまなワイヤ レベルのトランスポートが保証された配信を実装するのに役立ちますが、他のメッセージング システムとの相互運用性 (AMQP など) を可能にするためにも役立ちます。

発生する基本的な問題は、ペイロードとヘッダーに Java オブジェクトを含むメッセージをストリームに変換byte[]および/またはストリームに書き込む必要があることです。Java 独自のシリアライゼーションは、相互運用性がないため明らかに役に立ちません。私の好みは、シリアライゼーションに参加するすべてのオブジェクトに必要なロジックをユーザーが実装できるようにするインターフェイスを作成することです。

つまり、クライアント開発者にドメイン コードの生成を要求するのではなく、それを必要とするオブジェクトのシリアライザーを定義する必要があります。インターフェイスは次のようになります。

これは賢明なアイデアであり、完璧なインターフェースはどのようなものでしょうか? このコンテキストで意味のあるオブジェクトをシリアル化するための標準的な相互運用可能な方法はありますか?

ベテランの Spring ユーザーとして、私は Spring Integration がいくつかの (JMS) メッセージング機能を必要とする最近のプロジェクトで最も理にかなっているだろうと想定していました (詳細)。Spring Integration を数日使用した後でも、リクエスト/レスポンス (異なる JMS キューでリッスンする) 通信を行うために構成する必要があるチャネルの量を考えると、多くの構成オーバーヘッドのように感じます。

したがって、Camel が Spring Integration とどのように異なるかについての背景情報を探していましたが、そこにある情報はかなり予備のようです。

• http://java.dzone.com/articles/spring-integration-and-apache (2009 年 12 月以降、Spring Integration と Camel での実際の統合シナリオの実装の非常に中立的な比較)
• http://hillert.blogspot.com/2009/10/apache-camel-alternatives.html (Camel と他のソリューションの比較、2009 年 10 月)
• http://raibledesigns.com/rd/entry/taking_apache_camel_for_a (Matt Raible、2008 年 10 月)

質問: あるスタックを他のスタックよりも使用して、どのような経験をしましたか? Spring Integration にサポートがない場合、どのシナリオで Camel をお勧めしますか? それぞれの長所と短所はどこに見られますか? 実際のプロジェクトからのアドバイスは大歓迎です。

私はこれを持っています：

そして、私が構成しているのは非同期キューだと思いました。メッセージをその上にドロップし、他のスレッドにメッセージを取得して後で処理してもらいたいです。しかし、その瞬間、それは同期的にそれを行うようです。

私はそれを間違っていますか（明らかにそうです）、この構成に欠けているものがあるのか​​、それとも間違ったアプローチをしているのか疑問に思っていますか？

乾杯