Go でデッド RabbitMQ 接続を検出して処理する方法?

Go でのデッド RabbitMQ 接続の検出と処理

提供された RabbitMQ コンシューマ スクリプトでは、RabbitMQ サーバーの操作が中断されるとスクリプトが実行されたままになります。しかしメッセージには無反応。これに対処するには、切断された接続を検出し、再接続するかスクリプトを終了することが重要です。

基盤となるライブラリである streadway/amqp が解決策を提供します。 amqp.Connection タイプには、チャネル シグナリング トランスポート エラーまたはプロトコル エラーを返す NotifyClose() メソッドがあります。このチャネルを使用すると、接続エラーを検出できます。

接続エラー処理を組み込んだスクリプトの更新バージョンは次のとおりです。

import (
    "log"

    "github.com/streadway/amqp"
)

func main() {
    // Connection loop
    for {
        conn, err := amqp.Dial("amqp://guest:guest@localhost:5672/")
        if err != nil {
            log.Printf("Failed to connect to RabbitMQ: %v", err)
            continue
        }

        notify := conn.NotifyClose(make(chan *amqp.Error))

        ch, err := conn.Channel()
        if err != nil {
            log.Printf("Failed to open a channel: %v", err)
            continue
        }

        q, err := ch.QueueDeclare(
            "test_task_queue",
            true,
            false,
            false,
            false,
            nil,
        )
        if err != nil {
            log.Printf("Failed to declare a queue: %v", err)
            continue
        }

        err = ch.Qos(
            1,
            0,
            false,
        )
        if err != nil {
            log.Printf("Failed to set QoS: %v", err)
            continue
        }

        msgs, err := ch.Consume(
            q.Name,
            "",
            false,
            false,
            false,
            false,
            nil,
        )
        if err != nil {
            log.Printf("Failed to register a consumer: %v", err)
            continue
        }

        // Message receive loop
        for {
            select {
            case err := <p>この改訂されたスクリプトでは、接続ループは他の操作。メッセージ受信ループ内で、select ステートメントはエラー チャネルと受信メッセージの両方をチェックします。接続エラーが検出された場合、エラーをログに記録し、再接続をトリガーします。このメカニズムにより、スクリプトは一時的な接続の問題から回復し、通常の動作を再開できるようになります。</p>

以上がGo でデッド RabbitMQ 接続を検出して処理する方法?の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。