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