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

Bertha 。 2023-10-11 15:47 39阅读 0赞

## Binding详解 ##

![75cf54ab5d5afc2639d18cc0cc8f6ba8.png][]

黄线部分就是binding

`Exchange`与`Exchange`，`Queue`之间的虚拟连接，`Binding`中可以包含`Routing key`或者参数

![a8e1c6c305cdaa9f7a37b42f14f981fe.png][]

创建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，消息队列，保存消息并将它们转发给消费者。

![f751f49aa4be839ed191f0355777d0c4.png][]

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`输入用户名密码即可。

![8f537db59b06b1603282f43f108831ab.png][]

具体的api可以点击

### Message详解 ###

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

![70d1282122db04630e637303a40979b1.png][]

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需要持久化。

[75cf54ab5d5afc2639d18cc0cc8f6ba8.png]: https://img-blog.csdnimg.cn/img_convert/75cf54ab5d5afc2639d18cc0cc8f6ba8.png
[a8e1c6c305cdaa9f7a37b42f14f981fe.png]: https://img-blog.csdnimg.cn/img_convert/a8e1c6c305cdaa9f7a37b42f14f981fe.png
[f751f49aa4be839ed191f0355777d0c4.png]: https://img-blog.csdnimg.cn/img_convert/f751f49aa4be839ed191f0355777d0c4.png
[8f537db59b06b1603282f43f108831ab.png]: https://img-blog.csdnimg.cn/img_convert/8f537db59b06b1603282f43f108831ab.png
[70d1282122db04630e637303a40979b1.png]: https://img-blog.csdnimg.cn/img_convert/70d1282122db04630e637303a40979b1.png