djangocelery redis 消息unack 的异常出现场景

    xiaoxiao2022-07-04  105

     

    如若处理过程中出现异常,而没有回复ack 应答。通过后台就会看到有 unacked 的数据。

    如果积压的多会导致程序无法继续消费数据(数量和消费者的线程数有关)。 解决办法 针对异常 做处理,捕捉到后 也回复ack应答。

    程序断开于redis的链接后 unacked的消息状态会重新变为ready 等待消费。 代码更新后,server应用连接redis 就会重新消费掉消息。

     

    最新回复(0)