码农知识堂 - 1000bd
  •   Python
  •   PHP
  •   JS/TS
  •   JAVA
  •   C/C++
  •   C#
  •   GO
  •   Kotlin
  •   Swift
  • RabbitMQ 入门系列:3、基础含义:持久化、排它性、自动删除、强制性、路由键。


    系列目录

    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、扩展内容:延时队列:延时队列插件及其有限的适用场景。

    前言:

    本篇介绍:RabbitMQ 后续编码涉及的基础含义:持久化、排它性、自动删除、强制性、路由键。

    1、持久化:参数名:durable,默认值:false

    在定义队列或定义交换机的时候,涉及该参数。

    持久化作用说明:

    即将相关队列的消息、或交换机的绑定信息等内容,写入硬盘备份,以便系统故障或重启时,仍可以恢复原来的状态,保障信息不丢失。

    缺点:

    大量的硬盘写入,会对IO造成不小的影响,因此RabbitMQ的部署环境,应该尽量避免和IO读写频繁的应用在同一磁盘上,比如数据库等。

    示例代码:

    channel.QueueDeclare("dead",durable:true, false, false);

    2、排它性:参数名:exclusive,默认值:true

    在定义队列的时候,涉及该参数:

    排它性的作用说明:

    如果该参数为true,则该队列仅允许创建它的连接进行写入或读取,同时当该链接关闭时,该队列被删除。

    示例代码:

     //定义队列
        channel.QueueDeclare("dead", durable: true, exclusive: true, false);

     

    说明:

    该参数为true时,持久化参数是无效的,因为链接关闭即释放队列。

    3、自动删除:参数名:autoDelete,默认值:true

    在定义队列的时候,涉及该参数:

    自动删除的作用说明:

    如果该参数为true,则最后一名消费者关闭链接时,该队列被删除。

    示例:

    1、消费者A监听队列,然后关闭链接,则队列被删除;
    
    2、消费者A监听队列、消费者B监听队列、消费者C监听队列,则当全部链接都关闭时,队列被删除。

    示例代码:

        //定义队列
        channel.QueueDeclare("dead", durable: true, exclusive: true, autoDelete: true);

    4、强制性:参数名:mandatory,默认值:false

    在发布消息的时候,涉及该参数:

    强制性的作用说明:

    发送的消息,通过交换机,找不到对应队列时:

    如果为false:消息会被丢弃。
    如果为true:可以通过BasicReturn回调事件,拿到丢失的数据,进行二次处理。

    示例代码:

    复制代码
    using (var channel = Rabbit.Instance.DefaultConnection.CreateModel())
    {
        channel.BasicReturn += (e,a) => { 
        
            //回调事件。
        };
        //定义队列
        channel.QueueDeclare("dead", durable: true, exclusive: true, autoDelete: true);
     
        channel.BasicPublish("", "dead", mandatory:true, null, Encoding.UTF8.GetBytes("6秒就过期了1。"));
    
    }
    复制代码

    5、路由键:参数名:routingKey,使用默认路由时,即为队列名

    在定义交换机,或者发布消息时,涉及该参数:

    路由键的作用说明:

    1、未定义交换机,使用默认direct方式时,发消息消息时:交换机=空值,routingKey=队列名。
    
    2、自定义交换机,也设置routingKey时,发布消息的时:填写对应的交换机名和设置的routingKey。

    更多路由键的使用,在交换机进队介绍一文中介绍。

    示例代码:

    复制代码
    using (var channel = Rabbit.Instance.DefaultConnection.CreateModel())
    {
        //定义队列
        channel.QueueDeclare("dead", durable: true, exclusive: true, autoDelete: true);
     
        channel.BasicPublish("", routingKey:"dead", false, null, Encoding.UTF8.GetBytes("6秒就过期了1。"));
    
    }
    复制代码

    总结:

    本篇介绍RabbitMQ的基础参数含义,在后续的编码中,遇到时候,可以反复回来查看,加深理解。

  • 相关阅读:
    Wi-Fi连接握手包抓包
    nodejs项目实例拼车租车平台
    为什么说使用领英的人一定要用领英精灵
    驱动 10月23日 作业
    因子模型:协方差矩阵
    【ACM数论】和式变换技术,也许是最好的讲解之一
    小程序门店自提功能,提高线上线下销售量
    【由浅入深 - Java笔记】玩转List:List过滤和筛选
    京东数据报告:2023年常温奶消费市场数据分析
    JavaWeb 综合案例(包含注册与登录页面,包含对数据库的增删改查页面)新增加session与cookie与验证码
  • 原文地址:https://www.cnblogs.com/cyq1162/p/16609207.html
  • 最新文章
  • 沪漂五周年了:我越来越迷茫了
    Agentic Skill Routing 实战:别再把所有 Skill 塞进 AI Agent 上下文
    MySQL-Seconds_behind_master的精度误差
    [MAF预定义ChatClient中间件-03]CachingChatClient——利用缓存省钱省时间
    AI的至暗历史:从万众期待到被政府撤资,AI的两次死亡徘徊
    Agent OS :五种驯服不确定性的范式
    PortSwigger SQL注入LAB11
    数据库即时编译JIT
    [Begin]AI Learn Data Day 0
    深度学习进阶(二十七)现代 LLM 的核心架构设计其二:SwiGLU
  • 热门文章
  • 十款代码表白小特效 一个比一个浪漫 赶紧收藏起来吧!!!
    奉劝各位学弟学妹们,该打造你的技术影响力了!
    五年了,我在 CSDN 的两个一百万。
    Java俄罗斯方块,老程序员花了一个周末,连接中学年代!
    面试官都震惊,你这网络基础可以啊!
    你真的会用百度吗?我不信 — 那些不为人知的搜索引擎语法
    心情不好的时候,用 Python 画棵樱花树送给自己吧
    通宵一晚做出来的一款类似CS的第一人称射击游戏Demo!原来做游戏也不是很难,连憨憨学妹都学会了!
    13 万字 C 语言从入门到精通保姆级教程2021 年版
    10行代码集2000张美女图,Python爬虫120例,再上征途
小工具 小游戏
Copyright © 2022 侵权请联系2656653265@qq.com    京ICP备2022015340号-1

京公网安备 11010502049817号