2016-10-23 8 views
0

イベントソーシングのシナリオでは、クラッシュしたイベントコンシューマクライアントは、失われたすべてのイベントを取得する必要があります。クラッシュしたクライアント用のサブパブ不在メッセージの組み込みリカバリをサポートするブローカは何ですか?

(それが正しいと仮定して)回復アルゴリズムは次のようになります。

  1. は、「イベント・ソース(接続1)に

  2. 要求サーバー(接続2)全て逃したメッセージを(サブスクライブ特定のタイムスタンプ(クラッシュの直前)以来の「失敗パック」)。ローカルで不在イベントを適用する

  3. サブスクリプション接続からメッセージを読み込み、タイムスタンプのあるメッセージをmissed-packから最後に適用したメッセージよりも優先して適用します。 (ここでは、サブスクリプションと最初の読み取りとの間に公開されたすべてのメッセージがクライアントに配信されることを前提としています。

    (メッセージブローカー、無SQLデータベースは、...)のサポート、すなわちサーバー(イベントソース)でプログラミングする必要がない、「ボックスアウトのうち、」この回復過程をプログラミングするかどうブローカー

側。

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

答えて

1

多分あなたが探しているものは、 "キャッチアップサブスクリプション"機能です。それは完全にGet Event Storeによって提出されています。しかし、これは実際にはデータベースですが、http APIも備えた優れたトピックベースのpub/sub機能を備えています。

まだ分かりませんが、消費者主導型のサブスクリプションを作成してください。コンシューマは最後のチェックポイントを知っています(同時性の問題を引き起こす可能性のあるタイムスタンプはありません)。 、プロデューサーではありません。したがって、クライアントはいつでもどこから退出してもかまいません。

希望すると便利です。

関連する問題