RocketMQ延时消息的使用和延时级别的配置

迈不过友情╰ 2022-05-21 13:47 371阅读 0赞

# RocketMQ延时消息的使用和延时级别的配置 #

RocketMQ 支持定时消息，但是不支持任意时间精度，仅支持特定的 level，例如定时 5s， 10s， 1m 等。其中，level=0 级表示不延时，level=1 表示 1 级延时，level=2 表示 2 级延时，以此类推。

# 如何配置 #

在服务器端（rocketmq-broker端）的属性配置文件中加入以下行：

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

描述了各级别与延时时间的对应映射关系。

> 1.  这个配置项配置了从1级开始，各级延时的时间，可以修改这个指定级别的延时时间；
> 2.  时间单位支持：s、m、h、d，分别表示秒、分、时、天；
> 3.  默认值就是上面声明的，可手工调整；
> 4.  默认值已够用，不建议修改这个值。

# 如何发送延时消息 #

发送延时消息只需要在客户端（rocketmq-client端）待发送的消息（ com.alibaba.rocketmq.common.message.Message ）中设置延时级别即可。

“设置消息延时 10s 消费”的 Producer 端代码如下：

<table> 
 <tbody> 
  <tr> 
   <td> 
    <div>
      1 
    </div> 
    <div>
      2 
    </div> 
    <div>
      3 
    </div> 
    <div>
      4 
    </div> 
    <div>
      5 
    </div></td> 
   <td> 
    <div>
      Message msg = new Message(topic, tags, keys, body); 
    </div> 
    <div>
      msg.setDelayTimeLevel(3); 
    </div> 
    <div>
      ... 
    </div> 
    <div>
      SendResult sendResult = getMQProducer().send(msg); 
    </div> 
    <div>
      ... 
    </div></td> 
  </tr> 
 </tbody> 
</table>

其中 Message 是 com.alibaba.rocketmq.common.message.Message 。

发表评论取消回复

表情：

评论列表（有 0 条评论，371人围观）

还没有评论，来说两句吧...

相关阅读

相关 RocketMQ延时消息实现

可以看到，延迟消息成功被消息，并且我们注意到，消息被Consumer消费的时间【Thu Feb 24 11:30:09 CST 2022】 - 消息存储时间【Thu Fe...

迷南。/ 2024年05月23日 22:25/ 0 赞/ 108 阅读

相关 SpringBoot集成RocketMQ使用延时消息与消息过滤

1.首先了解一下什么是延时消息延时消息用来指定消息发送到消息队列(RocketMQ)的服务端后，延时一段时间之后才被投递到客户端进行消费(例如半分钟之后)，适用于解决一

我会带着你远行/ 2024年03月31日 13:17/ 0 赞/ 108 阅读

相关延时消息队列

目录前言一、延时队列实用场景二、DelayQueue DelayQueue的实现使用延迟队列 DelayQueue实现延时任务的优缺点三、

Myth丶恋晨/ 2024年03月26日 22:39/ 0 赞/ 108 阅读

相关 RocketMQ延时消息使用

RocketMQ延时消息使用生产者实例 @Component public class DelayProducer {

╰半夏微凉°/ 2024年03月22日 18:24/ 0 赞/ 89 阅读

相关 Java延时消息的实现

前言在实际的开发中，我们经常需要实现延时消息的功能。比如，我们需要在一定时间后执行某个任务，或者需要在某个时间点触发某个事件。在Java语言中，我们可以通过多种方式来实

布满荆棘的人生/ 2024年03月16日 12:10/ 0 赞/ 83 阅读

相关源码剖析RocketMQ延时消息原理

一、前言 RocketMQ版本4.8.0，本文中相关源码注释见GitHub中：[RocketMQ：release-4.8.0][RocketMQ_release-4.8.

Myth丶恋晨/ 2023年10月01日 16:08/ 0 赞/ 47 阅读

相关 RocketMQ：延时消息

<dependency> <groupId>org.apache.rocketmq</groupId> <artifactId>ro

曾经终败给现在/ 2023年06月26日 10:59/ 0 赞/ 40 阅读

相关 RocketMQ进阶-延时消息

前言在开发中经常会遇到延时任务的需求，例如在12306购买车票，若生成订单30分钟未支付则自动取消；还有在线商城完成订单后48小时不评价，自动5星好评。像

水深无声/ 2023年02月10日 13:28/ 0 赞/ 69 阅读

相关 RocketMQ延时消息的使用和延时级别的配置

RocketMQ延时消息的使用和延时级别的配置 RocketMQ 支持定时消息，但是不支持任意时间精度，仅支持特定的 level，例如定时 5s， 10s， 1m 等。其

迈不过友情╰/ 2022年05月21日 13:47/ 0 赞/ 372 阅读

相关 RocketMQ原理学习--延时消息实现原理

RocketMQ提供了延时消息类型，简单来说就是生产者在发送消息的时候指定一个延时时间，当到达延时时间之后消息才能够被投送到消费者。首先我们可

阳光穿透心脏的1/2处/ 2022年04月05日 17:26/ 0 赞/ 294 阅读