githubEdit

1. 延迟队列介绍

延迟队列是一种特殊的队列,允许消息或任务在指定的时间间隔后才被处理,在许多业务场景中具有广泛的应用价值。比如说,在电商场景中,如果用户下单后在指定时间内未完成支付,系统可以自动取消订单。在分布式系统中,延迟队列还可以用于定时任务的调度,例如每天定时清理日志文件、每周自动备份数据等。

Pulsar延时消息功能允许生产者指定一个延迟时间,经过一段时间后broker才会分发消息给消费者,而不是消息发布后就马上可以消费到。

这里需要区分的是,如果业务希望由消费端指定延迟时间,即消费端延迟队列功能,那么可以使用Pulsar的否定确认Negative Acknowledge或者重试队列功能来实现,这将会在后面文章中进行介绍。

下面说的延迟队列,专指生产端延迟队列,不再赘述,大部分消息队列中间件里所介绍的延迟队列指的也是生产端的延迟队列。

Last updated

Was this helpful?