erlang安装版本一致
RabbitMQ安装版本一致
以下示例使用 192.168.73.134 和 192.168.73.135 构建 Rabbitmq 集群
RabbitMQ 是用 erlang 开发的。Cluster 非常方便,因为 erlang 本质上是一种分布式语言,但它不支持负载均衡。在第一次模拟考试中,Rabbit模式可以分为三种:单模、共模和镜像模式。
第一次模拟考试:最简单的情况,非集群模式。
普通模式:默认集群模式。
about Queue Message实体只存在于一个节点,A,B这两个节点只有相同的元数据,即队列结构。
当消息进入A节点的Queue中后,consumer从B节点被拉取时,RabbitMQ会临时在A、B之间传递消息,B中的消息实体发送给consumer。
因此消费者尝试连接每个节点并从中获取消息。也就是说,对于同一个逻辑队列,需要在多个节点建立物理队列。否则不管是A还是B的消费者,出口总是在A,会有瓶颈。
这个模型有问题 A 节点故障后, B 节点无法检索到 A 节点中尚未消费的消息实体。
如果消息持久化完成,则等待A节点恢复后才能被消费;如果没有持久化,那么将不会有更多的节点
镜像模式:将需要的队列做成镜像队列,存在于多个节点中。属于RabbitMQ的HA方案。
该模式解决了上述问题。其本质与普通模式的区别在于消息实体会主动在镜像节点之间同步,而不是在镜像节点消费者取数据时临时拉取数据。
这种模式的副作用也很明显。除了降低系统性能外,如果图像队列数量过多,大量消息进入,集群内的网络带宽也会被这种同步通信大量消耗。
因此适用于对可靠性要求较高的场合(后面会详细介绍这种模式,我们目前搭建的环境就属于这种模式)。
(1)集群中的基本概念
RabbitMQ 的集群节点包括内存节点和磁盘节点。
顾名思义,内存节点将所有数据放在内存中,而磁盘节点将数据放在磁盘上。但是,如上所述,如果在传递消息时开启消息持久化,即使是内存节点,数据仍然安全地放置在磁盘上。
RabbitMQ 集群可以共享用户、虚拟主机、队列、交换器等。必须在所有节点上复制所有数据和状态。例外是当前属于创建它的节点的消息队列,尽管它们是可见的并且可以被所有节点读取。RabbitMQ 节点可以动态加入集群。一个节点可以加入集群,也可以从集群环集群进行基本的负载均衡。
集群中有两种类型的节点:
内存节点:只将状态保存到内存(例外:持久队列的持久内容会保存到磁盘)
磁盘节点:将状态保存到内存和磁盘。
内存节点不写入磁盘,但性能优于磁盘节点。在一个集群中,只需要一个磁盘节点来保存状态,
如果集群中只有内存节点,则不能停止,否则所有的状态、消息等都会丢失。
思路:
为了实现RabbitMQ的高可用,我们先搭建普通集群模式,再配置镜像模式,实现高可用。在Rabbit集群前面增加了一个反向代理,生产者和消费者通过反向代理访问RabbitMQ集群。
架构如下:
(2)集群模式配置
step1:局域网配置
在安装好的三个节点服务器中,分别修改/etc/hosts文件
1. vim /etc/hosts
192.168.73.134 节点 1
192.168.73.135 节点 2
step2:为不同节点之间的相同认证设置Erlang Cookie
Erlang 集群中每个节点的魔法 cookie 来实现,这个 cookie 存储在 /var/lib/rabbitmq/.erlang.cookie 中,该文件的权限为 400。
因此,必须保证每个节点的 cookie 一致,否则节点之间将无法通信。
从主节点采用 copy 的方式来保持 Cookie 的一致性:
1. chmod 777 /var/lib/rabbitmq/.erlang.cookie
2. scp -p 22 /var/lib/rabbitmq/.erlang.cookie [email protected]:/var/lib/rabbitmq/
复制后,检查文件的用户、组和权限是否符合要求。如果没有,请修改它。在.erlang.cookie之后恢复,否则可能会遇到错误:
3. chown rabbitmq:rabbitmq .erlang.cookie
4. chmod 400 /var/lib/rabbitmq/.erlang.cookie
step3:使用-分离运行每个节点
在RabbitMQ重启后设置cookie:
1. cd /sbin
2.rabbitmqctl停止
3. rabbitmq-server 启动
这里正常重启可能会提示节点实例再次运行。如果出现,使用以下命令启动:
1. ps -aux | 格雷厄尔
2. kill -9 {pid}
3. RABBITMQ_NODE_PORT=5678 RABBITMQ_NODENAME=rabbit@node1 ./rabbitmq-server -detached
RABBITMQ_NODE_PORT=5678 RABBITMQ_NODENAME=rabbit@node2 ./rabbitmq-server -detached
ps:上面的5678是因为rabbitmq端口改成了5678,而且nodename和hosts的设置是一致的。
依次启动所有节点。
step4:查看各个节点的状态
1.查看启动端口:netstat -lntp
活动 Internet 连接(仅限服务器)
Proto Recv-Q Send-Q 本地地址 外地址 状态 PID/程序名称
tcp 0 0 0.0.0.0:4369 0.0.0.0:* 听 27321/epmd
tcp 0 0 0.0.0.0:22 0.0.0.0:* LISTEN 760/sshd
tcp 0 0 127.0.0.1:25 0.0.0.0:* LISTEN 1066/master
tcp 0 0 0.0.0.0:15678 0.0.0.0:* 听 27862/beam.smp
tcp 0 0 0.0.0.0:25672 0.0.0.0:* 听 27862/beam.smp
tcp6 0 0 :::5678 :::* 听 27862/beam.smp
tcp6 0 0 :::8080 :::* 听 964/java
tcp6 0 0 :::4369 :::* 听 27321/epmd
tcp6 0 0 :::22 :::* LISTEN 760/sshd
tcp6 0 0 ::1:25 :::* LISTEN 1066/master
tcp6 0 0 127.0.0.1:8005 :::* 听 964/java
tcp6 0 0 :::8009 :::* 听 964/java
2.查看rabbitmq启动状态:
rabbitmqctl -n rabbit1@node1 状态
rabbitmqctl -n rabbit1@node2 状态
3.访问http://bbitraq后台打开后,可以查看网页是否可以访问
step5:创建和部署集群
以rabbit@rabbitmq2和rabbit@rabbitmq1组成集群,rabbitmq2作为内存节点(一个硬盘节点就够了);
兔子MQ2:
1.停止节点2的应用:rabbitmqctl -n rabbit@node2 stop_app
在节点 rabbit@rabbitmq2 上停止兔子应用程序
2.添加节点1作为内存节点rabbitmqctl -n rabbit@node2 join_cluster --ram rabbit@node1
集群节点 rabbit@node2 与 rabbit@node1
3、启动节点2的应用:rabbitmqctl -n rabbit@node2 start_app
起始节点rabbit@node2
step6:查看集群状态
1.查看节点1的集群状态:rabbitmqctl -n rabbit@node1 cluster_status
节点rabbit@node1的集群状态
[{nodes,[{disc,[rabbit@node1]},{ram,[rabbit@node2]}]},
{running_nodes,[rabbit@node1]},
{cluster_name,<<"rabbit@node1">>},
{分区,[]},
{警报,[{rabbit@node1,[]}]}]
2.查看节点2的集群状态:rabbitmqctl -n rabbit@node2 cluster_status
节点rabbit@node2的集群状态
[{nodes,[{disc,[rabbit@node1]},{ram,[rabbit@node2]}]},
{警报,[{rabbit@node1,[]}]}]
3.后台查看集群状态:
至此,rabbitmq 集群搭建完毕。
上面配置了RabbitMQ默认的集群模式,但是不保证队列的高可用。虽然可以将切换和绑定复制到集群中的任何节点,但不会复制队列内容。这种模式虽然解决了一些节点压力,但是队列节点宕机直接导致队列无法使用,只能等待重启。因此,需要关闭队列节点,否则故障也可以正常使用。要将队列的内容复制到集群中的每个节点,需要创建一个图像队列。
第一步:添加负载均衡器
在负载均衡器方面,F5的BIG-IP、Radware的AppDirector等商用产品都是硬件架构的产品,可以实现高处理能力。但是这些产品的高价会让人望而却步,所以我们也有软件负载均衡解决方案。互联网公司常用的软件LB有LVS、HAProxy、Nginx等,LVS是内核层产品,主要负责第四层的数据包转发,使用比较复杂。HAProxy 和 Nginx 是应用层产品,但 Nginx 主要用于处理 HTTP,因此选择 HAProxy 作为 RabbitMQ 前端的 lb。
1.安装HAProxy(在192.168.73.136安装在HAProxy上)
yum -y 安装haproxy
2.修改haproxy.config进行配置
vim /etc/haproxy/haproxy.config
添加以下配置:
听rabbitmq_cluster 0.0.0.0:5678
模式tcp
平衡循环
服务器rabbitmaster 192.168.73.134:5678 检查inter 2000 上升2 下降3
服务器rabbitslave 192.168.73.135:5678 检查inter 2000 上升2 下降3
修改HaProxy配置后,重启可能会提示端口绑定失败。在这种情况下,请执行以下命令:
setebool -P haproxy_connect_any=1
负载均衡器将监听 192.168.73.136 的 5678 端口,并轮询我们 192.168.73.134 和 192.168.73.135 的 5678 端口这两个节点。这样磁盘节点不会同时受到影响,除了故障。
第二步:配置Rabbitmq策略
在任意节点上执行:
rabbitmqctl set_policy ha-all "^" '{"ha-mode":"all"}'
上面的命令会将所有队列设置为镜像队列,即队列会被复制到每个节点,每个节点的状态会保持一致
第三步:使用负载服务器发送消息
客户端使用负载服务器172.16.3.110(panyuntao3)发送消息,队列复制到所有节点。到这里我们就完成了RabbitMQ集群的高可用配置。
通过上述相信大家对RabbitMQ集群搭建已经有所了解,如果您想了解更多相关知识,可以关注一下极悦的RabbitMQ教程,里面的内容细致全面,由浅到深,适合小白学习,希望对大家的学习能够有所帮助。
你适合学Java吗?4大专业测评方法
代码逻辑 吸收能力 技术学习能力 综合素质
先测评确定适合在学习