码农知识堂 - 1000bd
  •   Python
  •   PHP
  •   JS/TS
  •   JAVA
  •   C/C++
  •   C#
  •   GO
  •   Kotlin
  •   Swift
  • RabbitMQ 入门系列:9、扩展内容:死信队列:真不适合当延时队列。


    系列目录

    RabbitMQ 入门系列:1、MQ的应用场景的选择与RabbitMQ安装。

    RabbitMQ 入门系列:2、基础含义:链接、通道、队列、交换机。

    RabbitMQ 入门系列:3、基础含义:持久化、排它性、自动删除、强制性、路由键。

    RabbitMQ 入门系列:4、基础编码:官方SDK使用:链接创建、单例改造、发送消息、接收消息。

    RabbitMQ 入门系列:5、基础编码:交换机的进阶介绍及编码方式。

    RabbitMQ 入门系列:6、保障消息:不丢失:发送方、Rabbit存储端、接收方。

    RabbitMQ 入门系列:7、保障消息:不重复消费:产生消息的唯一ID。

    RabbitMQ 入门系列:8、扩展内容:接收信息时:可否根据RoutingKey过滤监听信息,答案是不能。

    RabbitMQ 入门系列:9、扩展内容:死信队列:真不适合当延时队列。

    RabbitMQ 入门系列:10、扩展内容:延时队列:延时队列插件及其有限的适用场景。

    前言:

    延迟队列用于事件发生后间隔一段时间后需要做特定处理的场景,如:

    1、电商支付系统中,用户下单后N分钟不支付,自动取消订单。
    2、用户浏览商品长时间后还没下单,后续推送相关产品和优惠券。
    3、用户注册或修改生日后:生日短信推送等。
    4、7天后的自动确认收货等。。。
    ......

    对于这类应用,用消息队列,对个别可能是合适的,但对整个系统应用而言,它是不靠谱的。

    消息队列的核心应用,是保持内存的队列,不断的产生并不断的消耗,最佳状态的保持系统的稳定和流畅。

    而延迟队列的核心,是积压消息,大量积压消息,这明显与消息队列的设计就不符合。

    下面来看看网传用死信队列来实现延迟队列的方式

    1、死信队列的概念:

    复制代码
    1、默认队列的消息过期了,或是被拒约处理,系统就是直接丢弃掉的。
    
    2、如果你不希望过期的消息,被系统直接丢弃,还想拿来二次处理,那么:
    
    可以通过绑定另一个队列,并标识为“x-dead-letter-exchange”,
    
    那么,原本要丢弃的消息,就都转发到这指定的队列中,这个接收丢弃信息的队列,就叫死信队列。
    复制代码

    2、死信队列的编码:

    复制代码
    using (var channel = Rabbit.Instance.DefaultConnection.CreateModel())
    {
        //定义普通队列来接收丢弃的信息
        channel.QueueDeclare("dead");
    
        IDictionary dic2 = new Dictionary();
        dic2.Add("x-dead-letter-exchange", "");//使用默认交换机
        dic2.Add("x-dead-letter-routing-key", "dead");//设置转移到的队列
        dic2.Add("x-message-ttl", 6000);//设置过期时间
        channel.QueueDeclare("sendtodead", arguments: dic2);
    
        channel.BasicPublish("", "sendtodead", false, null, Encoding.UTF8.GetBytes("6秒就过期了1。"));
        channel.BasicPublish("", "sendtodead", false, null, Encoding.UTF8.GetBytes("6秒就过期了2。"));
    
    }
    复制代码

     运行后,消息从sendtoddead队列6秒过期后,转移到dead队列。

    3、死信队列它的适用场景:

    1、队列有统一的过期时间,不能使用单个信息的过期时间:

    因为MQ不扫整个队列,只扫描队列第1个,判断是否过期,因此要求先进队列的必须先过期。

    2、过期时间应该较短(根据可能积压的数据考量时间,一个核心的考量数据量是:10万条-100万条),避免长时间积压数据

    对于长时间不消费的,不应该存入MQ,毕竟MQ的核心是内存队列,而不是磁盘队列。

    4、死信队列它为什么不适合当延时队列:

    了解完死信队列,会发现,其实在一个系统中,仅有比如N分钟后要处理逻辑的场景,比较适合,

    其它N天后要处理的,都不靠谱。

    而你用了N分钟的场景,那其它场景你用不用?

    用了,不靠谱!
    
    不用,得用其它方案,方案会不会多样化,不方便管理?

    总结:

    1、如果非要用死信队列当延时队列,那么要建立很多个第N分钟过期的队列。

    2、如果非要用死信队列当延时队列,那么下一篇介绍的官方的延时队列插件,会比死信队列更合适。

  • 相关阅读:
    Dockerfile概念简介
    2023最新SSM计算机毕业设计选题大全(附源码+LW)之java客户需求管理系统2v0d6
    HTML做一个学校网站(纯html代码)
    2024中国眼博会·第六届北京国际青少年眼健康产业展览会
    Ansible之playbooks剧本
    Elasticsearch搜索功能的实现(五)-- 实战
    鸡卵清白蛋白偶联石杉碱甲(Huperzine-OVA/Ovalbumin)的产品介绍
    Shiro学习详解
    数据结构_栈和队列
    [Linux] 6.VMware虚拟机网络配置
  • 原文地址:https://www.cnblogs.com/cyq1162/p/16643569.html
  • 最新文章
  • 攻防演习之三天拿下官网站群
    数据安全治理学习——前期安全规划和安全管理体系建设
    企业安全 | 企业内一次钓鱼演练准备过程
    内网渗透测试 | Kerberos协议及其部分攻击手法
    0day的产生 | 不懂代码的"代码审计"
    安装scrcpy-client模块av模块异常,环境问题解决方案
    leetcode hot100【LeetCode 279. 完全平方数】java实现
    OpenWrt下安装Mosquitto
    AnatoMask论文汇总
    【AI日记】24.11.01 LangChain、openai api和github copilot
  • 热门文章
  • 十款代码表白小特效 一个比一个浪漫 赶紧收藏起来吧!!!
    奉劝各位学弟学妹们,该打造你的技术影响力了!
    五年了,我在 CSDN 的两个一百万。
    Java俄罗斯方块,老程序员花了一个周末,连接中学年代!
    面试官都震惊,你这网络基础可以啊!
    你真的会用百度吗?我不信 — 那些不为人知的搜索引擎语法
    心情不好的时候,用 Python 画棵樱花树送给自己吧
    通宵一晚做出来的一款类似CS的第一人称射击游戏Demo!原来做游戏也不是很难,连憨憨学妹都学会了!
    13 万字 C 语言从入门到精通保姆级教程2021 年版
    10行代码集2000张美女图,Python爬虫120例,再上征途
Copyright © 2022 侵权请联系2656653265@qq.com    京ICP备2022015340号-1
正则表达式工具 cron表达式工具 密码生成工具

京公网安备 11010502049817号