RabbitMQ 声明队列时候的参数解释

参考连接:http://www.rabbitmq.com/releases/rabbitmq-dotnet-client/v3.6.6/rabbitmq-dotnet-client-3.6.6-client-htmldoc/html/type-RabbitMQ.Client.IModel.html#method-M:RabbitMQ.Client.IModel.BasicConsume(System.String,System.Collections.IDictionary,RabbitMQ.Client.IBasicConsumer)html

建立Connection【高成本,tcp的链接】 能够建立无数个channel【低成本】redis

1.QueueDeclare方法 声明队列
public static QueueDeclareOk QueueDeclare(this IModel model, string queue = "", bool durable = false, bool exclusive = true, bool autoDelete = true, IDictionary<string, object> arguments = null);算法

durable:持久化
mnesia:erlang 数据库,有专门的表去保存咱们的队列声明数据库

exclusive:排外
当前定义的队列connection中的channel是共享的,其余的connection是访问不到的
当conneciton.close的时候,queue被删除异步

autoDelete:自动删除
当前最后一个consumer断开以后,autoDelete队列tcp

agruments:rabbitmq 的扩展this


2.QueueDeclareNoWait方法 声明队列,不等待队列建立结果,异步的orm

3.QueueDeclarePassive方法:消极的声明建立,判断队列是否存在,不存在报错htm


4.详细说明下QueueDeclare方法agruments(rabbitmq的扩展)blog

参考地址:https://www.cnblogs.com/LiangSW/p/6224333.html

1. 咱们要知道到底有哪些参数属性。。。。

 

《1》 Message TTL

<1> Queue TTL =》 Per-Queue Message TTL 【给一个queue的全部message限定一个时间】
Cache的一个效果。。。
//声明一个queue,里面的内容自发布起五秒后被删除
channel.QueueDeclare("messagettlqueue", true, false, false, new Dictionary<string, object> { { "x-message-ttl", 5000 }

<2> Message TTL =》 单独指定。【定制化的】

IBasicProperties basicProperties,
var properties = channel.CreateBasicProperties();
//设置过时时间
properties.Expiration = "5000";
channel.BasicPublish(null, "queue", properties, Encoding.UTF8.GetBytes("我五秒后就会消失"));


2.Auto Expire 【自动删除】

《1》 当咱们的queue在指定的时间未被访问,就会被删除。。。

//声明一个queue,queue五秒内并且未被任何形式的消费,则被删除
channel.QueueDeclare("queue", true, false, false, new Dictionary<string, object> { { "x-expires", 5000 } });

3. Max Length 限定队列的最大长度。。。 limit =1000

4. Max Length Bytes 限定队列的最大占用空间大小。。。 【通常来讲受制于内存,disk的大小限定】

//声明一个queue,最大长度10,最大大小2048bytes
channel.QueueDeclare("queue", true, false, false, new Dictionary<string, object>
{
{ "x-max-length", 10 },
{ "x-max-length-bytes", 2048}
});
redis,memcache。。。 LRU算法。。。淘汰机制。。。。

5.Dead letter exchagne 与 Dead letter routing key

何为Dead letter,,也就是说那些没有被投递出去的信件


一: Dead letter exchange

有时候咱们不但愿message被drop掉,而是走到另外一个队列中,又或者是保存起来。。。


二: Dead letter routing key

打到exchange中去的时候,他的routingkey是什么,,


和普通定义方式没什么两样。。。

 

三: Maximum priority

优先级加到队列上,就是一个优先级队列,,, 【堆,大根堆,小根堆】

1. 给队列贴上一个优先级的标签。。。 x-max-priority =10, 这个值不要设置的太大。。。 节点更多。。 sortset。。。

无论你用什么语言实现,都是一个tree结构。。。。

2. 给message打上具体的优先级的value。。。 value<=10

MSMQ的message级别通常也就4,5中。。。low/normal/high/higher//........

咱们经过“优先级”特性,,将一个queue 变成了 stack。。。。

相关文章
相关标签/搜索