RabbitMQ基础组件介绍

阳光穿透心脏的1/2处 2023-02-22 03:58 25阅读 0赞

RabbitMQ采用Erlang语言开发

### 概念 ###

![AMQP基本概念][AMQP]

*  生产者（producer）：创建消息，发布到代理服务器（Message Broker）。
 *  消费者（consumer）：消费消息
 *  代理服务器（Message Broker）：接收和分发消息的应用，RabbitMQ Server就是消息代理服务器，其中包含概念很多，以RabbitMQ 为例：信道（channel）、队列（queue）、交换器（exchange）、路由键（routing key）、绑定（binding key）、虚拟主机（vhost）等。
 *  信道（channel）: 应用程序（生产与/或消费）和代理服务器之间TCP连接内的虚拟连接，解决TCP连接数量限制及降低TCP连接代价。每个信道有一个ID，其概念与“频分多路复用”类似。参考上图：AMQP基本概念
 *  队列（queue）：消息最终到达队列中，等待消费者消费。使用“basic.consume”订阅可获得队列全部消息，“basic.get”订阅只能获得队列的一条消息（如果队列中存在消息）。如果无人订阅，消息将在队列中存储，等待订阅；如果多个消费者同时订阅该队列，消息将以自动轮询（round-robin）方式发送给消费者（Fanout Exchange，每个消费者只能获得队列中消息的子集）
 *  交换器（exchange）：消息到达代理服务器的第一站，根据分发规则，匹配查询表中的（routing key）路由键（Fanout Exchange除外），分发消息到队列（queue）中去。常用的类型有：direct (point-to-point), topic (publish-subscribe) and fanout (multicast)，请参考“2.1交换器”
 *  路由键（routing key）：消息发送给交换器时，消息将拥有一个路由键（默认为空），交换器根据这个路由键将消息发送到匹配的队列中。
 *  绑定键（binding key）：队列需要通过绑定键（默认为空）绑定到交换器上，交换器将消息的路由键与所绑定队列的绑定键进行匹配，正确匹配的消息将发送到队列中。路由键是偏向生产的概念，而绑定键是偏向消费的概念。
 *  虚拟主机（vhost）：AMQP概念的基础，其本质上就是一个mini版的代理服务器（拥有自己的队列、交换器和绑定，更重要的是，拥有自己的权限机制），RabbitMQ默认的vhost：“/”（类似于网络中的namespace），每个用户只能访问自己的vhost（通常会被指派至少一个vhost），进而用户只能访问自己的队列、交换器和绑定，所以vhost之间是绝对隔离的（安全性与可移植性）。

### RabbitMQ说明 ###

##### 交换器类型 #####

*  direct交换器  
    如果路由键（routing key）匹配成功，消息就被投递到对应的各个队列，绑定键（binding key）不支持“\*”和“\#”。消费者在接受消息的信道上可以给生产者反馈。
 *  fanout  
    不存在（routing key）路由键，消息以自动轮询（round-robin）的形式发送到对应的队列（幼儿园给孩子分苹果，如果苹果足够多，将平均分配给每个人），队列不存在绑定键（binding key），消费者在接受消息的当前信道上可以给生产者反馈。
 *  topic  
    存在（routing key）路由键，消息以广播的形式发送到绑定键（bing key）匹配的各个队列，绑定键（binding key）支持“\*”和“\#”
 *  headers （已废弃）  
    略

*：除“.”作为分隔符，匹配任意字符，如*.msg-inbox匹配任意.msg-info结尾的字符  
\#：将匹配任意字符，如\#msg-inbox匹配任意以msg-inbox结尾的字符，包含“ . \* \# ”等字符  
[RabbitMQ基本概念][RabbitMQ]

[AMQP]: https://img-blog.csdnimg.cn/20200701154738175.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2ppbmc5NTY4OTk0NDk=,size_16,color_FFFFFF,t_70
[RabbitMQ]: https://www.jianshu.com/p/25816ae3d8db