3.RabbitMQ 架构以及 通信方式

一、RabbitMQ的架构

RabbitMQ的架构可以查看官方地址


可以看出RabbitMQ中主要分为三个角色：

• Publisher：消息的发布者，将消息发布到RabbitMQ中的Exchange
• RabbitMQ服务：Exchange接收Publisher的消息，并且根据Routes策略将消息转发到Queue中
• Consumer：消息的消费者，监听Queue中的消息并进行消费
• Routes：就是我们下面说的 Routing Key

RabbitMQ发送消息的策略是，消息到达Exchange，然后根据 RoutingKey 去配置到 Queue，然后消费者监听queue来完成消费

二、AMQP概念

RabbitMq是基于AMQP协议的。

1.什么是AMQP协议

1. server：又称Broker,接收客户端连接，实现AMQP实体服务
2. Connection： 连接，应用程序与Broker的网络连接
3. Channel：网络信道，几乎所有的操作都在Channel中进行，Channel是进行消息读写的通道。客户端可建立多个Channel，每个Channel代表一个会话任务。
4. Virtual Host ：虚拟地址，用于进行逻辑隔离，最上层的消息路由。一个Virtual host里面可以有若干个Exchange和Queue，同一个Virtual host 里面不能有相同名称的Exchange或Queue，可以理解为 Mysql中的 db概念，不同的用户可以管理不同的 Virtual Host，默认是 / 目录，也可以在 管理页面上 创建 Virtual Host 并指定给相应的用户，或者在命令行中创建和设置用户。
5. ExChange：交换机，接收消息，根据路由键转发消息到绑定的队列
6. Binding：Exchange和Queue之间的虚拟连接，binding中可以包含routing key(路由键)
7. Routing key：一个路由规则，虚拟机可用它来确定如何路由一个特定消息
8. Queue：也称为Message Queue，消息队列，保存消息并将它们转发给消费者
9. Message：消息，服务器和应用程序之间传送的数据，由Properties和Body组成,Properties可以对消息进行修饰，比如消息的优先级、延迟等高级特性；Body则就是消息体内容

二、ExChange详解

1. Name：交换机名称
2. Type：RabbitMQ中交换机的类型有 direct（直接） 、topic（主题）、fanout（广播）、headers（标题）
3. Durability：交换机是否需要持久化，true为持久化。
4. Auto Delete：当最好一个绑定到Exchange上的队列删除后，自动删除Exchange。
5. Internal：当前Exchange是否用于RabbitMQ内部使用，默认False
6. Arguments：扩展参数，用户扩展AMQP协议自制定化使用

三、Queue详解

1. name：队列的名称
2. durable：是否是持久化队列
3. autoDelete：当最后一个消息不在了，是否自动删除队列，默认false。

三、RabbitMQ通讯的方式

RabbitMQ通讯方式 是依赖于 Exchange的类型的。

3.1 direct类型交换机

所有发送到Direct Exchange的消息被转发到RouteKey中指定的Queue

注意：Direct模式可以使用RabbitMQ自带的Exchange：default Exchange，所以不需要将Exchange进行任何绑定操作，消息传递时，RouteKey必须完全匹配才会被队列接收，否则该消息会被抛弃

注意：Direct模式可以使用RabbitMQ自带的Exchange：default
Exchange，所以不需要将Exchange进行任何绑定操作，消息传递时，RouteKey必须完全匹配才会被队列接收，否则该消息会被抛弃

3.2 fanout类型交换机

1. 不处理Routing Key，只需要简单的将队列绑定到交换机上
2. 发送到交换机的消息都会被转发到与该交换机绑定的所有队列上
3. Fanout交换机转发消息是最快的
   

3.3 topic类型交换机

所有发送到Topic Exchange的消息被转发到所有关心RouteKey中指定Topic的Queue上

Exchange将RouteKey和某个Topic进行模糊匹配，此时队列需要绑定一个Topic

注意：可以使用通配符进行模糊匹配

• 符号 # 匹配一个或多个词
• 符号 * 只匹配一个词
• 例如：log.# 能够匹配到 log.info.a、log.info.c、log.info
• log.* 只能匹配到 log.info 。

3.4 headers类型交换机

上面的三种都是通过 Routing Key来进行匹配的，而headers是通过消息的header来进行匹配的。

headers头部的 x-match 参数是 必须的，如果x-match设置的是all，那么生产者在生产消息时必须满足设置的headers条件，
我上面设置的是 x-match=all ，name=jack，age=23，那么我想发送消息到这个队列里面，那么消息头必须要有 name=jack，age=23。
如果我设置的是 x-match=any ，那么我满足其中一个条件就好了，比如上面是 name = jack，age= 23，那么我消息头带其中的一个就可以了，也就是他们两个的任意一个。
如果不满足的话，消息无法到达exchange绑定的queue中。