我可以防止 amqp.Channel 因错误而关闭吗？

亲爱的编程学习爱好者，如果你点开了这篇文章，说明你对《我可以防止 amqp.Channel 因错误而关闭吗？》很感兴趣。本篇文章就来给大家详细解析一下，主要介绍一下，希望所有认真读完的童鞋们，都有实质性的提高。

我尝试在 go 中的单个通道上创建多个 amqp 队列消费者。

我面临的问题是，当创建多个消费者时，如果第一个失败，通道会立即关闭，从而阻止进一步的操作。

有办法避免这种情况还是我必须重新创建频道？

示例

假设队列“client-a”不存在，这将导致在为“client-b”创建队列消费者时出错，因为此时通道已关闭。错误将是 exception (504) 原因：“通道/连接未打开”

package main

import (
    "github.com/streadway/amqp"
    "log"
)

func check(err error) {
    if err != nil {
        panic(err)
    }
}

func TestChannelProblems() {
    // Setup AMQP stuff
    connection, err := amqp.Dial("amqp://guest:guest@localhost:5672/")
    check(err)
    log.Println("Queue connection ok")

    channel, err := connection.Channel()
    check(err)
    log.Println("Queue channel ok")

    queuesToConnectTo := []string{"client-a", "client-b"}

    for i, _ := range queuesToConnectTo {
        queueName := queuesToConnectTo[i]

        _, err := channel.Consume(queueName, "", false, false, false, false, nil)
        if err != nil {
            log.Printf("Connecting to queue %v failed: %v", queueName, err.Error())
        }

        // ... Here would be the logic to use the return value of channel.Consume
    }
}

解决方案

长话短说：在 amqp（或至少 rabbitmq）中，因协议异常而关闭通道是正常行为，并且必须由应用程序处理。

来源：https://www.rabbitmq.com/channels.html#error-handling

一般不建议这样做。如果您的一个消费者遇到错误，它也会关闭另外两个。您应该为每个消费者打开一个渠道。尽管打开通道的成本相对较高，但由于它是网络往返，因此在实践中这不太可能成为问题。

您必须重新创建频道。如果连接上发生任何错误，库 streadway/amqp 无论如何都会关闭传递通道（通道 = go 类型 <-chan amqp.delivery）。

您可以查看 this thread，了解有关如何处理 amqp 错误并可能恢复它们的详细信息。本质上，您使用 NotifyClose 来监听关闭事件：

// c is an *amqp.Channel
errC := c.NotifyClose(make(chan *amqp.Error, 10))
go func() {
    for err := range errC {
        if err != nil {
            // error-handling
        }
    }
}()

好了，本文到此结束，带大家了解了《我可以防止 amqp.Channel 因错误而关闭吗？》，希望本文对你有所帮助！关注golang学习网公众号，给大家分享更多Golang知识！