RabbitMQ相关概念介绍（一）

叁歲伎倆 2022-09-01 08:16 215阅读 0赞

RabbitMQ整体上是一个生产者与消费者模型，主要负责接收、存储和转发消息。

### 生产者和消费者 ###

Producere：生产者，就是消息投递的一方。

生产者创建消息之后发布到RabbitMQ中。消息一般包含2个部分：消息体和标签。消息体一般是一个带有业务逻辑结构的数据，比如一个JSON字符串。消息的标签用来表述这条消息，比如一个交换机的名称和一个一个路由键。

Consumer：消费者，就是接收消息的一方。

消费者连接到RabbitMQ服务器，并订阅到队列上。当消费者消费一条消息时消费的只是消息体。消息路由的过程中会丢弃标签，存入到队列的只是消息体，消费者也之后消费消息体，也就不知道消息的生产者是谁，当然消费者也不关心生产者是谁。

Broker：消息中间件的服务节点。

对于RabbitMQ来说，一个RabbitMQ Broker可以简单的看作一个RabbitMQ服务节点，或者RabbitMQ服务实例。大多数情况下也可以将一个RabbitMQ Broker看作一台RabbitMQ服务器。

### 队列 ###

Queue：队列，是RabbitMQ的内部对象，用于存储消息。

RabbitMQ中的消息只能存储在队列中，这一点与Kafka相反，Kafka的消息存储在topic（主题）这个逻辑层面，而相对应的队列逻辑这是topic实际存储文件中的位置标识。RabbitMQ的生产者生产消息并最终存放在队列中，消费者可以从队列中获取消息并消费。

多个消费者可以订阅同一个队列，当多个消费者同时订阅同一个队列的时候，队列中的消息会被平均分摊给多个消费者，而不是每个消费者可以消费到所有的消息。

### 交换器 ###

Exchange：交换器。生产者发送消息不是直接到队列的，而是将消息发送到Exchange，由交换器将消息路由到与交换器绑定的队列上。如果路由不到，或返回给生产者，或丢弃。

交换器有4中类型，不同的交换器有着不同的处理策略。

fanout：会将消息路由到当前交换器绑定的所有队列中。

direct：会叫消息路由到那些BindingKey和RoutingKey完全匹配的队列中。

topic：direct是BindingKey和RoutingKey完全匹配，而他是direct的一种扩展模糊匹配。

RoutingKey是一个由点“.”隔开的字符串。如：topic.order。

BindingKey和RoutingKey一样也是一个由点隔开的字符串。

BindingKey中可以存在两种特殊字符串“\*”和“\#”，用于做模糊匹配，其中“\*”用与匹配一个单词，“\#”用于匹配多个（可以是零个）

### 路由键 ###

RoutingKey：路由键。生产者将消息发给交换器的时候，一般会指定一个RoutingKey，用于来指定这个消息的路由规则，而这个RoutingKey需要与交换器和绑定键（BindingKey）联合使用才能最终生效。

在交换器和绑定键（BindingKey）固定的情况下，生产者可以在发送消息的时候指定RoutingKey来决定消息流向哪里。

### 绑定 ###

Binding：绑定。RabbitMQ中通过绑定将交换器和对流关联起来，在绑定的时候一般会指定绑定键（BindingKey），这样RabbitMQ就知道如何正确的将消息路由到队列。

生产者将消息发送给交换器时，需要一个RoutingKey，当BindingKey和RoutingKey相匹配时，消息会被路由到对应的队列中，在绑定多个队列到同一个交换器的时候，这些绑定允许使用相同的BindingKey。BindingKey并不是在所有情况下都生效，它依赖于交换器的类型，比如fanout类型的交换器就无视BindingKey，而是将消息路由到当前交换器绑定的所有消息队列上。

### AMQP协议介绍 ###

RabbitMQ就是遵循AMQP协议的，也就是说RabbitMQ是AMQP协议的Erlang的实现。AMQP协议的模型架构和RabbitMQ模型一样，生产者将消息发送给交换器，交换器和队列绑定。当生产者发送消息时所携带的RoutingKey和绑定的BindingKey相匹配的时候，消息被存入相应的队列中，消费者可以订阅队列来获取消息。

AMQP协议本身包括三层：

Module Layer：位于协议最高层，主要定义了一些客户端使用的命令，客户端可以使用这些命令实现自己的业务逻辑。

Session Layer：位于中间层，主要负责将客户端的命令发送给服务器，再将服务器的应答返回给客户端，主要为客户端与服务器之间的通信提供可靠性同步机制和错误处理。

Transport Layer：位于最底层，主要传输二进制数据流，提供帧的处理、信道复用、错误检测和数据标识等。