如何增加 RabbitMQ(Pika)的 unack 重新投递时间?
How can RabbitMQ's (Pika) unack redelivery time be increased?
如何增加RabbitMQ (Pika) unack 重新投递时间?我们有一个很长的 运行 任务,它花费的时间比默认的重新交付时间更长,因此当它在处理完成后尝试确认时,它会导致 unable to send ack
错误。
我假设您运行正在进入此处完整讨论的频道确认超时 - https://github.com/rabbitmq/rabbitmq-server/pull/2990#issuecomment-1002089576
Long-running 像您这样的任务应该将正在处理的消息发布到另一个代表 in-progress 工作的队列(可能每个工作人员一个队列),然后确认原始消息。工作完成后,消费并确认 in-progress 队列中的消息,以及 re-consume 来自原始队列的消息。
是的,这是更多的工作,但引入通道确认超时是有充分理由的。如果您知道您不会 运行 遇到所描述的问题,您可以 可以 增加 RabbitMQ 配置中的超时。
注意: RabbitMQ 团队监控 rabbitmq-users
mailing list 并且有时只在 Whosebug 上回答问题。
如何增加RabbitMQ (Pika) unack 重新投递时间?我们有一个很长的 运行 任务,它花费的时间比默认的重新交付时间更长,因此当它在处理完成后尝试确认时,它会导致 unable to send ack
错误。
我假设您运行正在进入此处完整讨论的频道确认超时 - https://github.com/rabbitmq/rabbitmq-server/pull/2990#issuecomment-1002089576
Long-running 像您这样的任务应该将正在处理的消息发布到另一个代表 in-progress 工作的队列(可能每个工作人员一个队列),然后确认原始消息。工作完成后,消费并确认 in-progress 队列中的消息,以及 re-consume 来自原始队列的消息。
是的,这是更多的工作,但引入通道确认超时是有充分理由的。如果您知道您不会 运行 遇到所描述的问题,您可以 可以 增加 RabbitMQ 配置中的超时。
注意: RabbitMQ 团队监控 rabbitmq-users
mailing list 并且有时只在 Whosebug 上回答问题。