我正在使用streadway's amqp 库来连接rabbitmq 服务器。 该库提供了一个 channel.Consume() 函数，该函数返回一个“”。 它还提供了一个 channel.Get() 函数，该函数返回“Delivery”等内容。
我必须实现 pop() 功能，并且我正在使用 channel.Get()。但是，documentation 说：
"In almost all cases, using Channel.Consume will be preferred."
这里的首选是指推荐吗？在 channel.Consume() 上使用 channel.Get() 有什么缺点吗？如果是，如何使用 channel.Consume() 来实现 Pop() 函数？
【问题讨论】：
据我从文档中得知，是的，“首选”确实意味着“推荐”。
似乎channel.Get() 没有提供与channel.Consume() 一样多的功能，并且由于它返回Delivery 的chan 而更容易在并发代码中使用，而不是每个单独的@ 987654330@单独。
提到的额外功能是exclusive、noLocal 和noWait，以及可选的参数Table“对队列或服务器具有特定语义”。
要使用channel.Consume() 实现Pop() 函数，您可以链接到amqp example consumer 中的一些代码片段，创建一个channel using the Consume() function，创建一个function to handle the chan of Delivery，它实际上将实现您的Pop() 功能，然后fire off the handle() func in a goroutine。
关键是如果没有接收到，通道（在链接的示例中）将阻止发送。在示例中，handle() 函数使用range 处理整个通道，直到它为空。您的Pop() 功能可能会更好地由一个仅接收来自chan 的最后一个值并返回它的函数来提供。每次运行它都会返回最新的Delivery。
编辑：从通道接收最新值并对其进行处理的示例函数（这可能不适用于您的用例，如果该函数将另一个 Delivery 上的 Delivery 发送到另一个要处理的函数。另外，我没有测试过下面的代码，可能会出错）
func handle(deliveries <-chan amqp.Delivery, done chan error) {
select {
case d = <-deliveries:
// Do stuff with the delivery
// Send any errors down the done chan. for example:
// done <- err
default:
done <- nil
}
}
【讨论】：
这真的取决于你想做什么。如果您只想从队列中获取一条消息（第一条），您可能应该使用 basic.get，如果您打算处理来自队列的所有传入消息 - basic.consume 就是您想要的。
可能不是平台或库特定的问题，而是协议理解问题。
UPD
我对 Go 语言不太熟悉，所以我会尝试为您简要介绍一下 AMQP 的详细信息并描述用例。
您有时可能会遇到麻烦并使用basic.consume 产生开销：
有了basic.consume，你就有了这样的工作流程：
basic.consume方法通知broker你要接收消息
basic.consume-ok 消息basic.deliver消息
有了basic.get，你就有了这样的工作流程：
basic.get给broker
basic.get-ok 方法，它保存消息或basic.empty 方法，表示服务器上没有可用消息的情况关于同步和异步方法的注意事项：同步应该有一些响应，异步是否没有
注意basic.qos 方法prefetch-count 属性：当no-ack 属性设置在basic.consume 或basic.get 上时，它会被忽略。
规范在basic.get 上有一个注释：“此方法使用同步对话提供对队列中消息的直接访问，该同步对话专为同步功能比性能更重要的特定类型的应用程序而设计”，适用于连续消息消费。
我的个人测试表明，在 RabbitMQ 3.0.1 和 Erlang R14B04 上，使用 basic.get (0.38659715652466) 获取 1000 条消息比使用 basic.consume 一条接一条 (0.47398710250854) 获取 1000 条消息要快 15% 以上.
如果您只在主线程中使用一条消息 - 可能您必须使用basic.get。
您仍然可以只异步使用一条消息，例如在单独的线程中或使用某种事件机制。有时这对您的机器资源来说会是更好的解决方案，但您必须注意队列中没有可用消息的情况。
如果你必须一一处理消息，很明显应该使用basic.consume，我认为
【讨论】：