其他分享
首页 > 其他分享> > RocketMQ延时消息

RocketMQ延时消息

作者:互联网

适用场景

适用于定时向用户发送提醒信息,订单超时自动关闭等

使用方法

RocketMQ延时消息就是生产端发送时,可以为消息指定一个延迟级别的消息属性,指定该条消息在指定时间后才能被消费端收到

public void setDelayTimeLevel(int level) {
    this.putProperty(MessageConst.PROPERTY_DELAY_TIME_LEVEL, String.valueOf(level));
}

默认有18个延迟级别,1~18,对应时间如下

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

延迟级别是可配的,在broker配置文件中增加一条

messageDelayLevel=1s 5s 10s 30s 1m 2m 3m 4m 5m 6m 7m 8m 9m 10m 20m 30m 1h 2h 90s
msg.setDelayTimeLevel(19);

如上图发送,消息将在90s后投递

标签:9m,10m,7m,30s,消息,延时,RocketMQ,延迟
来源: https://blog.csdn.net/baidu_32223873/article/details/115115206