166°

RabbitMQ利用延迟消息来做定时任务的时候,注意什么

今天遇到一个同事,说想用rabbitmq来做定时任务,我想着这很简单啊,就是利用它的延迟消息来做就是了啊。但是,问题是他也是这样做的,但是并没有延迟执行代码,而是立刻执行了。怎么回事?

问题

利用rabbitmq的延迟消息执行定时任务,没有定时执行。现在就来测试这个问题。

我们写个测试方法来测试发送消息,并且延迟执行。

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

这样我们来请求,delay为6000毫秒,接口6秒后确实执行了代码。

现在我们设置延迟时间为一年。现在继续请求接口,但是发现消息被立即消费了。看来问题原因就是,延迟时间超过极限值了。

原因

这里的失败主要与消息的过期时间(TTL)有直接的关系。在RabbitMQ中,消息的过期时间必须是非负 32 位整数,即:0 <= n <= 2^32-1,以毫秒为单位。 其中,2^32-1 = 4294967295。

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

以上内容皆为本人观点,欢迎大家提出批评和指导,我们一起探讨!

本文由【DeDe程序员】发布于开源中国,原文链接:https://my.oschina.net/u/3317809/blog/3157912

全部评论: 0

    我有话说: