Redis Streamsの消費者グループとは何ですか？

消費者グループは、複数の消費者が同じデータストリームを読むことで協力できるようにすることにより、メッセージの複製の問題を解決します。 1.消費者グループは、各メッセージがグループ内の1人の消費者によって1回だけ処理されることを保証します。 2。消費者は、それが正常に処理されていることを確認でき、未確認のメッセージを再割り当てすることができます。 3。Xgroup Createを使用してグループを作成し、XreadGroupがメッセージを読み取り、Xack確認プロセスが完了します。 4.未確認のメッセージはPELリストに保存され、Xpendingを通じて表示するか、Xclaimに転送できます。

Redis Streamsの消費者グループは、複数の消費者を整理する方法であり、お互いのつま先を踏むことなく、同じストリームからデータを読むことができるように協力することができます。共有のTo Doリストからタスクの処理に取り組んでいるチームのように考えてください。各人（消費者）はタスクを取り、独立して作業します。

消費者グループはどのような問題を解決しますか？

消費者グループがなければ、同じストリームから複数の消費者が読んでいる場合、彼らはすべて同じメッセージを受け取ります。ワークロードを分割したい場合、それは理想的ではありません。3人が同時に同じタスクを実行していると想像してください。

消費者グループと：

• ストリーム内の各メッセージは、グループ内の1人の消費者によって1回だけ処理されます。
• 消費者は、成功したメッセージ処理を認めることができます。
• 何かがうまくいかない場合、または消費者がクラッシュした場合、未承認のメッセージを再割り当てすることができます。

これにより、消費者グループは、信頼性の高いスケーラブルなメッセージ処理システムの構築に最適です。

消費者グループは実際にどのように機能しますか？

消費者グループを使用する場合、理解する重要な概念がいくつかあります。

• ストリーム：データのソース。
• グループ：消費者の名前付きグループ。
• 消費者：グループの一部としてストリームからのメッセージを読み取る個々のプロセスまたはクライアント。
• 保留中のエントリリスト（PEL） ：消費者にどのメッセージが配信されているが、まだ認められていないかを追跡します。

これが単純化されたフローです：

• グループの1人の消費者は、 XREADGROUPを使用してメッセージを読み取ります。
• メッセージは進行中であるとマークされています。
• 消費者が処理を終了したら、 XACKを送信して完了を確認します。
• メッセージが特定の時間内に認められていない場合、別の消費者に配信できます。

消費者グループの作成と使用方法

消費者グループから始めるには、最初にXGROUP CREATEコマンドを使用してストリームに関連付けられたグループを作成する必要があります。方法は次のとおりです。

 Xgroup Mystream MyGroup $を作成します

$シンボルは、グループが最新のメッセージ以降の読み取りを開始することを意味します。既存のすべてのメッセージも処理する場合は、 $を省略します。

グループが存在すると、消費者はメッセージを引っ張り始めることができます。

 XreadGroup Group MyGroup Consumer1 Count 1 Streams Mystream>

これにより、Redisはmystreamからmygroupグループのconsumer1に最大1つの未処理のメッセージを放棄するように指示します。

処理後、消費者は次のことを送信する必要があります。

 Xack MyStreamMyGroup <Message-Id>

これにより、保留中のリストからメッセージが削除され、Redisがそれが正常に処理されたことを伝えます。

注意すべきこと

消費者グループと協力するとき、いくつかのゴッチャスがあります：

• 承認されていないメッセージが確認されるまでPELにとどまります。 XPENDINGで確認できます。
• 消費者はクラッシュする可能性があり、メッセージは承認されていません。 XCLAIMを使用して、これらのメッセージを別の消費者に移動します。
• 消費者名はユニークである必要はありませんが、誰が何をしているのかを追跡するのに役立ちます。
• メッセージ保持はユースケースに依存します - Redisはポリシーを設定しない限り、メッセージを自動的に削除しません。

たとえば、デバッグまたは回復している場合、これは便利です。

 XペンディングマイストリームMyGroup

それは、消費者がそれらを持っているなどの詳細と、それらが保留中の期間などの詳細とともに、まだ認められるのを待っているメッセージの数を示しています。

したがって、消費者グループはほとんどの調整を処理しますが、承認を管理し、自分で再試行する必要があります。

基本的にそれだけです。

以上がRedis Streamsの消費者グループとは何ですか？の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。