7

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

 1 year ago
source link: https://www.cnblogs.com/cyq1162/p/16609207.html
Go to the source link to view the article. You can view the picture content, updated content and better typesetting reading experience. If the link is broken, please click the button below to view the snapshot at that time.

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);
17408-20220821212924609-1759718122.png

2、排它性：参数名：exclusive，默认值：true

在定义队列的时候，涉及该参数：

排它性的作用说明：

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

示例代码：

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

 

17408-20220821213207261-420618796.png
该参数为true时，持久化参数是无效的，因为链接关闭即释放队列。

3、自动删除：参数名：autoDelete，默认值：true

在定义队列的时候，涉及该参数：

自动删除的作用说明：

如果该参数为true，则最后一名消费者关闭链接时，该队列被删除。
1、消费者A监听队列，然后关闭链接，则队列被删除；

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

示例代码：

    //定义队列
    channel.QueueDeclare("dead", durable: true, exclusive: true, autoDelete: true);
17408-20220821213358377-1936388703.png

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的基础参数含义，在后续的编码中，遇到时候，可以反复回来查看，加深理解。


report

Recommend

About Joyk


Aggregate valuable and interesting links.
Joyk means Joy of geeK