2

永続サブスクライバーをサポートし、メッセージのタイムスタンプに基づいて、特定のトピックのすべてのメッセージを順番に再生できるメッセージ バス プロバイダーを見つけようとしています。さらに、メッセージが遅れて到着したときに、メッセージバスが各永続コンシューマーのチェックポイントをリセットするようにしたいと考えています。例えば

  1. クライアントは 2009-12-22 12:00:00 にトピック 1 にサブスクライブします
  2. メッセージ 1 が到着、タイムスタンプが 2009-12-22
  3. クライアントがメッセージ 1 を受信
  4. クライアントの切断
  5. メッセージ 2 が到着、タイムスタンプ 2009-12-21 18:00:00
  6. クライアント接続
  7. クライアントはメッセージ 2 を受信し、次にメッセージ 1 を受信します

オープン ソース プロバイダーを強く希望します。これをサポートするメッセージバスプロバイダーを知っている人はいますか? ActiveMQ、Mass Transit などの導入ドキュメントを読もうとしましたが、メッセージ バスの用語については後れを取っていることを認めざるを得ないため、多くのことを理解できませんでした。

4

2 に答える 2

0

AMQP（RabbitMQなどによって実装）を使用すると、永続的なキューを定義して、それらを同じ交換に接続できます。メッセージを受信したい各クライアントは、最初に独自の永続キューを設定します。このキューは、クライアントが切断されている間も、交換機から受信したメッセージを保持します。

これの唯一の制限は、接続したことがなく、予期せず現場に到着したクライアントが、遅ればせながらキューを設定して、以前のすべてのメッセージのダンプを要求できないことです。AMQP 1.0はそのような普遍的な永続性を可能にするかもしれませんが、私は新しいモデルをよく知らないので、はっきりとは言えません。

于 2009-12-22T22:02:18.050 に答える
0

春の統合プロジェクトを見たいと思うかもしれません。

http://www.springsource.org/spring-integration

于 2009-12-31T02:23:32.230 に答える