RocketMQ 延迟消息实战在电商系统中应用 ​

什么是延迟消息 ​

• Producer 将消息发送到消息队列 RocketMQ 服务端，但并不期望这条消息立马投递，而是推迟到在当前时间点之后的某一个时间投递到 Consumer 进行消费，该消息即定时消息，目前支持固定精度的消息

• 源代码代码: rocketmq - store > MessageStoreConfig.java 属性 messageDelayLevel

消息级别

1s 5s 10s 30s 1m 2m 3m 4m 5m 6m 7m 8m 9m 10m 20m 30m 1h 2h

• 使用message.setDelayTimeLevel(xxx)
  xxx是级别，1表示配置里面的第一个级别，2表示第中二个级别

message.setDelayTimeLevel(3);

• 定时消息:目前 rocketmq 开源版本还不支持，商业版本则有，两者使用场景类似

使用场景 ​

• 通过消息触发一些定时任务，比如在某一固定时间点向用户发送提醒消息
• 消息生产和消费有时间窗口要求：比如在天猫电商交易中超时未支付关闭订单的场景，在订单创建时会发送一条延时消息。这条消息将会在 30 分钟以后投递给消费者，消费者收到此消息后需要判断对应的订单是否已完成支付。如支付未完成，则关闭订单。如已完成支付则忽略