V2EX = way to explore
V2EX 是一个关于分享和探索的地方
现在注册
已注册用户请  登录
dyc87112
V2EX  ›  程序员

RabbitMQ 延迟消息的延迟极限是多少?

  •  
  •   dyc87112 ·
    dyc87112 · 2019-07-23 14:05:44 +08:00 · 2555 次点击
    这是一个创建于 1711 天前的主题,其中的信息可能已经有所发展或是发生改变。

    之前在写 Spring Cloud Stream 专题内容的时候,特地介绍了一下如何使用 RabbitMQ 的延迟消息来实现定时任务。最近正好因为开发碰到了使用过程中发现,延迟消息没有效果,消息直接就被消费了的情况。因此就继续深入研究了一下问题原因,在此记录下来,给碰到类似问题的童鞋们参考。

    问题定位

    因为不是所有的消息都出现了没有延迟消息效果的因素,通过有问题的消息特征,大致猜测可能是延迟时间过长导致了消息延迟失败。为了验证这个原因,先拿之前文章中的例子,来测试一下延迟时间是否与问题直接相关。

    对之前的延迟消息使用样例(文末的 Git 仓库中可以获取完整代码)接口做一下微改,增加了一个请求参数delay来控制延迟时间:

    @GetMapping("/sendMessage")
    public String messageWithMQ(@RequestParam String message, @RequestParam Long delay) {
        log.info("Send: " + message);
        testTopic.output().send(MessageBuilder.withPayload(message).setHeader("x-delay", delay).build());
        return "ok";
    }
    

    然后尝试发起了两个请求:

    请求 1:延迟 5000 毫秒。消息发送到 MQ 之后确实延迟了 5 秒之后才得到了消费,没有任何问题。

    curl localhost:8080/sendMessage?message=hello&delay=5000
    

    请求 2:延迟 1 年( 31536000000 毫秒)。消息发送到 MQ 之后马上就被消费者消费了,完全没有延迟效果。

    curl localhost:8080/sendMessage?message=hello&delay=31536000000
    

    问题小结

    在明确了问题原因之后,需要对该功能的时候做一些明确的限定(延迟时间的极限),以避免再次出现类似的问题。深入探索下去,这里的失败主要与消息的过期时间( TTL )有直接的关系。在 RabbitMQ 中,消息的过期时间必须是非负 32 位整数,即:0 <= n <= 2^32-1,以毫秒为单位。 其中,2^32-1 = 4294967295。

    这里我们可以尝试下面两个请求,分别设置延迟时间为 4294967295 何 4294967296:

    curl localhost:8080/sendMessage?message=hello&delay=4294967295
    curl localhost:8080/sendMessage?message=hello&delay=4294967296
    

    可以发现,当延迟时间为 4294967295 毫秒的时候,延迟消息工作正常;当延迟时间为 4294967296 毫秒的时候,消息被直接消费,没有延迟效果。

    所以,我们在使用 RabbitMQ 的延迟消息功能时候,必须注意它的延迟极限是 4294967295 毫秒。如果你的业务需求会超过这个临界值,就必须避开这个坑,采用其他方法来实现需要延迟或者定时执行的任务了。

    代码示例

    本文示例读者可以通过查看下面仓库的中的 stream-delayed-message 项目:

    如果您对这些感兴趣,欢迎 star、follow、收藏、转发给予支持!

    5 条回复    2019-07-23 23:27:11 +08:00
    jakehu
        1
    jakehu  
       2019-07-23 15:27:24 +08:00
    延时消息 beanstalkd 做的不错 https://github.com/beanstalkd/beanstalkd
    不过没试过延时一年,哈哈
    pubby
        2
    pubby  
       2019-07-23 15:33:12 +08:00 via Android
    @jakehu beanstalkd 的延迟是秒级
    julyclyde
        3
    julyclyde  
       2019-07-23 15:58:34 +08:00
    curl 的时候,如果后边有 & 符号
    建议给 URL 整体加上单引号
    qwerthhusn
        4
    qwerthhusn  
       2019-07-23 17:36:16 +08:00
    我们是用的 https://github.com/rabbitmq/rabbitmq-delayed-message-exchange 那个插件。听说 rabbitmq 自带的 ttl 有些问题
    vibbow
        5
    vibbow  
       2019-07-23 23:27:11 +08:00   ❤️ 1
    max value of 32 bit unsigned integer => 4,294,967,295
    关于   ·   帮助文档   ·   博客   ·   API   ·   FAQ   ·   我们的愿景   ·   实用小工具   ·   2884 人在线   最高记录 6543   ·     Select Language
    创意工作者们的社区
    World is powered by solitude
    VERSION: 3.9.8.5 · 26ms · UTC 13:52 · PVG 21:52 · LAX 06:52 · JFK 09:52
    Developed with CodeLauncher
    ♥ Do have faith in what you're doing.