RocketMq 延时队列以及自定义实现的思路

RocketMq 延时队列

延时队列 先说一下，基本的概念，什么是延时队列，实际的业务场景就是，一个人下订单后多久没有支付，然后取消订单，这个多久就是延时，这个逻辑可以用延时队列实现。 2. RocketMq 延时队列 首先，RocketMq本身提供，几类的延时队列， 详细可以看源码 org.apache.rocketmq.store.config.MessageStoreConfig

private String messageDelayLevel = "1s 5s 10s 30s 1m 2m 3m 4m 5m 6m 7m 8m 9m 10m 20m 30m 1h 2h";

定义了这么多的类型，那RocketMq是怎么操作的，TopicValidator在这个地方有定义了个，对应不同级别的延时队列， org.apache.rocketmq.common.topic.TopicValidator p

RocketMq 延时队列以及自定义实现的思路最先出现在Python成神之路。