rabbitmq的总结

Posted 2021-01-23 ydymz

rabbitmq的术语

组件

Server(broker)：接收客户端连接，实现AMQP消息队列的路由功能的进程.简单来说就是消息队列服务器实体。

Vhost：虚拟主机，一个broker里可以开设多个vhost，用作不同用户的权限分离。权限控制组，用户只能关联到一个vhost上，一个vhost中可以有若干个Exchange和Queue，默认的vhost是"/"

Exchange：接收生产者发送的消息，并根据Binding规则将消息路由给服务器中的队列 Exchange Type决定了Exchange路由消息额行为，例如，在RabbitMQ中，ExchangeType有Direct、Fanout和Topic三种，不同类型的Exchange路由得到行为是不一样的

queue：用于存储还未消费的消息。消息队列载体，每个消息都会被投入到一个或多个队列

 

channel：消息通道，在客户端的每个连接里，可建立多个channel，每个channel代表一个会话任务

 

Message：由Header和Body组成，Header是由生产者添加到各种属性的集合，包括Message是否被持久化，是由哪个Message Queue接收优先级是多少等，而Body是真正需要传输的APP数据

操作

Binding: 绑定，它的作用就是把exchange和queue按照路由规则绑定起来。：

key标记

BindingKey： 在mq中设置的绑定key

RoutingKey：路由关键字，exchange根据这个关键字进行消息投递

角色

producer：消息生产者，就是投递消息的程序。

consumer：消息消费者，就是接受消息的程序。

 

rabbitmq的使用过程

客户端声明一个exchange，并设置相关属性。
客户端声明一个queue，并设置相关属性。
客户端使用routing key，在exchange和queue之间建立好绑定关系。
消费者使用routing key，在exchange和queue之间建立好绑定关系。
生产者连接到消息队列服务器，打开一个channel。
生产者投递消息到exchange，exchange接收到消息后，就根据消息的key和已经设置的binding，进行消息路由，将消息投递到一个或多个队列里。
消费者根据queue接受消息

 

exchange类型

direct 只有两个routingkey完全相同，exchange才会选择对应的binging进行消息路由

topic routingkey可以有通配符：‘*‘,‘#‘.其中‘*‘表示匹配一个单词， ‘#‘则表示匹配没有或者多个单词

fanout 直接将消息路由到所有绑定的队列中，无须对消息的routingkey进行匹配操作

header 路由的规则是根据header来判断