RabbitMQ 是一个开源的消息代理软件，实现了高级消息队列协议（AMQP，Advanced Message Queuing Protocol）。它充当了消息的中间件，用于在分布式系统中传递消息，提供了可靠的、异步的、跨应用程序的消息传递机制。
RabbitMQ 的主要特点和用途：
消息队列： RabbitMQ 作为消息队列（Message Queue）的一种实现，允许应用程序之间通过消息进行通信。消息队列可以解耦发送者和接收者，使得它们可以独立地演进和扩展。
解耦应用组件： 通过在系统的不同部分之间引入消息队列，可以实现应用组件的解耦。这意味着系统的不同部分可以独立开发、部署和扩展，而不必知道其他部分的实现细节。
异步通信： RabbitMQ 支持异步消息传递，允许发送者发送消息后立即继续执行，而不必等待接收者的响应。这有助于提高系统的并发性和响应性。
可靠性： RabbitMQ 提供了消息持久性选项，确保即使在代理重启后，也不会丢失已经发送的消息。这对于关键的业务消息和任务很重要。
灵活的消息路由： RabbitMQ 提供了灵活的消息路由和交换机（Exchange）的机制。通过不同类型的交换机和路由规则，可以实现多样化的消息路由策略。
工作队列： RabbitMQ 可以用作工作队列，允许任务的异步执行。生产者将任务放入队列，而工作者则从队列中取出任务并处理。这对于分布式任务处理和负载均衡非常有用。
发布/订阅模式： RabbitMQ 支持发布/订阅模式，允许多个消费者订阅同一队列，并接收相同的消息。这在实现广播和通知系统时很有用。
可扩展性： RabbitMQ 支持水平扩展，可以通过添加更多的节点来提高消息代理的处理能力。这有助于应对不断增长的负载。
社区支持和丰富文档： RabbitMQ 是一个开源项目，拥有庞大的社区支持和丰富的文档资源，使得使用和集成 RabbitMQ 相对容易。
集群模式
RabbitMQ 支持不同类型的集群模式，以确保高可用性和水平扩展。以下是 RabbitMQ 中常见的集群模式：
镜像队列集群（Queue Mirroring Cluster）： 这是 RabbitMQ 中最常见的集群模式。在这种模式下，队列的所有消息都会在集群中的多个节点上进行复制（镜像）。每个队列的复制体称为队列的镜像。如果一个节点失效，仍然可以从其他节点获取相同队列的消息。这提高了队列的可用性和可靠性。
所有者模式（Quorum Queues Cluster）： 在 RabbitMQ 3.8 版本及更高版本中引入了 Quorum Queues，这是一种基于 Raft 协议的新队列类型。Quorum Queues 提供更强的数据一致性和容错性，它们的数据存储在多个节点上。Quorum Queues 的集群模式称为所有者模式。在这种模式下，队列的所有者（leader）负责处理消息的写入和复制，而其他节点则充当跟随者（followers），复制队列的数据。
基于发布/订阅的集群模式（Publisher-Subscriber Cluster）： RabbitMQ 也支持发布/订阅模式的集群，其中交换机和队列的绑定关系会在所有集群节点之间共享。这样，无论消息生产者连接到哪个节点，消息都能够正确地发布到相应的队列。这种模式可以用于构建分布式的发布/订阅系统。
专业术语
ConnectionFactory（连接管理器）：应用程序与Rabbit之间建立tcp连接的管理器，程序代码中使用；
Channel（信道）：消息推送使用的通道；
Exchange（交换器）：用于接受、分配消息；
Queue（队列）：用于存储生产者的消息；类似存放商品的仓库和商店。是生产商品的工厂和购买商品的用户之间的中转站。
Broker：简单来说就是消息队列服务器实体
vhost：虚拟主机，一个broker里可以开设多个vhost，用作不同用户的权限分离.
producer：消息生产者，就是投递消息的程序。
consumer：消息消费者，就是接受消息的程序。
user:用户
Binding: exchange 与 queue 之间的虚拟链接，binding 中可以包含 routing key。binding 信息被保存到 exchange 的查询表中，用于消息的分发。
VB.Net
Copy
节点类型
磁盘节点（Disk Node）： 磁盘节点是 RabbitMQ 集群中的普通节点，它负责存储消息和元数据，以确保消息的持久性。磁盘节点会将消息写入磁盘，以便在节点重启后仍然可以访问。大多数节点都是磁盘节点，尤其是那些处理关键业务消息的节点。
内存节点（Memory Node）： 内存节点是一种轻量级的节点类型，它主要用于缓存消息，而不将它们写入磁盘。内存节点对于处理大量短暂消息的情况非常有用，因为它们能够更快地处理消息。然而，内存节点不能保证消息的持久性，因此在节点重启后可能会丢失消息。
镜像节点（Mirrored Node）： 镜像节点是 RabbitMQ 集群中的节点，它主要用于存储队列的镜像副本。镜像节点在集群中的其他节点上维护队列的镜像，以提供消息的冗余存储。这有助于提高队列的可用性和可靠性。
所有者节点（Quorum Queues Owner Node）： 在 RabbitMQ 3.8 版本及更高版本中引入的 Quorum Queues 中，引入了所有者节点的概念。所有者节点负责处理队列的写入和复制，而其他节点充当跟随者（followers），负责复制队列的数据。这种节点类型用于 Quorum Queues 集群模式。
192.168.50.138 rabbitmq-1
192.168.50.139 rabbitmq-2
192.168.50.140 rabbitmq-3
下载
wget https://github.com/rabbitmq/rabbitmq-server/releases/download/v3.7.10/rabbitmq-server-3.7.10-1.el7.noarch.rpm
下载erlang
wget https://cloud.7boe.top/d/HKOSS/%E8%BD%AF%E4%BB%B6%E5%8C%85/RabbitMQ/erlang-21.3.8.21-1.el7.x86_64.rpm
开启web管理页面
rabbitmq-plugins enable rabbitmq_management
创建用户并且授权
rabbitmqctl add_user wang passwd
rabbitmqctl set_user_tags wang administrator
列出用户
rabbitmqctl list_users
给权限
rabbitmqctl set_permissions -p "/" wang ".*" ".*" ".*"
拷贝
cp /usr/share/doc/rabbitmq-server-3.7.5/rabbitmq.config.example /etc/rabbitmq/rabbitmq.config
修改配置文件
61 {lookback_users,[]}
重启
systemctl restart rabbitmq-server
常用端口
4369 -- erlang端口
5672 --程序连接端口
15672 -- 管理界面ui端口
25672 -- server间内部通信口
创建数据目录
mkdir -p /data/rabbitmq/data
mkdir -p /data/rabbitmq/logs
chmod 777 -R /data/rabbitmq
chmod 777 -R /data/rabbitmq/logs
chown rabbitmq.rabbitmq /data/ -R
新写一个env变量配置文件
vim /etc/rabbitmq/rabbitmq-env.conf
RABBITMQ_MNESIA_BASE=/data/rabbitmq/data
RABBITMQ_LOG_BASE=/data/rabbitmq/logs
其他两台机器要拷贝cookie
scp root@10.31.162.200:/var/lib/rabbitmq/.erlang.cookie /var/lib/rabbitmq/
加入集群的机器要关闭 被加入的master要开启
rabbitmqctl stop_app
chmod 400 .erlang.cookie
chown rabbitmq.rabbitmq .erlang.cookie
rabbitmqctl start_app
以内存加入，然后开启
rabbitmqctl join_cluster --ram rabbit@rabbitmq-1
rabbitmqctl start_app
加入方式
（1）默认rabbitmq启动后是磁盘节点，在这个cluster命令下，mq-2和mq-3是内存节点，
mq-1是磁盘节点。
（2）如果要使mq-2、mq-3都是磁盘节点，去掉--ram参数即可。
（3）如果想要更改节点类型，可以使?命令rabbitmqctl change_cluster_node_type
disc(ram),前提是必须停掉rabbit应?
集群状态
rabbitmqctl cluster_status
页面查看
http://192.168.50.138:15672
一条命令即可
rabbitmqctl set_policy ha-all "^" '{"ha-mode":"all"}'
设置策略
rabbitmqctl set_policy [-p Vhost] Name Pattern Definition
-p Vhost： 可选参数，针对指定vhost下的queue进行设置
Name: policy的名称，可以定义
Pattern: queue的匹配模式(正则表达式),也就是说会匹配一组。
Definition：镜像定义，包括ha-mode,ha-params,ha-sync-mode
ha-mode:指明镜像队列的模式
all：表示在集群中所有的节点上进行镜像
exactly：表示在指定个数的节点上进行镜像，节点的个数由ha-params指定
ha-sync-mode：进行队列中消息的同步方式，有效值为automatic和manual
ha-params：ha-mode模式需要用到的参数