天翼云分布式消息服务RocketMQ-延时消息
文档简介:
延时消息:Producer 将消息发送到消息队列MQ服务端,设计消费时延,消息发送到服务端后,过了预设的时间后才可以被消费者消费。发送延时消息时需要设定一个延时时间长度,消息将从当前发送时间点开始延迟固定时间之后才开始投递。
延时消息:Producer 将消息发送到消息队列MQ服务端,设计消费时延,消息发送到服务端后,过了预设的时间后才可以被消费者消费。发送延时消息时需要设定一个延时时间长度,消息将从当前发送时间点开始延迟固定时间之后才开始投递。
目前RocketMQ只支持特定级别的延时,16个级别的延时。需要在发送消息时设置延时级别,如:
//mq默认的16个等级:messageDelayLevel:1s 5s 10s 30s 1m 2m 3m 4m 5m 6m 7m 8m 9m //10m
//20m 30m 1h 2h
message.setDelayTimeLevel(5);