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