RabbitMQ集群

Posted 2023-03-20

参考技术A 1.允许消费者和生产者在RabbitMQ节点崩溃的情况下进行
2.通过添加更多节点来线性扩展消息通信的吞吐量

1.队列元数据：队列名称和它们的属性（是否可持久化，是否自动删除）
2.交换器元数据：交换器名称、类型、属性（是否持久化）
3.绑定元数据：一张表格，展示如何将消息路由到队列
4.vhost元数据：vhost内的队列、交换器和绑定提供命名空间和安全属性

1.单一节点的RabbitMQ会将所有的内部元数据存储在内存中，同时，将标记为可持久化的队列和交换器以及它们的绑定存储在硬盘上
2.引入RabbitMQ集群后：RabbitMQ需要追踪新的元数据，即集群节点位置、以及节点与已记录的其他类型元数据的关系
3.在RabbitMQ集群中可以选择将元数据存储至磁盘中或者存储在RAM中

1.不是每一个节点都有所有队列的完全拷贝
2.队列的信息（元数据、状态和内容）只会存在于其所有者的单节点而不会在其他非所有者的节点中存在
3.非所有者的节点只知道队列的元数据和指向该队列的所有信息的指针。
4.当集群节点崩溃时，该节点的队列和关联的绑定就会消失。

1.存储空间
2.性能：消息的发布需要将消息复制到备一个集群节点。对于持久化的消息来说，每条消息都会触发磁盘活动。没新增一个节点网络和磁盘的负载都会增加。

1.交换器只是一张查询报，是名称和队列的绑定表，不是实际上的消息路由器，信道才是实际的消息路由器
2.创建一个新的交换机，会在集群的所有节点上复制一份，所以每个节点都可访问到新的交换器
3.当消息已经发布，在路由完成之前节点故障可以通过“事务”或者“发送方确认”机制保证数据不丢失

1.在RabbitMQ中，节点要么是内存节点，要么是磁盘节点
2.内存节点：将所有的队列、交换器、绑定、用户、权限和vhost元数据定义都为仅存储在内存中
3.磁盘节点：将元数据存储在磁盘中
4.单节点应用智能是磁盘节点，否则每次重启后，节点的配置都会消失
5.RabbbitMQ集群中至少有一个磁盘节点，其他节点都可以为内存节点；磁盘节点保证集群配置免于重启，内存节点保证性能。

1.由于RabbitMQ不会将队列复制到所有节点，所以我们可以使用RabbitMQ提供的镜像概念去为队列去创建一个镜像队列，镜像队列会有一个主拷贝，这个主拷贝仅存在一个节点上(主队列)；镜像节点在集群中的其他节点有从拷贝（从队列）。

【rabbitMQ】rabbitMQ集群节点重新加入集群相关操作

参考技术A rabbitMQ 架构为  rabbitMQ + keepalived  镜像模式。

rabbitmq01  192.168.1.101

rabbitmq01  192.168.1.102

vip 192.168.1.110  在rabbitmq02 上

现在 rabbitmq01 故障 ，起不来，队列数据同步rabbbit02 有问题。

解决方法是将rabbitmq01 这个故障节点从集群中剔除，然后重新加入。

在rabbitmq02  192.168.1.102服务器上

剔除rabbitmq01节点

# rabbitmqctl cluster_status

# rabbitmqctl  forget_cluster_node  rabbit@192-168-1-101

# rabbitmqctl cluster_status

 

在rabbitmq01  192.168.1.101服务器上

停止rabbitmq相关进程

# systemctl  stop rabbitmq-server

# ps aux | grep rabbit | grep -v grep | awk ‘print $2’| xargs kill -9

移除rabbitmq相关数据文件

# mkdir /kingdee/rabbitmqBackup

# mv  /var/lib/rabbitmq/*  /kingdee/rabbitmqBackup/

重新启动rabbitmq

# systemctl  start  rabbitmq-server

# ps aux | grep rabbit

创建rabbitMQ用户

# rabbitmqctl  add_user   mquser    rabbitMQ@123

注：此密码为安装时设置的rabbitMQ密码

# rabbitmqctl  list_users

# rabbitmqctl  set_user_tags   mquser    administrator

# rabbitmqctl  set_permissions   -p  /   mquser    '.*'  '.*'  '.*'

# rabbitmqctl  stop_app

# rabbitmqctl  join_cluster   rabbit@192-168-1-102

# rabbitmqctl  cluster_status

# rabbitmqctl  start_app

# systemctl  start  keepalived

在rabbitmq02  192.168.1.102服务器上

添加策略同步策略

# rabbitmqctl   set_policy ha-all  "^"   '"ha-mode":"all","ha-sync-mode":"automatic"'

RabbitMQ Cluster群集安装配置

https://www.cnblogs.com/elvi/p/7736661.html

Network partition detected

Mnesia reports that this RabbitMQ cluster has experienced a network partition. 

There is a risk of losing data. Please read RabbitMQ documentation about network partitions and the possible solutions.

https://www.rabbitmq.com/partitions.html