RabbitMQ的一些笔记(未完待续)

   2023-02-15 10:55:44

RabbitMQ

消息队列最常的使用场景：解耦，异步，削峰。

一、RabbitMQ简介：

RabbitMQ是一个由erlang开发的AMQP（Advanced Message Queue 高级消息队列协议 ）的开源实现，能够实现异步消息处理

RabbitMQ是一个消息代理：它接受和转发消息。

优点： 

1、异步消息处理

2、业务解耦（下订单操作：扣减库存、生成订单、发红包、发短信），将下单操作主流程：扣减库存、生成订单然后通过MQ消息队列完成通知，发红包、发短信

3、错峰流控 （通知量 消息量 订单量大的情况实现MQ消息队列机制，淡季情况下访问量会少）

4、灵活的路由（Flexible Routing）在消息进入队列之前，通过 Exchange 来路由消息的。对于典型的路由功能，RabbitMQ 已经提供了一些内置的 Exchange 来实现。针对更复杂的路由功能，可以将多个 Exchange 绑定在一起，也通过插件机制实现自己的 Exchange 。

RabbitMQ网站端口号：15672

程序里面实现的端口为：5672

二、RabbitMQ的核心组成部分

1、Server：又称Broker ,接受客户端的连接，实现AMQP实体服务。 安装rabbitmq-server

2、Connection：连接，应用程序与Broker的网络连接 TCP/IP/ 三次握手和四次挥手

3、Channel：网络信道，几乎所有的操作都在Channel中进行，Channel是进行消息读写的通道，客户端可以建立对各Channel，每个Channel代表一个会话任务。

4、Message :消息：服务与应用程序之间传送的数据，由Properties和body组成，Properties可是对消息进行修饰，比如消息的优先级，延迟等高级特性，Body则就是消息体的内容。

5、Virtual Host 虚拟地址，用于进行逻辑隔离，最上层的消息路由，一个虚拟主机理由可以有若干个Exhange和Queueu，同一个虚拟主机里面不能有相同名字的Exchange

6、Routing key：是一个路由规则，虚拟机可以用它来确定如何路由一个特定消息，决定了生产者将消息发送到哪个交换机。

7、Exchange：交换机，接受消息，根据路由键发送消息到绑定的队列。(不具备消息存储的能力)，在RabbitMQ中，生产者发送信息不会直接将消息投递到队列中，而是将消息投递到交换机中，再由交换机转发到具体的队列中，队列再将消息以推送或者拉取方式给消费进行消费

8、Bindings：Exchange和Queue之间的虚拟连接，binding中可以保护多个routing key，决定了交换机与哪个队列绑定。

9、Queue：队列：也成为Message Queue,消息队列，保存消息并将它们转发给消费者。

三、RabbitMQ整体架构

四、RabbitMQ的运行流程

五、Rabbitmq交换机

接收生产者的消息，然后根据路由键Routing key把消息投递到跟交换机绑定的对应队列上

1、扇形交换机(Fanout Exchange)

扇形交换机是最基本的交换机，它的作用是广播消息，把能接收到的消息全部发送给绑定在自己身上的队列，因为广播不需要思考，所以扇形交换机处理消息的速度也是所有交换机类型里面最快的

2、直连交换机(Direct Exchange)

将消息推送到binding key与该消息的routing key相同的队列

直连交换机x上绑定了两个队列，第一个列队绑定了绑定键orange，第二个队列有两个绑定键：black和green。在这种情况下，一个消息在布时指定了路由键为orange将会只被路由到列队q1，路由键为black和green的消息都将被路由到队列q2，其他的消息都将被丢失

3、主题交换机(Topic Exchange)

特点就是在它的路由键和绑定键之间是有规则的。

规则：

*  (星号) 用来表示一个单词 (必须出现的)
#  (井号) 用来表示任意数量（零个或多个）单词
// *  代表两点之间一个占位单词
// #  代表后面所有，匹配所有

通配的绑定键是跟队列进行绑定的，举个例子：

队列Q1 绑定键为 *.TT.* 队列Q2绑定键为 TT.#

如果一条消息携带的路由键为 A.TT.B，那么队列Q1将会收到；

如果一条消息携带的路由键为TT.AA.BB，那么队列Q2将会收到；

当一个队列的绑定键为 "#"（井号） 的时候，这个队列将会无视消息的路由键，接收所有的消息。

当 * (星号) 和 # (井号) 这两个特殊字符都未在绑定键中出现的时候，此时主题交换机就拥有的直连交换机的行为。

所以主题交换机也就实现了扇形交换机的功能，和直连交换机的功能