基本概念
- 消息(message): 消息就是指在应用与应用之间传输的数据。消息可以很简单,比如一个字符串;消息也可以很复杂,比如一个对象。消息包括消息体(即实际数据)和路由键(可以理解成标签),后面会 一 一 介绍。
- 生产者(producer):发送消息的程序。
- 消费者(consumer):接收并处理消息的程序。
-
服务节点(Broker):也就是RabbitMQ服务器。
-
队列:是RabbitMQ中的内部对象,用于存储消息,且Rabbit MQ的消息只能存储在队列中;和数据结构中的队列一个意思,先进先出,如下图。
生产者将消息发送到队列,多个消费者可以订阅同一个队列进行消息消费,这时消息是被平均分摊给多个消费者处理,如下图。
上图显示生产者直接将消息投递到队列,实际上不是这样的,而是生产者先将消息投递到交换器,再由交换机路由到对应的队列中,这里就又涉及到几个概念,路由键(Routing Key)、绑定键(Binding Key)、交换器(Exchange)。 - 交换器(Exchange):可以想成生产者和队列之间的一个中间人,消费者将消息给交换器,交换器通过一定的规则将消息转发给对应的队列,这个规则由RoutingKey、BindingKey、交换器类型共同决定。
- 路由键(Routing Key):生产者将消息发送给交换器时,一般会指定一个RoutingKey,用来指定这个消息的路由规则,而这个RoutingKey需要与交换器、BingingKey联合使用才会生效。
-
绑定键(BindingKey):将交换器和队列进行绑定关联,这样交换器就知道如何路由消息到队列。
交换器类型
是的,交换器也有类型。RabbitMQ中常用交换器分为四种类型,fanout、direct、topic、headers四种,下面 一 一 介绍。
fanout:它会将所有发送到该交换器的消息路由到所有与该交换器绑定的队列中,而与RoutingKey、BindingKey无关。
-
direct:它会把消息路由到RoutingKey和BindingKey完全匹配的队列中,如下图。
-
topic:前面的direct是严格匹配的,有些时候并不能满足实际业务需求,topic类型的交换器对此进行了扩展,约定使用由“ . ”分割的字符串来指定RoutingKey和BindingKey,如com.rabbitmq.client、java.lang,而且可以使用通配符“ * ”和“ # ”做模糊匹配,“ * ”用来匹配一个单词,“ # ”用来匹配多个单词,如下图。
headers:headers类型的交换器不依赖RoutingKey和RoutingKey的匹配规则来路由消息,而是根据发送消息内容中的headers属性进行匹配。headers类型的交换器性能很差,不实用,基本看不到它的存在,就不细讲了。
有了以上概念,可以得到RabbitMQ模型架构
注意事项:其实可以将RoutingKey和BindingKey看成是一个东西,实际用的时候不会去特别区分他俩的关系。