MQ消息队列中间件— Rabbit MQ

消息中间件主要用于组件之间的解耦，消息的发送者无需知道消息使用者的存在，反之亦然。消息（Message）是指在应用间传送的数据。消息可以非常简单，比如只包含文本字符串，也可以更复杂，可能包含嵌入对象。是用于业务解耦的情况，其它常见场景包括最终一致性、广播、错峰流控等等。消息发送与接受的双方遵守这个协议可以实现异步通讯。

https://blog.csdn.net/cdefggg/article/details/88375249

https://zhuanlan.zhihu.com/p/63700605

官方模拟器： http://tryrabbitmq.com/

路由转发。生产者Producer在发送消息时，都需要指定一个RoutingKey和Exchange，Exchange收到消息后可以看到消息中指定的RoutingKey，再根据当前Exchange的ExchangeType,按一定的规则将消息转发到相应的queue中去。

1、 Message Quene是应用程序对应用程序的通信方法。异步RPC的主要手段之一。不需要直接调用彼此来通信。

2、Rabbit MQ(开源消息代理)是实现AMQP（应用层开放标准advanced message queuing protocal提供统一消息服务）协议的MQ产品。

3、消息的生产者Producer--->消息队列----->消息的消费者

4、 安装 Rabbit MQ：windows计算机名用英文，关闭安全软件:   

        1）Erlang环境（编程语言）: opt_win64_17.3.exe

             http://www.erlang.org/download/otp_win64_17.3.exe

        2）按照RabbitMQ服务: rabbitmq-server-3.4.1.exe

5、安装完测试：打开 rabbitMQ command prompt

    输入rabbitmq-plugins enable rabbitmq_management启动后台服务软件，浏览器输入127.0.0.1:15672 ，用户名/密码：guest/guest

6、overview:显示消息队列，节点，路径，端口（ AMQP端口5672，集群端口25672，web管理端口15672）

        connections:

        channels:数据通道（持久化的队列在管理页面可以看到有个“D”，durable为true）

        exchanges:交换机，类型，可以添加交换机。

            点击Exchange的Name可进入到Exchange的详情页面，在里面将Exchange与Queue进行Binding。

            测试： 点进交换器之后有一栏是Publish message， 发送成功后切换到Queues查看是否收到消息，点击ls队列进去查看， 展开Get message选项，点击GetMessage(s)就能得到消息了。

            测试： https://blog.csdn.net/qq_41097820/article/details/88793329

        quenes:队列

                    Message

• Ready： 队列中等待消费的消息
• Unacked：队列中等待被确认的消息（此时消息已到达消费者，但是未被确认）
• Total：队列中消息总数

        admin：添加用户等，Tags指角色；添加virtual host（关联到用户access，起隔离作用，每个vhost本质上就是一个mini版的rabbitmq服务器，拥有自己的队列、交换机、绑定和权限机制）。

7、MQ中的最小对象：消息=消息描述符+用户数据，队列定义的长度制约消息的长度。队列：先进先出FIFO,对远程队列的访问需要使用”通道“。包含关系：消息<队列<队列管理器，三者组合唯一确定一个消息。

一般一个Message有两个部分：payload（有效载荷）和label（标签），payload顾名思义就是传输的数据，label是exchange的名字或者说是一个tag，它描述了payload，而且RabbitMQ也是通过这个label来决定把这个Message发给哪个Consumer

8、通道：应用在队列管理器与队列管理器之间的，单向的点对点的通信连接：

•     单一方向；

•     通常成对使用；

如果要在  队列管理器与队列管理器之间实现消息传输，必须在两个队列管理器上都要定义相应的通道。

9、RabbitMQ中生产者将消息发送到Exchange（交换器），由Exchange将消息路由到一个或多个Queue中（或者丢弃）。RabbitMQ中通过Binding将Exchange与Queue关联起来，这样RabbitMQ就知道如何正确地将消息路由到指定的Queue了。

10、对于rabbitmq来说，一个broker可以看成一个rabbitmq服务节点，，或者服务实例。也可以将一个broker看做一台rabbitmq服务器

11、rabbitmq有一个最大内存阈值，可以通过配置来实现。当接收的消息达到最大阈值时，rabbitmq不会再接收消息，并进入阻塞状态。rabbitmq有一个内存换页阈值，当达到换页阈值时，将当前内存内的消息放入到磁盘内，而此时会区分持久化消息和非持久化消息。持久化消息因为在接收到消息后就已经存入磁盘，所以在换页时不会重复存入磁盘。此时只会将非持久化消息存入到磁盘内。

12、当内存使用超过配置的阈值或者磁盘剩余空间低于配置的阈值时，rabbitmq会出现告警。此时会暂时阻塞客户端连接（显示blocked），并停止接收客户端发来的消息，以避免服务器崩溃，客户端与服务端的心跳检测也会失效。

13、发送可靠性：确保消息成功发送到broker

        At most once：最多一次，消息可能会丢失，但不会重复传输

        At least once：最少一次，消息不会丢失，但可能重复传输

        Exactly once：恰好一次，保证每条消息都被传输到broker且仅传输一次

RabbitMQ支持：At most once和At least once

14、abbitMQ的六种工作模式：

• 1、Work queues

• 2、Publish/subscribe

• 3、Routing

• 4、Topics

• 5、Header 模式

• 6、RPC

15、Exchange Types有 fanout、direct、topic、headers这四种类型：

*queue对load balance的处理是完美的。对于多个Consumer来说，RabbitMQ 使用循环的方式（round-robin）的方式均衡的发送给不同的Consumer。

        fanout类型：广播模式，Exchange路由规则非常简单，它会把所有发送到该Exchange的消息路由到所有与它绑定的Queue中。

        direct类型： Exchange路由规则也很简单，它会把消息路由到那些binding key与routing key完全匹配的Queue中,binding key == routing key。（在绑定（Binding）Exchange与Queue的同时，一般会指定一个Binding key;但Binding key并不是在所有情况下都生效，它依赖于Exchange Type）

        topic message类型：binding key like routing key, 其中routing key中可以带 * 和 # 来做模糊匹配， “*”用于匹配一个单词，“#”用于0~N个单词.

        headers类型: Exchange不依赖于routing key与binding key的匹配规则来路由消息，而是根据发送的消息内容中的headers属性进行匹配。

*：Virtual host：即虚拟主机

当多个不同的用户使用同一个RabbitMQ server提供的服务时，可以划分出多个vhost，每个用户在自己的vhost创建exchange／queue