springBoot整合rabbitMQ --实现延时消息功能

最近一直在考虑订单延时取消的功能,之前一直用的定时任务,那么有没有更好的实现方式呢?rabbitMQ 的延时消息实现则是一个很好的选择。
电商项目中针对延时这种场景有很多,比如:

  • 订单业务:在电商中,用户下单后30分钟后未付款则取消订单。
  • 下单业务:用户下单并付款后,1分钟后发短信给用户。
  • 注册业务:比如新用户注册完,5天后给予短信提醒,增加系统活跃量。

要知道rabbitMQ是AMQP协议支持的,但是他们并没有实现延时队列功能。但是我们可以通过rabbitMQ 的高级特性TTL+DLX来实现。

一、何为TTL?

TTL 全称 Time To Live(存活时间/过期时间)
当消息到达存活时间后,还没有被消费,会被自动清除。
RabbitMQ可以对消息设置过期时间,也可以对整个队列(Queue)设置过期时间。

二、何为死信队列?

死信队列,英文缩写:DLX 。Dead Letter Exchange(死信交换机),当消息成为Dead message后,可以被重新发送到另一个交换机,这个交换机就是DLX。

三、实践

拿下单未付款取消订单的功能来举例:
springBoot整合rabbitMQ --实现延时消息功能

上一篇:串口服务器厂家哪家好


下一篇:Redlock(redis分布式锁)原理分析