celery 结合 rabbitmq 使用时，celery 消费者执行时间太久发送 ack 消息失败
celery 5.3.6 结合 rabbitmq 使用时，celery 消费者执行时间超过 30 分钟，执行完成后向 rabbitmq 发起确认消费完成的 ack 消息时，提示 Connection reset by peer，rabbitmq 客户端连接已经断开了，这会导致同一个执行时间比较久的任务不断重复消费而且每次都无法成功发送 ack 消息。
这种情况下，添加对执行结果的 redis 缓存，每次执行消费任务时先检查结果是否已经存在（由唯一键来确定是同一个任务），每次执行完消费任务将结果添加进 redis 缓存再发送 ack 消息，这样来避开同一个执行时间比较久的任务不断重复消费。
原文地址：https://blog.csdn.net/npk191954/article/details/142413667
免责声明：本站文章内容转载自网络资源，如本站内容侵犯了原著者的合法权益，可联系本站删除。更多内容请关注自学内容网（zxcms.com）！