zoukankan      html  css  js  c++  java
  • RabbitMQ 利用消息超时和死信交换机实现定时任务

      在 RabbitMQ 的基础功能中,并没有定时任务或者延时任务这种功能,然而很多业务都有此类需求,但是我们可以依赖 RabbitMQ 的消息自动超时和死信交换机等基本的属性来实现这类需求,大致思路如下:

      1.通过计算 任务执行时间 和 当前时间的时间差,作为消息的超时时间(Expire)属性;

      2.将消息发到一个具有死信交换机的队列中暂时缓存消息;

      3.消息在缓存队列中到达超时时间,自动发送到死信交换机,从而到达任务目标队列,由消费者进行消费;

      流程图如下:

       

  • 相关阅读:
    中国大陆地区用户请特别注意:请勿存放违反当地法律法规文件
    JAVA日报
    JAVA日报
    JAVA日报
    JAVA日报
    JAVA日报
    JAVA日报
    JAVA日报
    JAVA日报
    JAVA日报
  • 原文地址:https://www.cnblogs.com/malcolmfeng/p/8548961.html
Copyright © 2011-2022 走看看