ApsaraMQ for RocketMQ:Message filtering

Règles relatives aux tags

• Chaque message ne peut avoir qu'un seul tag.

• Un tag est une chaîne sensible à la casse. Par exemple, TagA et tagA sont des tags différents.

• Limitez la longueur des tags à moins de 128 caractères.

Syntaxe de l'expression de filtre

Cas d'utilisation : routage des transactions e-commerce

Une plateforme e-commerce envoie des messages de commande, de paiement et de logistique vers un seul topic Trade_Topic. Différents systèmes en aval s'abonnent avec des filtres de tags différents :

Exemple de code

Définissez un tag côté producteur :

Message message = messageBuilder.setTopic("topic")
                .setKeys("messageKey")
                .setTag("TagA")
                .setBody("messageBody".getBytes())
                .build();

Abonnez-vous aux messages avec un seul tag :

String topic = "Your Topic";
FilterExpression filterExpression = new FilterExpression("TagA", FilterExpressionType.TAG);
pushConsumer.subscribe(topic, filterExpression);

Abonnez-vous aux messages correspondant à plusieurs tags :

String topic = "Your Topic";
FilterExpression filterExpression = new FilterExpression("TagA||TagB||TagC", FilterExpressionType.TAG);
pushConsumer.subscribe(topic, filterExpression);

Abonnez-vous à tous les messages du topic :

String topic = "Your Topic";
FilterExpression filterExpression = new FilterExpression("*", FilterExpressionType.TAG);
pushConsumer.subscribe(topic, filterExpression);

Règles relatives aux attributs

• Chaque message peut comporter plusieurs attributs personnalisés. Chaque attribut est une paire clé-valeur.

• Les clés d'attribut doivent commencer par une lettre ou un trait de soulignement (_) et ne peuvent contenir que des lettres, des chiffres et des traits de soulignement.

Référence de la syntaxe SQL-92

Rédigez les expressions de filtre à l'aide des opérateurs SQL-92 suivants :

Contraintes sur les valeurs numériques :

• Les valeurs numériques sont des entiers 32 bits, allant de -2 147 483 648 à 2 147 483 647.

• Les chaînes convertibles en nombres sont traitées comme des valeurs numériques.

Gestion des cas limites par le broker

Si une expression de filtre ne peut pas être évaluée correctement, le broker supprime le message au lieu de le livrer. Cela s'applique à trois situations :

Cas d'utilisation : filtrage des messages logistiques par région

Une plateforme e-commerce envoie des messages de commande et logistiques vers Trade_Topic. Les messages logistiques contiennent un attribut Region avec des valeurs telles que Hangzhou ou Shanghai.

Exemple de code

Définissez un tag et des attributs personnalisés côté producteur :

Message message = messageBuilder.setTopic("topic")
                .setKeys("messageKey")
                .setTag("messageTag")
                // Custom attribute: region
                .addProperty("Region", "Hangzhou")
                .setBody("messageBody".getBytes())
                .build();

Abonnez-vous aux messages correspondant à un seul attribut :

String topic = "topic";
FilterExpression filterExpression = new FilterExpression(
    "Region IS NOT NULL AND Region='Hangzhou'", FilterExpressionType.SQL92);
simpleConsumer.subscribe(topic, filterExpression);

Abonnez-vous aux messages correspondant à plusieurs attributs :

String topic = "topic";
FilterExpression filterExpression = new FilterExpression(
    "Region IS NOT NULL AND price IS NOT NULL AND Region = 'Hangzhou' AND price > 30",
    FilterExpressionType.SQL92);
simpleConsumer.subscribe(topic, filterExpression);

Abonnez-vous à tous les messages du topic :

String topic = "topic";
FilterExpression filterExpression = new FilterExpression("True", FilterExpressionType.SQL92);
simpleConsumer.subscribe(topic, filterExpression);

Pourquoi les consommateurs d'un même groupe perdent-ils des messages lorsqu'ils s'abonnent à des tags différents ?

Tous les consommateurs d'un groupe de consommateurs doivent utiliser la même expression de filtre. Si le consommateur A s'abonne à TagA tandis que le consommateur B s'abonne à TagB, une incohérence d'abonnement se produit et des messages sont perdus. Alignez les expressions de filtre sur tous les consommateurs du groupe ou répartissez-les dans des groupes de consommateurs distincts.

Comment le nombre de messages consommés est-il calculé lorsque le filtrage est actif ?

Seuls les messages validant l'expression de filtre sont comptabilisés dans la consommation. Les messages filtrés sont exclus du décompte.

Pourquoi des messages s'accumulent-ils alors que les consommateurs affichent une consommation nulle ?

Les messages ne correspondant pas au filtre actif existent toujours dans le topic et sont pris en compte dans le backlog. Ce comportement est attendu. Consultez la section Calcul des messages accumulés pour obtenir les formules exactes.