阿胶在那种网站做推广好,收费标准,头条淘宝联盟网站推广怎么做,网站做多少屏合适1.RabbitMQ集群模式介绍 普通集群 默认的集群模式#xff0c;比如有节点node1、node2和node3#xff0c;三个节点是普通集群#xff0c;但是他们仅有相同的元数据#xff0c;即交换机、队列的结构消息只存在其中的一个节点里面#xff0c;假如消息A存储在node1节点#x…1.RabbitMQ集群模式介绍 普通集群 默认的集群模式比如有节点node1、node2和node3三个节点是普通集群但是他们仅有相同的元数据即交换机、队列的结构消息只存在其中的一个节点里面假如消息A存储在node1节点消费者连接node1节点消费消息时可以直接取出来但如果消费者是连接的其他节点那RabbitMQ会把queue中的消息从存储它的节点中取出并经过连接节点转发后再发送给消费者假如node1故障那node2无法获取node1存储未被消费的消息如果node1持久化后故障那需要等node1恢复后才可以正常消费如果node1没做持久化后故障那消息将会丢失这个情况无法实现高可用性且节点间会增加通讯获取消息性能存在瓶颈该模式更适合于消息无需持久化的场景如日志传输的队列注意集群需要保证各个节点有相同的token令牌。erlang.cookie是erlang的分布式token文件集群内各个节点的erlang.cookie需要相同才可以互相通信 镜像集群大厂基本使用这个方式 队列做成镜像队列让各队列存在于多个节点中和普通集群比较大的区别就是【队列queue的消息message】会在集群各节点之间同步且并不是consumer获取数据时临时拉取而普通集群则是临时从存储的节点里面拉取对应的数据实现了高可用性部分节点挂掉后不影响正常的消费可以保证100%消息不丢失推荐奇数个节点结合LVSKeepalive进行IP漂移防止单点故障缺点由于镜像队列模式下消息数量过多大量的消息同步也会加大网络带宽开销适合高可用要求比较高的项目过多节点的话性能则更加受影响注意集群需要保证各个节点有相同的token令牌。erlang.cookie是erlang的分布式token文件集群内各个节点的erlang.cookie需要相同才可以互相通信 还有其他通过插件形成的集群比如Federation集群
2.普通集群docker搭建 Linux启动3个rabbitmq节点 # 节点一
docker run -d --hostname rabbit_host1 \
--name gen-rabbitmq1 \
-p 15672:15672 -p 5672:5672 \
-e RABBITMQ_NODENAMErabbit \
-e RABBITMQ_DEFAULT_USERadmin \
-e RABBITMQ_DEFAULT_PASSGen123 \
-e RABBITMQ_ERLANG_COOKIErabbitmq_cookie \
--privilegedtrue \
-v /usr/local/rabbitmq/1/lib:/var/lib/rabbitmq \
-v /usr/local/rabbitmq/1/log:/var/log/rabbitmq \
rabbitmq:management# 节点二
docker run -d --hostname rabbit_host2 \
--name gen-rabbitmq2 \
-p 15673:15672 -p 5673:5672 \
-e RABBITMQ_NODENAMErabbit \
-e RABBITMQ_DEFAULT_USERadmin \
-e RABBITMQ_DEFAULT_PASSGen123 \
-e RABBITMQ_ERLANG_COOKIErabbitmq_cookie \
--privilegedtrue \
-v /usr/local/rabbitmq/2/lib:/var/lib/rabbitmq \
-v /usr/local/rabbitmq/2/log:/var/log/rabbitmq \
--link gen-rabbitmq1:rabbit_host1 \
rabbitmq:management# 节点三
docker run -d --hostname rabbit_host3 \
--name gen-rabbitmq3 \
-p 15674:15672 -p 5674:5672 \
-e RABBITMQ_NODENAMErabbit \
-e RABBITMQ_DEFAULT_USERadmin \
-e RABBITMQ_DEFAULT_PASSGen123 \
-e RABBITMQ_ERLANG_COOKIErabbitmq_cookie \
--privilegedtrue \
-v /usr/local/rabbitmq/3/lib:/var/lib/rabbitmq \
-v /usr/local/rabbitmq/3/log:/var/log/rabbitmq \
--link gen-rabbitmq1:rabbit_host1 \
--link gen-rabbitmq2:rabbit_host2 \
rabbitmq:management参数说明 --hostname自定义docker容器的主机名
--link容器之间连接link不可或缺使得三个容器能互相通信
--privilegedtrue使用该参数容器内的root拥有真正的root权限否则容器出现permission denied
-v宿主机和容器路径映射
-e RABBITMQ_NODENAME缺省Unix*:rabbitHOSTNAME
-e RABBITMQ_DEFAULT_USERadmin登录用户名
-e RABBITMQ_DEFAULT_PASSGen123登录密码
-e RABBITMQ_ERLANG_COOKIE值必须相同也就是一个集群内相当于不同节点之间通讯的密钥erlang.cookie是erlang的分布式token文件集群内各个节点的erlang.cookie需要相同才可以互相通信配置集群 # 节点一配置集群
docker exec -it gen-rabbitmq1 bash
rabbitmqctl stop_app
rabbitmqctl reset
rabbitmqctl start_app
exit# 节点二加入集群--ram是以内存方式加入忽略该参数默认为磁盘节点
docker exec -it gen-rabbitmq2 bash
rabbitmqctl stop_app
rabbitmqctl reset
rabbitmqctl join_cluster --ram rabbitrabbit_host1
rabbitmqctl start_app
exit# 节点三加入集群--ram是以内存方式加入忽略该参数默认为磁盘节点
docker exec -it gen-rabbitmq3 bash
rabbitmqctl stop_app
rabbitmqctl reset
rabbitmqctl join_cluster --ram rabbitrabbit_host1
rabbitmqctl start_app
exit# 查看集群节点状态配置启动了3个节点1个磁盘节点和2个内存节点
rabbitmqctl cluster_status测试 node1主节点创建队列发送消息可以选择消息是否持久化node2和node3通过节点自身的web管控台可以看到队列和消息如果把node1节点停止node2和node3会收不到消息如果是在非主节点非磁盘节点创建队列和发送消息则其他队列可以显示 springboot项目配置集群 spring:rabbitmq:virtual-host: /password: Gen123username: adminaddresses: 192.168.101.128:5672,192.168.101.128:5673,192.168.101.128:56743.mirror镜像集群配置 背景 前面搭建了普通集群如果磁盘节点挂掉后如果没开启持久化数据就丢失了其他节点也无法获取消息所以我们这个集群方案需要进一步改造为镜像模式集群 策略policy介绍 RabbitMQ的策略policy是用来控制和修改集群的vhost队列和Exchange复制行为就是要设置哪些Exchange或者Queue的数据需要复制、同步以及如何复制同步 策略会同步同一个VirtualHost中的交换机和队列数据 Name自定义策略名称Pattern匹配符^代表匹配所有Definitionha-modeallha-sync-modeautomatic ha-mode指明镜像队列的模式可选下面的其中一个all表示在集群中所有的节点上进行镜像同步一般使用这个参数exactly表示在指定个数的节点上进行镜像同步节点的个数由ha-params指定nodes表示在指定的节点上进行镜像同步节点名称通过ha-params指定ha-sync-mode镜像消息同步方式manua手动automatic自动集群重启顺序 启动顺序磁盘节点–内存节点关闭顺序内存节点–磁盘节点最后关闭必须是磁盘节点否则容易造成集群启动失败、数据丢失等异常情况
