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

  • Z时代
  • 2024-01-10
  • 分类：综合

编程

今天遇到一个同事，说想用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毫秒。如果你的业务需求会超过这个临界值，就必须避开这个坑，采用其他方法来实现需要延迟或者定时执行的任务了。

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

以上是 RabbitMQ利用延迟消息来做定时任务的时候，注意什么 的全部内容， 来源链接： utcz.com/z/512694.html

回到顶部