【发布时间】:2015-12-13 03:40:14
【问题描述】:
我使用 pika for python 与 RabbitMQ 进行通信。我有 6 个线程,它们使用和确认来自同一个队列的消息。我为每个线程使用不同的连接(和通道)。所以我有几个非常接近的问题:
如果与 rabbit 的连接将在 1 个线程中关闭,并且我将重新连接,则交付标签值将重置,重新连接后将从 0 开始?
重新连接后,我将以相同的顺序为每个线程接收相同的未确认消息,或者它将开始在所有线程之间再次分发它们,或者它将从重新连接点开始?
这在我的应用程序中很重要,因为在消息接收和确认之间存在延迟,我希望避免在接下来的流程步骤中重复。
【问题讨论】: