Lightweight Message Queue (anciennement MNS) propose une solution de traçage de bout en bout qui suit les messages tout au long de leur cycle de vie et vous aide à diagnostiquer les problèmes dans les systèmes de messagerie distribués.
Présentation
Dans les systèmes distribués, une seule requête traverse souvent plusieurs services. Les files d'attente de messages gèrent la communication asynchrone, notamment l'écrêtage des pics de charge et le découplage des applications. Lorsque les messages circulent entre les producteurs, la file d'attente et les consommateurs, toute défaillance peut entraîner une perte de messages, des retards ou une consommation en double, ce qui complexifie l'analyse des causes profondes.
La solution de traçage de bout en bout de Lightweight Message Queue (anciennement MNS) enregistre le chemin de transmission complet d'un message tout au long de son cycle de vie et fournit des journaux détaillés ainsi que des métriques de performance. Ingestez les données de trace conformes à OpenTelemetry dans Alibaba Cloud Tracing Analysis pour diagnostiquer rapidement les anomalies.
Fonctionnalités principales
Audit de production et de consommation : Enregistrement des détails des opérations, du temps d'exécution et de l'état des résultats.
Requête conditionnelle : Localisation rapide des problèmes grâce à des filtres tels que l'ID du message, le nom de la file d'attente et la plage de temps.
Intégration normalisée : Respect de la norme OpenTelemetry et intégration transparente aux données de traçage des applications.
Détection des anomalies : Détection et marquage automatiques des traces anormales pour accélérer le diagnostic des pannes.
Définition de la trace
Le traçage de Lightweight Message Queue suit la spécification OpenTelemetry Messaging Spans et l'étend avec des attributs spécifiques aux files d'attente de messages.
Attributs génériques des spans de messagerie
Lightweight Message Queue prend en charge les attributs génériques des spans de messagerie définis dans la norme OpenTelemetry. Pour plus de détails, consultez la spécification OpenTelemetry Messaging Spans.
Ces attributs incluent les éléments suivants :
messaging.system: Identifiant du système de messagerie.messaging.operation.name: Nom de l'opération.messaging.operation.type: Type de l'opération.messaging.destination.name: Nom de la file d'attente ou du sujet de destination.messaging.message.id: ID du message.error.type: Type d'erreur (en cas d'échec de l'opération).
Attributs spécifiques à Lightweight Message Queue
En plus des attributs standard, Lightweight Message Queue fournit les attributs de span suivants :
|**Nom de l'attribut**
|
**Type**
|
**Description**
|
**Valeur d'exemple**
|
**Niveau d'exigence**
| | --- | --- | --- | --- | --- | |
`messaging.smq.operation`
|
string
|
Nom de la méthode d'opération spécifique de Lightweight Message Queue.
|
SendMessage, ReceiveMessage, PublishMessage
|
Obligatoire
| |
`messaging.smq.request_id`
|
string
|
ID unique de la requête.
|
6733433D43444218004FAED2
|
Obligatoire
| |
`messaging.smq.message_tag`
|
string
|
Tag de message pour les messages publiés sur un sujet.
|
order, payment
|
Facultatif
| |
`messaging.smq.next_visible_time`
|
int
|
Horodatage UNIX (en secondes) indiquant quand le message redevient visible.
|
1731413593
|
Facultatif
| |
`messaging.smq.receipt_handle.in_response`
|
string
|
Handle de réception renvoyé lors de la réception d'un message.
|
8-oMWXHzxBZlgIlzuz8ztxz0z8MHzcT8Z3Zsy3y0
|
Facultatif
| |
`messaging.smq.receipt_handle.in_request`
|
string
|
Handle de réception utilisé pour supprimer ou modifier un message.
|
8-oMWXHzxBZlgIlzuz8ztxz0z8MHzcT8Z3Zsy3y0
|
Facultatif
| |
`messaging.smq.subscription.type`
|
string
|
Type d'abonnement.
|
HTTP, HTTPS, QUEUE
|
Facultatif
|
Détails des valeurs d'attribut
Les valeurs suivantes sont prises en charge pour messaging.smq.operation :
SendMessage: Envoyer un message de file d'attente.BatchSendMessage: Envoyer des messages de file d'attente par lots.ReceiveMessage: Recevoir un message de file d'attente.BatchReceiveMessage: Recevoir des messages de file d'attente par lots.DeleteMessage: Supprimer un message de file d'attente.BatchDeleteMessage: Supprimer des messages de file d'attente par lots.ChangeMessageVisibility: Modifier le délai d'expiration de visibilité d'un message.PeekMessage: Consulter un message de file d'attente sans le supprimer.BatchPeekMessage: Consulter des messages de file d'attente par lots sans les supprimer.PublishMessage: Publier un message sur un sujet.ConsumeMessage: Consommer un message abonné.AckMessage: Confirmer la consommation du message.Notify: Pousser une notification.
Les valeurs suivantes sont prises en charge pour messaging.smq.subscription.type :
HTTP: Abonnement à un endpoint HTTP.HTTPS: Abonnement à un endpoint HTTPS.QUEUE: Abonnement à une file d'attente.
Limites
Seul le client Java SDK (version 1.3.0 ou ultérieure) prend en charge l'envoi des données de trace à Tracing Analysis. Pour plus d'informations sur les versions du SDK, consultez Historique des versions.
Options d'ingestion des données de trace
Intégrez Lightweight Message Queue à Application Real-Time Monitoring Service (ARMS) pour une collecte, un stockage et une analyse unifiés des données de trace. Pour plus d'informations, consultez Qu'est-ce que la surveillance des applications ?.
Intégration avec la surveillance des applications ARMS
Pour obtenir des instructions détaillées, consultez Intégration d'une application.