RabbitMQ笔记四:Binding,Queue,Message概念

Binding详解

 
黄线部分就是binding

ExchangeExchangeQueue之间的虚拟连接,Binding中可以包含Routing key或者参数

 
创建binding

注意:

  • default Exchange不能进行Binding,也不需要进行绑定。
  • 除default Exchange之外,其他任何Exchange都需要和Queue进行Binding,否则无法进行消息路由(转发)
  • Binding的时候,可以设置一个或多个参数,其中参数要特别注意参数类型,如果Routing key中指定的参数类型和消息中指定的参数类型不一致(header Exchange)也不能进行消息转发。
  • Direct Exchange,Topic Exchange进行Binding的时候,需要指定Routing key
  • Fanout Exchange,Headers Exchange进行Binding的时候,不需要指定Routing key。

Queue详解

Queue称为Message Queue,消息队列,保存消息并将它们转发给消费者。

 
RabbitMQ架构图

属性

  • Durability:是否持久化,Durable是,Transient是否。如果不持久化,那么在服务器宕机或重启之后Queue就会丢失。
  • Auto delete:如果选择yes,当最后一个消费者不在监听Queue的时候,该Queue就会自动删除,一般选择false。
  • Arguments:AMQP协议留给AMQP实现者扩展使用的。
    x-message-ttl:一个消息推送到队列中的存活时间。设置的值之后还没消费就会被删除。
    x-expires:在自动删除该队列的时候,可以使用该队列的时间。
    x-max-length:在队列头部删除元素之前,队列可以包含多少个(就绪)消息,如果再次向队列中发送消息,会删除最早的那条消息,用来控制队列中消息的数量。
    x-max-length-bytes:在队列头部删除元素之前,队列的总消息体的大小,用来控制队列中消息的总大小。
    x-dead-letter-exchange:当消息被拒绝或者消息过期,消息重新发送到的交换机(Exchange)的可选名称。
    x-dead-letter-routing-key:当消息被拒绝或者消息过期,消息重新发送到的交换机绑定的Route key的名称,如果没有设置则使用之前的Route key。
    x-max-priority:队列支持的最大优先级数,如果没有设置则不支持消息优先级
    x-queue-mode:将队列设置为延迟模式,在磁盘上保留尽可能多的消息以减少RAM使用; 如果未设置,队列将保持在内存中的缓存,以尽可能快地传递消息。
    x-queue-master-locator:将队列设置为主位置模式,确定在节点集群上声明队列主节点所在的规则。

可以在控制台上查看queue列表还可以通过rabbitmqctl list_queues命令进行查看。

[root@mqserver ~]# rabbitmqctl list_queues
Listing queues
weixin  0
duanxin 0
APP     0
email   0
WAP     0
zhihao.miao.order       0
PC      0
OA      1

指定某个vhost下的队列:

[root@mqserver ~]# rabbitmqctl list_queues -p /
Listing queues
weixin  0
duanxin 0
APP     0
email   0
WAP     0
zhihao.miao.order       0
PC      0
OA      1

可以通过restful api来查看:http://192.168.1.131:15672/api/queues输入用户名密码即可。

 
具体的api可以点击

Message详解

消息。服务器和应用程序之间传送的数据,本质上就是一段数据,由Properties和Payload(body)组成。

 
 

Delivery mode:是否持久化,如果未设置持久化,转发到queue中并未消费则重启服务或者服务宕机则消息丢失。
Headers:头信息,是由一个或多个健值对组成的,当固定的Properties不满足我们需要的时候,可以自己扩展。

Properties(属性)
content_type:传输协议
content_encoding:编码方式
priority:优先级
correlation_id:rpc属性,请求的唯一标识。
reply_to:rpc属性,
expiration:消息的过期时间
message_id:消息的id
timestamp:消息的时间戳
...

如何保证消息的不丢失,三个地方做到持久化。

  1. Exchange需要持久化。
  2. Queue需要持久化。
  3. Message需要持久化。


作者:二月_春风
链接:https://www.jianshu.com/p/fc97159f31d1
來源:简书
简书著作权归作者所有,任何形式的转载都请联系作者获得授权并注明出处。
原文地址:https://www.cnblogs.com/shizhijie/p/9802029.html