Comment les scripts Go peuvent-ils détecter et récupérer des blocages RabbitMQ ?

Enquête sur la détection des blocages RABBITMQ dans les scripts Go

Un utilisateur a rencontré un problème où un script consommateur Go utilisant la bibliothèque streadway/amqp ne répondait pas Arrêt du serveur RabbitMQ et les messages sont restés non livrés au redémarrage du serveur. Cela soulève la question : comment pouvons-nous détecter une connexion consommateur morte et reconnecter ou mettre fin au script consommateur ?

Pour déchiffrer cela, nous approfondissons le mécanisme de battement de cœur de la bibliothèque. L'intervalle de battement de coeur est défini sur 10 secondes par défaut. Cependant, cette fonctionnalité de battement de cœur n'est pas exposée dans l'API, ce qui la rend indisponible pour une utilisation explicite.

Au lieu de cela, l'approche recommandée consiste à utiliser la méthode NotifyClose() d'amqp.Connection, qui renvoie un transport de signalisation de canal ou erreurs de protocole. En créant une boucle pour se reconnecter en permanence, nous pouvons garantir que notre consommateur reste actif et réactif aux changements de serveur.

Un exemple de mise en œuvre de cette approche est le suivant :

for {
    // Establish the connection
    conn, err := amqp.Dial("amqp://guest:guest@localhost:5672/")
    if err != nil {
        // Handle the error and retry
    }

    // Register for connection closure notifications
    notify := conn.NotifyClose(make(chan *amqp.Error))

    // Create a channel and consumer
    ch, err := conn.Channel()
    if err != nil {
        // Handle the error
    }
    msgs, err := ch.Consume(...)

    for {
        select {
        case err := <-notify:
            // Handle the connection error and reconnect
        case d := <-msgs:
            // Process the message
        }
    }
}

En incorporant ceci Mécanisme de gestion des erreurs, notre script consommateur peut gérer gracieusement les interruptions de connexion et assurer la livraison continue des messages même dans des environnements de serveur dynamiques.

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!