消息中间件——RabbitMQ（四）命令行与管控台的基本 *** 作！

RabbitMQ是2007年发布，是一个在AMQP(高级消息队列协议)基础上完成的，简称MQ全称为Message Queue, 消息队列（MQ）是一种应用程序对应用程序的通信方法，由Erlang（专门针对于大数据高并发的语言）语言开发，可复用的企业消息系统，是当前最主流的消息中间件之一，具有可靠性、灵活的路由、消息集群简单、队列高可用、多种协议的支持、管理界面、跟踪机制以及插件机制。

1消息 就是数据，增删改查的数据。例如在员工管理系统中增删改查的数据

2队列 指的是一端进数据一端出数据，例如C#中(Queue数据结构）

1消息队列指：一端进消息，一端出消息

2RabbitMQ就是实现了消息队列概念的一个组件，以面向对象的思想去理解，消息队列就是类，而RabbitMQ就是实例，当然不仅仅只有RabbitMQ,例如ActiveMQ，RocketMQ，Kafka，包括Redis也可以实现消息队列。

1在常见的单体架构中，主要流程是用户UI *** 作发起>

rabbitmq-plugins 用于启用（enable）、禁用（disable）和浏览（browse）插件。 这些 *** 作必须要由具有对 RabbitMQ 配置目录可写权限的用户执行。

一些插件依赖于其他的插件才能正常工作， rabbitmq-plugins 遍历这些依赖关系并且启用所有必需的插件。在 rabbitmq-plugins 命令行中列出的插件被标记为显式启用；依赖插件被标记为隐式启用。隐式启用的插件，在他们不需要的时候，在不再需要时会自动禁用。

启用、禁用和设置命令将更新插件文件，然后尝试连接到代理，并确保它运行所有启用的插件。默认情况下，如果无法连接到运行的代理（例如，如果它已停止），则会显示警告。指定 --online 或 --offline 来更改此行为。

该命令，显示所有的插件，它们的版本号，依赖关系和描述。显示的每个插件内容的前缀是在 [] 内加上两种状态指示符，第一个指示符是 " "，表示该插件没有被启用； "E" 的指示符表示该插件被显示启用； "e" 的指示符表示该插件被隐式启用； 或者 "!" 表示该插件被启用但缺失，因此无法运行。

第二个指示符是 "" 表示该插件没有运行； "" 表示在运行。如果给出了可选模式，则只显示名称匹配模式的插件。

通过命令 rabbitmq-plugins enable rabbitmq_management 来启动rabbitmq_management 插件，即可通过web端来查看集群的状态，有以下节点需要注意

如果RabbitMQ集群只有一个broker节点，那么该节点的失效将导致整个服务临时性的不可用，并且可能会导致message的丢失（尤其是在非持久化message存储于非持久化queue中的时候）。可以将所有message都设置为持久化，并且使用持久化的queue，但是这样仍然无法避免由于缓存导致的问题：因为message在发送之后和被写入磁盘并执行fsync之间存在一个虽然短暂但是会产生问题的时间窗。通过publisher的confirm机制能够确保客户端知道哪些message已经存入磁盘，尽管如此，一般不希望遇到因单点故障导致服务不可用。

如果RabbitMQ集群是由多个broker节点构成的，那么从服务的整体可用性上来讲，该集群对于单点失效是有d性的，但是同时也需要注意：尽管exchange和binding能够在单点失效问题上幸免于难，但是queue和其上持有的message却不行，这是因为queue及其内容仅仅存储于单个节点之上，所以一个节点的失效表现为其对应的queue不可用。

为了提高程序的吞吐量，保持消息的可靠性，一台机器挂了后，RabbitMQ能够正常生产，消费消息。

rabbitmq有三种模式：单机模式，普通集群模式，镜像集群模式

Demo级别的，一般只是本机测试玩玩而已，生产环境下不会用的。

在多台机器上启动多个rabbitmq实例，每个机器启动一个。

但是你创建的queue，只会放在一个rabbtimq实例上，但是每个实例都同步queue的元数据(存放含queue数据的真正实例位置)。消费的时候，实际上如果连接到了另外一个实例，那么那个实例会从queue所在实例上拉取数据过来。

示意图

这种方式确实很麻烦，也不怎么好，没做到所谓的分布式，就是个普通集群。

普通集群的方式，确实达到了消息的高可用，但没办法保证可靠性，没做到分布式，简而言之，只是一个普通的集群。

这种模式，才是所谓的rabbitmq的高可用模式，跟普通集群模式不一样的是，你创建的queue，无论元数据还是queue里的消息都会存在于多个实例上，然后每次你写消息到queue的时候，都会自动把消息到多个实例的queue里进行消息同步。

上图中每个节点有一个queue，生产者生产完毕数据后投递到指定交换机的队列，交换机的队列进行消息同步。

每个节点queue都有一个完整的rabbitmq节点，所以这种方式叫做镜像集群

好处： 任何一个节点宕机后，其它节点不受影响，正常使用

坏处：

确保机器中安装了Docker，若未安装，可看：云原生Docker入门 – 阿里云服务器Linux环境下安装Docker

查看拉取的镜像

成功运行

设置节点1

浏览器输入 您的ip地址:15673

再次测试即可成功~

File —> New —> Project —> Maven —> 直接Next 进入下一步创建普通的Maven工程即可

创建一个默认的Maven聚合工程，将src文件夹删除，该工程就是一个Maven聚合工程

引入依赖如下：

在项目内，新建一个Moudle，rabbitmq-order-producer 默认Maven工程，下一步即可

在项目内，新建一个Moudle，rabbitmq-order-cousumer 默认Maven工程，下一步即可

Maven聚合工程创建完成图

Maven依赖图

自行手写MainApplication即可

创建完成！

编写完成！

启动消费者

交换机

=

15674

15675

成功消费数据！

已成功同步消息~

以上就是关于消息中间件——RabbitMQ（四）命令行与管控台的基本 *** 作！全部的内容，包括:消息中间件——RabbitMQ（四）命令行与管控台的基本 *** 作！、Spring整合rabbitmq实践（一）：基础、厉害！一文了解消息中间件-RabbitMQ等相关内容解答，如果想了解更多相关内容，可以关注我们，你们的支持是我们更新的动力！