参考连接: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。。。。