Golang的代码如何解决RabbitMQ永远被屏蔽的问题？

我在使用rabbitmq时发现一段有趣的代码

forever := make(chan bool)

    go func() {
        for d := range msgs {
    
            log.Printf("Received a message: %s", d.Body)

        }
    }()

    log.Printf(" [*] Waiting for messages. To exit press CTRL+C")
    <-forever

这是一段代码， 事实上，在正常模式下， 这会导致死锁错误， 像这样 在此输入图像描述 在此输入图像描述

但是当我导入rabbitmq包时，这段代码不会导致错误 在此输入图像描述 这是为什么？我很困惑。 感谢您的回答！

期待有人解释

正确答案

当您使用rabbitmq时，msgs变量是<-chan amqp.delivery类型的接收通道 - 查看文档，即通道接收消息。每次出现消息时，范围循环都会进入正文。这是一个有用的控制序列——在工作线程等待和处理消息时阻塞主 goroutine。在这种情况下不存在死锁，因为rabbitmq连接将在适当的时候沿着msgs chan发送消息。

在早期的代码中，当您连接到队列并实例化 msgs 通道时，amqp 包会在后台创建另一个 goroutine，以沿着 msgs 通道发送消息。

msgs, err := ch.Consume(
  q.Name, // queue
  "",     // consumer
  true,   // auto-ack
  false,  // exclusive
  false,  // no-local
  false,  // no-wait
  nil,    // args
)

这与提供的死锁示例不同，其中没有额外的 go 例程来沿着 forever 通道发送消息。 goroutine 进入睡眠状态，没有机会被唤醒。这是一个僵局。