RabbitMQ"Zombie"消费者

Max*_*Max 7 tcp amqp rabbitmq

我在EC2上使用spot实例来从RabbitMQ队列中使用.每项工作都需要几秒钟,并且需要手动"确认".

实例终止时出现问题.现在没有时间彻底关闭AMQP消费者了,所以我仍然认为RabbitMQ服务器仍然认为死去的消费者仍然存在.它不会重新提供他们的工作,它仍然会为他们提供新工作.

如何让RabbitMQ自动超时僵尸消费者并将其从工作池中删除?

tim*_*ath 6

我建议在RabbitMQ连接上设置Heartbeat属性.如果心跳停止,RabbitMQ最终将切断连接并将未打包的消息放回队列中.