問題タブ [aggregator]

Mule 3.x で完全にカスタムのアグリゲータを作成するための推奨される方法は何ですか? 完全にカスタムとは、相関 ID やメッセージ数などを使用せずに、独自のロジックに従っていることを意味します。

mulesoft サイトのドキュメントは古くなっています。3.x には存在しない AbstractEventAggregator を使用すると書かれています。

http://www.mulesoft.org/documentation/display/MULE3USER/Message+Splitting+and+Aggregatio

より深く掘り下げると、このクラスは 3.x で AbstractAggregator に名前が変更されたようです。

http://www.mulesoft.org/docs/site/3.2.0/apidocs/org/mule/routing/AbstractAggregator.html

ただし、これを使用する方法を示す例はありません。上記の最初のリンクで説明されている LoanBroker の例は、実際には相関アグリゲーターを使用しています (2.x の例では、ドキュメントが参照しているものと思われます)。

ある時点で、抽象メソッド shouldAggregate と doAggregate を持つ抽象クラスがありました。これは私が拡張したい種類のクラスです。

私のニーズ

社内の標準製品で、事態が発生したときにさまざまなイベントを発生させたいと思います。さまざまなカスタムソリューションのグローバルasaxで、必要に応じてこれらのイベントに接続し、対応したいと思います。

既存のモジュール

asp.netのイベントアグリゲーターを探していましたが、何を使用すればよいかわかりません。Prismについて読んだことがありますが、これはasp.netではなくWPF/Silverlightを対象としているようです。

次に、WPFとは関係なく、アグリゲーターを自分のバージョンに移植したように見えるこの男がいます：http ://weblogs.asp.net/rashid/archive/2009/03/05/use-event-aggregator-to- make-your-application-more-extensible.aspx

質問

asp.netのイベントアグリゲーターを使用した経験はありますか？これは本番用であるため、ネット上のランダムな男からのホームコード化されたアグリゲーターを使用しないことを好みます:)

前もって感謝します。

編集1： NServiceBusは目的のために少しやり過ぎだったようです。トリックを実行する単一のEventAggregatorクラスを作成しました。

クラス：

イベントクラス：

グローバルasaxへのイベントハンドラーの登録：

イベントの発生：

編集2：

そして、これが関心のあるもののための私のユニットテストです：

編集3：

アグリゲーターがスレッドセーフではないことを指摘してくれたStevenRobbinsのおかげで、PublishメソッドとRegisterメソッドにロックを追加しました。

コミッション ジャンクションの製品カタログ検索 API を使用してローカル ディールを検索/取得した人はいますか? (BuyWithMe と KGBDeals は取引を CJ に投稿します)

この API を使用する Yipit クローンがあります。このクローンは、場所に基づいて取引を適切に分類できませんでした。この問題を修正する必要がありました。私が見た問題は、API の応答に場所/都市情報が含まれていないことです。したがって、取引を都市に基づいて分類することはできません。これは基本的にローカル取引の目的を殺します。

CJ API を使用して同様の作業を行ったことのある方からのアドバイスをお待ちしています。何かが足りないのかもしれません。

Prismを使用してアプリケーションを実装しています。アプリケーションには、さまざまなマシンまたはサーバーに常駐するいくつかの分散コンポーネントがあります。それらを伝達するために、EventAggregatorを使用してメッセージングサービスを実装することを計画しています。しかし、それに取り組む前に、いくつかの説明が必要です。

1. EventAggregatorを分散環境で使用できますか。はいの場合、メッセージが公開またはサブスクライブされるサーバーまたはハブを定義する方法は？

2. Event Aggregatorを使用するアプリケーションのパフォーマンスへの影響は何ですか？無視できると思いますが、それでも知りたいです。

3. イベントアグリゲーターのアプローチは、エンタープライズ環境での将来の拡張に適していますか？

よろしくお願いいたします。

アシシュシャルマ

ASP.NET Web フォームに実装されたイベント アグリゲーターのサンプル/デモが見つかりません。ほとんどすべての記事は Silverlight に関するものです。

イベントアグリゲーターパターンを実装するASP.NET web.formsの作業コードを含む記事を教えてください。

最も単純な例: イベント アグリゲーター パターンで相互に通信する ASP.net Web フォームの 2 つのユーザー コントロール。

編集

現在、ユーザー コントロールに大きく基づいた ASP.NET Web フォーム アプリケーションを使用しています。コンテナー aspx ページは、相互に通信する必要がある複数のユーザー コントロール (ascx) をホストできます。当面は、コンテナ ページを通過するイベントによって実行されます。

これは制御不能になっています:(

php/Mysql を使用してクライアント向けの RSS、Twitter、およびその他のコンテンツ アグリゲータを作成しました。これには通常、cron ジョブ、いくつかのフィードの解析、データベースへのデータの挿入、保存とその後の再公開、削除、アーカイブなどが含まれます。画期的なものは何もありません。

しかし今、私は一般ユーザー向けのアグリゲーター サービスを構築する任務を負っています。サービスにアクセスできる各ユーザーは、数百ではないにしても、数十のソース フィードを追加できるため、これは迅速に拡張する必要があると思います。数か月以内に数千のフィードを定期的に解析する可能性があり、運が良ければ 1 年以内に 100,000、またはそれ以上になる可能性があります。

究極のモデルは、Googleリーダーが行うことに似ていると思います。

では、これにはどのような戦略が適しているでしょうか。複数のオーバーラップする cron、フィードを継続的に実行して読み取り、API に接続してコンテンツをプルしますか? 必要に応じて、Elastic Cloud などの複数のインスタンスを実行する予定はありますか?

アグリゲーターの構築方法に関するスレッドがすでにいくつかあることを残念に思います。それらのほとんどは、ビルドの基本を説明するのに役立ちますが、安定した信頼できるスクリプトが既に存在することについての提案が必要です.

私は特に、ファッション専用の Wordpress サイトにファッション固有のニュース アグリゲーターを追加することを検討しています。簡単に言えば、Glam、Vogue、Instyle、NYTimes、Fashion などの Web サイトで最新ニュースを探して Web をクロールし、それらを私が持っているさまざまなカテゴリ (ファッションとスタイル、ビューティーとメイクアップ、ヘルス＆ウェルネスなど

これを実行できる (またはほとんどカスタマイズされていない) スクリプトについて、仲間の stackoverflowers からいくつかの推奨事項が必要です。ありがとうございます！そして皆様、よい休日を。

LAMP を使用してフィード (RSS、Twitter、その他のサービスなど) アグリゲーターを構築しています。フィードを好きなだけ追加して、フィードを読んだり、並べ替えたり、個々のフィードやフィードのグループを一度に表示したりできるという点で、Google リーダーと非常によく似ています。

私は以前にこのタイプのサービスを構築したことがありますが、グループ全体が集約されたすべてのフィード項目にアクセスできる少数の限られたグループを対象としていました。だから、それはかなり簡単でした。

しかし今回は、人々がサブスクライブできるサービスを構築しているので、潜在的に (理想的には) 数千のユーザーと数万のフィード、そして数百万のフィード アイテムを持つことができます。

データベーススキーマ（簡略化）に対する私のアプローチは次のとおりです。

ただし、ユーザーは何百ものフィードをサブスクライブできるため、サブスクライブしたフィード (またはそのサブセット) の feed_items をデータベースに照会するための最適かつ最適化された方法を計画しようとしています。

Mule ESB CE 3.2.1 で、必要に応じてメモリ内の多数の csv インバウンド ファイルを集約し、それらを並べ替える必要があります。

この種のロジックをどのように実装できますか?

message-chunking-aggregator-router を試してみましたが、xsd スキーマがそのような構成を許可しないため、起動時に失敗します。

また、自分の相関 ID をインバウンド メッセージに添付して、カスタム アグリゲータで処理しようとしましたが、Mule が内部で以下で構成されるキーを使用していることがわかりました。

内部 ID は毎回異なります (相関シーケンスが正しい場合も同様です): このように、Mule は予想どおり相関シーケンスのみを使用せず、同じメッセージが何度も処理されます。

最後に、カスタム アグリゲーターを書き直すことができますが、より統合された手法を使用したいと考えています。

前もって感謝します、

ガブリエル

アップデート

message-chunk-aggregator を試してみましたが、重複が認められるため、要件に適合しません。

カバーする必要があるシナリオを詳しく説明しようとしています。

1. Mule ポーリング (SFTP ロケーションで)
2. ファイル1「FIXEDPREFIX_1_of_2.zip」が検出され、メモリのどこかに保持されます（開いているSFTPStreamとしては問題ありません）。グループ化のためにいくつかの相関情報が維持されます: グループ、シーケンス、グループサイズ。
3. ファイル 1 "FIXEDPREFIX_1_of_2.zip" が再度検出されますが、重複するため挿入できません
4. ファイル 2「FIXEDPREFIX_2_of_2.zip」が検出され、正しく追加されました
5. グループサイズに達したと通知された場合、Mule は正しいメッセージセットで MessageCollection をルーティングします

ポイント 2. については、幸運にもファイル名から情報を取得し、それらを MuleMessage::correlation* プロパティに入れて、後続のコンポーネントがそれらを使用できるようにしました。

私はしましたが、重複は同じように処理されます。

再度、感謝します

ガブリエル