抖音怎么开通小程序推广_房屋装修设计师培训_企业管理培训公司排行榜_宁波优化seo软件公司

celery 5.3.6 结合 rabbitmq 使用时，celery 消费者执行时间超过 30 分钟，执行完成后向 rabbitmq 发起确认消费完成的 ack 消息时，提示 Connection reset by peer，rabbitmq 客户端连接已经断开了，这会导致同一个执行时间比较久的任务不断重复消费而且每次都无法成功发送 ack 消息。

这种情况下，添加对执行结果的 redis 缓存，每次执行消费任务时先检查结果是否已经存在（由唯一键来确定是同一个任务），每次执行完消费任务将结果添加进 redis 缓存再发送 ack 消息，这样来避开同一个执行时间比较久的任务不断重复消费。