How to Gracefully Handle Dead RabbitMQ Connections in Go?-Golang-php.cn

How to Gracefully Handle Dead RabbitMQ Connections in Go?

Linda Hamilton

Release： 2024-12-10 06:48:12

Original

434 people have browsed it

How to Gracefully Handle Dead RabbitMQ Connections in Go?

Detecting Dead RabbitMQ Connections in Go

In this scenario, a consumer script written in Go using the streadway/amqp library fails to exit when the RabbitMQ server is stopped. Additionally, the consumer stops receiving messages once the server is restarted.

Solution: Using Connection Notification

The amqp.Connection type has a NotifyClose() method that provides a channel for signaling transport or protocol errors. By using this method, we can handle connection drop events and gracefully handle them.

The following code snippet demonstrates how to use connection notification to detect dead connections and perform necessary actions:

import (
    "log"
    "time"

    "github.com/streadway/amqp"
)

func main() {
    for {  // Reconnection loop
        conn, err := amqp.Dial("amqp://guest:guest@localhost:5672/") // Setup
        if err != nil {
            log.Fatal(err)
        }
        notify := conn.NotifyClose(make(chan *amqp.Error)) // Error channel

        ch, err := conn.Channel()
        if err != nil {
            log.Fatal(err)
        }
        msgs, err := ch.Consume(
            "test_task_queue", // Queue
            "",     // Consumer
            false,  // Auto-ack
            false,  // Exclusive
            false,  // No-local
            false,  // No-wait
            nil,    // Args
        )
        if err != nil {
            log.Fatal(err)
        }

        for {  // Receive loop
            select {  // Check connection
            case err = <-notify:
                // Work with error
                log.Println(err)
                break // Reconnect
            case d := <-msgs:
                // Work with message
                log.Printf("Received a message: %s", d.Body)
                d.Ack(false)
                dotCount := bytes.Count(d.Body, []byte("."))
                t := time.Duration(dotCount)
                time.Sleep(t * time.Second)
                log.Printf("Done")
            }
        }
    }
}

Copy after login

In this modified script, we have wrapped the main consumer logic within a loop that continuously checks for connection closure using the notify channel. If an error is received, it logs the error, and the process reconnects.

By utilizing connection notifications, we can detect dead RabbitMQ connections and take appropriate actions, such as reconnecting, logging errors, or terminating the script.

The above is the detailed content of How to Gracefully Handle Dead RabbitMQ Connections in Go?. For more information, please follow other related articles on the PHP Chinese website!