rabbitmq - 从 RabbitMQ 队列中弹出一个元素

Question

我有一个队列，我已经从中塞满了一些 n 元素。

我想从中取出1个元素，然后退出回调。pika示例都使用了回调机制，这在应用程序结构中确实没有意义。

定义回调如下

def callback(...):
  do_data_thinggs(...)
  exit(0)

不起作用，因为消息留在队列中

这样做的惯用语是什么？

Answer 1

你会想看看频道上的 basic_get 方法，看看：

https://github.com/pika/pika/blob/03542ef616a2a849e8bfb0845427f50e741ea0c6/docs/examples/blocking_basic_get.rst例如，这将阻塞直到收到消息。

Answer 2

如果我理解正确，我认为这与您不确认有关。看看这个教程：RabbitMQ 教程 2