如若处理过程中出现异常,而没有回复ack 应答。通过后台就会看到有 unacked 的数据。
如果积压的多会导致程序无法继续消费数据(数量和消费者的线程数有关)。 解决办法 针对异常 做处理,捕捉到后 也回复ack应答。
程序断开于redis的链接后 unacked的消息状态会重新变为ready 等待消费。 代码更新后,server应用连接redis 就会重新消费掉消息。