Qu'est-ce qu'un groupe de consommateurs dans Redis Streams?

Les groupes de consommateurs résolvent le problème de la duplication des messages en permettant à plusieurs consommateurs de collaborer à la lecture du même flux de données. 1. Le groupe de consommateurs garantit que chaque message n'est traité qu'une seule fois par un consommateur du groupe; 2. Le consommateur peut confirmer qu'il est traité avec succès et que les messages non confirmés peuvent être réaffectés; 3. Utilisez Xgroup Create pour créer un groupe, XReadGroup lit le message et le processus de confirmation Xack est terminé; 4. Les messages non confirmés sont stockés dans la liste des PEL et peuvent être visualisés via XPending ou transférés au Xclaim.

Un groupe de consommateurs dans Redis Streams est un moyen d'organiser plusieurs consommateurs afin qu'ils puissent travailler ensemble en lisant des données du même flux, sans se précipiter sur les orteils les uns des autres. Pensez-y comme une équipe travaillant sur le traitement des tâches à partir d'une liste de tâches partagée - chaque personne (consommateur) prend une tâche et y travaille indépendamment.

Quel problème résout un groupe de consommateurs?

Sans groupes de consommateurs, si vous avez plusieurs consommateurs qui lisent le même flux, ils recevront tous les mêmes messages. Ce n'est pas idéal si vous voulez diviser la charge de travail - imaginez trois personnes qui font exactement la même tâche en même temps.

Avec un groupe de consommateurs:

• Chaque message du flux n'est traité qu'une seule fois par un consommateur du groupe.
• Les consommateurs peuvent reconnaître le traitement réussi des messages.
• Si quelque chose ne va pas ou si un consommateur s'écrase, les messages non reconnus peuvent être réaffectés.

Cela rend les groupes de consommateurs parfaits pour construire des systèmes de traitement des messages fiables et évolutifs.

Comment fonctionnent les groupes de consommateurs dans la pratique?

Lorsque vous utilisez un groupe de consommateurs, il y a quelques concepts clés à comprendre:

• Stream : la source des données.
• Groupe : un groupe nommé de consommateurs.
• Consommateur : un processus individuel ou un client qui lit les messages du flux dans le cadre d'un groupe.
• Liste des entrées en attente (PEL) : pistes quels messages ont été livrés au consommateur mais n'ont pas encore été reconnus.

Voici un flux simplifié:

• Un consommateur du groupe lit un message à l'aide de XREADGROUP .
• Le message est marqué comme étant en cours.
• Une fois le consommateur terminé le traitement, il envoie un XACK pour confirmer l'achèvement.
• Si le message n'est pas reconnu dans un certain temps, il peut être livré à un autre consommateur.

Comment créer et utiliser un groupe de consommateurs

Pour commencer par les groupes de consommateurs, vous devez d'abord créer un groupe associé à un flux à l'aide de la commande XGROUP CREATE . Voici comment:

 Xgroup crée mystream mygroup $

Le symbole $ signifie que le groupe commence à lire à partir du dernier message. Si vous souhaitez également traiter tous les messages existants, omettez le $ .

Une fois le groupe existe, un consommateur peut commencer à tirer des messages:

 XreadGroup Group MyGroup Consumer1 Count 1 Streams MyStream>

Cela indique à Redis de donner jusqu'à 1 message non transformé de mystream à consumer1 dans le groupe mygroup .

Après le traitement, le consommateur doit envoyer:

 Xack mystream mygroup <sessage-id>

Cela supprime le message de la liste en attente, disant à Redis qu'il avait été traité avec succès.

Choses à surveiller

Il y a quelques gotchas lorsque vous travaillez avec des groupes de consommateurs:

• Les messages non reconnus restent dans le PEL jusqu'à confirmer. Vous pouvez les vérifier avec XPENDING .
• Les consommateurs peuvent s'écraser , laissant les messages sans rapport. Utilisez XCLAIM pour déplacer ces messages vers un autre consommateur.
• Les noms de consommateurs n'ont pas besoin d'être uniques, mais cela aide à suivre qui fait quoi.
• La rétention des messages dépend de votre cas d'utilisation - Redis ne supprimera pas automatiquement les messages à moins que vous ne définissez une stratégie.

Par exemple, si vous déboguez ou récupérez, cela est utile:

 XPending mystream mygroup

Il montre combien de messages attendent toujours d'être reconnus, ainsi que des détails comme quel consommateur les a et depuis combien de temps ils ont été en attente.

Ainsi, bien que les groupes de consommateurs gèrent la majeure partie de la coordination, vous devez toujours gérer vous-même des remerciements et des tentatives possibles.

Fondamentalement, c'est tout.

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!